Как создавали Kafka consumer для проверки сообщений?

Расскажите о реальном consumer: как задавали подключение, топик, группу, десериализацию и стартовую позицию. Проверка должна находить именно своё событие и иметь ограниченное ожидание.

Уникальный идентификатор теста помогает не спутать чужие сообщения со своим результатом. Учитывайте повторы, задержки и момент подписки: сообщение может быть опубликовано раньше начала чтения. После проверки закрывайте consumer и освобождайте тестовые ресурсы. Не используйте рабочую consumer group, чтобы тест случайно не забирал сообщения у приложения или не менял его offsets.