NewConsumerComponent returns a new ConsumerComponent.

NewProducerComponent returns a new ProducerComponent.

WithConsumerAppName sets the app name for the ConsumerComponent.

WithConsumerBrokers sets the brokers for the ConsumerComponent.

WithConsumerLogger sets the logger for the ConsumerComponent.

WithConsumerTLSDir sets the location of the TLS directory for the ConsumerComponent.

WithConsumerTopics sets the topics for the ConsumerComponent.

WithProducerBatchSize sets the batching size for the ProducerComponent.

WithProducerBatchTimeout sets the batching timeout for the ProducerComponent.

WithProducerBrokers sets the brokers for the ProducerComponent.

WithProducerLogger sets the logger for the ProducerComponent.

WithProducerSASLMechanism sets the sasl mechanism for the ProducerComponent.

WithProducerTLSDir sets the location of the TLS files for the ProducerComponent.

WithSASLMechanism sets the sasl mechanism for the ConsumerComponent.

ProducerComponent represents a Kafka producer component.

ConsumerComponentOption represents an option for the ConsumerComponent.

ProducerComponentOption represents an option for the ProducerComponent.