NewConsumer creates a new Consumer instance.

NewProducer creates a new Producer instance.

NewPubSub creates a new PubSub instance.

DefaultClientRack is the default client rack identifier.

DefaultFlushTimeout is the default timeout duration for producer Flush call.

DefaultPartitionAssignmentStrategy is the default partition assignment strategy used by group members.

DefaultPollInterval is the default maximum interval Poll call can block.

DefaultPubSubEventsChanSize is the default size of events buffered channel.

Consumer is the Kafka consumer.

ConsumerConfig is the Kafka consumer configuration.

Producer is the Kafka producer.

ProducerConfig is the Kafka producer configuration.

PubSub implements the publish–subscribe messaging pattern using a Kafka producer and consumer pair.

PubSubConfig is the PubSub configuration.