CreateKafkaConsumer creates a goroutine that subscribes to Kafka topic.

DeleteKafkaConsumer deletes goroutine created by CreateKafkaConsumer.

GetSASLConfiguration build SASL configuration for kafka.

GetTLSConfiguration build TLS configuration for kafka, return tlsConfig associated with kafka connection.

NewConsumer returns new consumer.

ErrorCrtFileMandatory when private key is provided but certificate not.

ErrorKeyFileMandatory when certificate is provided but private not.

ErrorUsernameOrPasswordMandatory when username or password is not provided.

Consumer represents a Sarama consumer group consumer.