Какими средствами именно в автотестах работали с Kafka?

Назовите реальные клиентские библиотеки или обёртки, которыми тесты отправляли и читали сообщения Kafka. Отдельно объясните организацию топиков, consumer group и ожидания результата.

Проверка должна связывать событие с конкретным тестом по безопасному уникальному признаку и иметь ограниченное ожидание. Учитывайте смещения, повторы и возможное получение чужих сообщений. Десериализация, схема и подтверждение бизнес-эффекта важнее самого факта чтения. Если пользовались готовой утилитой команды, так и скажите; не приписывайте себе разработку всей Kafka-инфраструктуры.