IsTopicExist returns whether an error is caused by a topic already existing.

NewConsumer returns a new Kafka Consumer.

NewErroredProducer returns a Producer that fails when any methods are called.

NewLeastBytesPartitioner function takes topic as an argument, but it is not used.

NewManager returns a Kafka Manager.

NewProducer returns a new Kafka Producer.

Message represents a Kafka message.

Consumer represents a Kafka Consumer.

Manager represents an object that can manage Kafka Producers and Consumers.

Producer represents a Kafka producer.