# Functions
NewBatchIterator returns a new instance of BatchIterator, configured from the provided ConsumerConfig and ConsumerSettings.
NewIterator returns a new instance of Iterator, configured from the provided ConsumerConfig and ConsumerSettings.
NewPublisher returns a new instance of Publisher, configured from the provided ProducerConfig and ProducerSettings.
NewTransaction returns a new instance of Transaction, configured from the provided ProducerConfig, ProducerSettings, ConsumerConfig and BatchConsumerSettings.
# Variables
DefaultBatchConsumerSettings stores the default values for BatchConsumerSettings.
DefaultConsumerSettings stores the default values for ConsumerSettings.
DefaultProducerSettings stores the default values for ProducerSettings.
# Structs
BatchConsumerSettings the optional settings for a batched Kafka consumer.
BatchIterator models a Kafka consumer that iterates over batches of records.
ConsumerConfig defines the configuration properties needed for initializing a Kafka consumer.
ConsumerSettings the optional settings for a Kafka consumer.
Iterator models a simple Kafka consumer, which yields a single message at a time.
KerberosConfig defines the configuration properties needed for using SASL Kerberos authentication.
PlainSASLConfig defines the configuration properties needed for using SASL/PLAIN authentication.
ProducerConfig defines the configuration properties needed for initializing a Kafka producer.
ProducerSettings the optional settings for a Kafka producer.
PrometheusConfig defines the configuration properties needed for exposing Prometheus metrics.
Publisher models a Kafka producer.
ScramSASLConfig defines the configuration properties needed for using SASL/SCRAM-SHA-512 authentication.
Topic models a Kafka producer with a set, "hardcoded" destination topic.
Transaction models a Kafka transaction session.
TransactionalTopic models a transactional Kafka producer with a set, "hardcoded" destination topic.