# Functions
NewBroker creates a new instance of Kafka broker.
NewConsumer creates a new instance of Kafka cluster consumer.
NewConsumerWrapper creates a new instance of consumer wrapper.
NewLocalOffsetManager creates a new instance of a local offset manager.
NewLocalOffsetStore creates a new instance of local offset store.
NewManager creates a new instance of Kafka manager.
NewOptions creates a new Options object with default values.
NewPartitionCheckpoints creates a new instance of partition checkpoints.
NewProducer creates a new instance of Kafka producer.
ToPartitionOffset creates a new PartitionOffset map from a raw map.
WithClusterVersion kafka cluster version.
WithLogWriter sets the writer to write the internal Sarama logs to.
WithSASL enables SASL authentication.
WithTLS enables TLS.
# Constants
ControllerBrokerLabel controller node marker.
SASLHandshakeV0 version 0.
SASLHandshakeV1 version 1.
SASLMechanismNone SASL authentication is not enabled.
SASLMechanismPlain plain text authentication mode.
SASLMechanismSCRAM256 sha-256 authentication mode.
SASLMechanismSCRAM512 sha-512 authentication mode.
# Variables
DefaultClusterVersion default cluster version.
ErrEmptyEnvironment occurs when the provided environment is empty.
ErrEmptyTopic occurs when the provided topic is empty.
# Structs
API represents a Kafka API.
Broker represents a Kafka broker node.
BrokerMeta holds a Kafka broker's metadata.
ClusterMetadata Kafka cluster metadata.
ConfigEntry represents a Kafka config.
Consumer represents a new Kafka cluster consumer.
ConsumerGroup represents a consumer group.
ConsumerGroupDetails represents consumer group details.
ConsumerWrapper wraps Sarama consumer and its underlying client.
Event Kafka event.
GroupMember represents a consumer group member.
GroupMemberDetails represents consumer group member details.
LocalOffsetManager represents a type to manage local offset storage.
LocalOffsetStore represents a type to manage partition offsets locally.
LogEntry represents a broker log entry.
LogFile represents a broker log file.
Manager a type to query Kafka metadata.
Offset represents an offset pair for a given partition.
Options holds the configuration settings for kafka consumer.
PartitionCheckpoints holds a list of explicitly requested offsets (if applicable).
PartitionMeta represents partition metadata.
Producer represents a wrapper around Sarama producer.
Topic represents a Kafka topic with metadata.
TopicMetadata holds metadata for a topic.
# Type aliases
APIByCode sorts the API list by code.
BrokersByID sorts the brokers by ID.
Callback the function which will get called upon receiving a message from Kafka.
ConfigEntriesByName sorts configuration entries by name.
ConsumerGroupDetailsByName sorts a list of consumer group details by group name.
ConsumerGroups the map of consumer groups keyed by consumer group ID.
GroupMembers represents a map to hold consumer group members.
Option represents a configuration function.
PartitionMetaByID sorts partition metadata by partition ID.
PartitionOffset represents a map of partition offset pairs.
SASLHandshakeVersion SASL handshake version.
TopicPartitionOffset represents a map of topic offset pairs for all the partitions.
TopicPartitions a map of topic and partition list.
TopicsByName sorts the topic list by name.