Feature: add Kafka related unit tests

[YarikRevich]

Apply the following testcontainers unit

kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.1"));
kafka.start();