Запускаем KafkaTest

Трогать код в пакете internal нельзя (но можно если очень хочется и обоснованно, что без этого нельзя)

По факту трогать надо KafkaProducer и TopicListener

Нужно чтобы каждый листенер работали по своей семантике - at most once, at least once, exactly once - это и проверяет тест