NewAsyncProducer creates a new Kafka async producer or panics if failed.

NewConsumer creates a new Kafka consumer or panics if failed.

ErrAsyncProducer is an error when Kafka async producer wasn't opened.

ErrClosePartitionConsumer is an error when a partition consumer wasn't properly closed.

ErrCloseProducer is an error when async producer wasn't closed properly.

ErrConsumePartition is returned when failed to consume partition.

ErrGetPartitions is returned when failed to get partitions.

ErrNewConsumer is an error when new Kafka consumer can't be created.

AsyncProducer is a Kafka async producer.

Broker is the struct for Kafka broker.

Config holds the list of brokers and topics.

Consumer is a Kafka consumer.

Topic is the struct for Kafka topic.