ConsumeMessages consumes messages from Kafka and calls the handler function for each message.

ConvertMessageToProto converts a message to a protobuf message.

ConvertProtoToMessage converts a protobuf message to a byte array.

NewConsumer creates a new Kafka consumer and subscribes to the given topics.

NewProducer creates a new Kafka producer.

ProduceMessage produces a message to the given topic.

IConsumerServer is an interface for a consumer server.

ConsumerServiceRegistrationOption is a type alias for a function that takes a key store configuration, a groupID and a list of topics and returns an error.