GetDefaultConfig returns default specific config.

Manager creates a simple Kafka Manager with default config to perform administrative tasks.

NewConsumer initializes a default consumer client for consuming messages.

NewConsumerFromPartition initializes a default consumer client for consuming messages.

NewConsumerOption specifies consumer policies.

NewMessage creates message that is publishable.

NewProducer initializes a new client for publishing messages.

NewStreamReader creates a stream reader by wrapping a kafka consumer.

NewStreamWriter creates a stream writer by wrapping a kafka producer.

Producer initializes a default producer client for publishing messages.

SetLogger turns on sarama log.

WithBrokers specifies brokers for kafka consumer.

WithDisableAutoMark gives clients the ability to turn off auto-marking which means clients are responsible to mark the offset themselves This is useful when clients want to retry certain message they fail to process.

WithInitialOffset specifies the initial offset to use if no offset was previously committed.

OffsetNewest lets consumers retrieve the newest possible message.

OffsetOldest lets consumers retrieve the oldest possible message.

StrategyHash distributes writes based on 32-bit FNV-1 Hash function.

Uses the same strategy for assigning partitions as the java clienthttps://github.com/apache/kafka/blob/0.8.2/clients/src/main/java/org/apache/kafka/common/utils/Utils.java#L244.

StrategyLeastBytes distributes writes to nodes with least amount of traffic.

StrategyRoundRobin distributes writes evenly.

ConsumerGroupOption is the default for Consumer Group.

CreateTopicOptions is an options that will be applied to topic creation.

Message is a data structure representing kafka messages.

PartitionInfo contains metadata for a given partition.

Consumer defines interface for kafka consumer.

GroupInfo is a map of PartitionInfo.

ListTopicsResponse is a map of TopicInfo.

Strategy is a type of routing rule.

TopicInfo is a map of GroupInfo.

TopicPartitionRequest lets Kafka manager know which topic to modify and the target number of partitions it should have.