NewService initializes a new Kafka Service.

ErrAsyncProduce is returned when an asynchronous message production fails.

ErrFetchMessages is returned when fetching messages from Kafka topics fails.

ErrKafkaClientSetup is returned when setting up the Kafka client fails.

ErrKafkaPing is returned when a ping to Kafka brokers fails.

ErrMarshalData is returned when marshaling message data into JSON fails.

ErrMarshalKey is returned when marshaling the message key into JSON fails.

ErrSyncProduce is returned when a synchronous message production fails.

Config defines the configuration for the Kafka Service.

Service provides an abstraction for Kafka producers and consumers.