В интеграционном тесте с Embedded Kafka настоящий брокер запускается внутри тестового процесса. Аннотация
@EmbeddedKafka создаёт топик greetings, поэтому внешняя Kafka и Docker не нужны.KafkaTemplate публикует сообщение, а отдельный KafkaConsumer получает запись через KafkaTestUtils.getSingleRecord. Перед отправкой тест считывает сообщения, созданные ApplicationRunner при запуске, чтобы проверка не забрала старую запись.Тест подтверждает доставку от продюсера до брокера и обратно к потребителю, но не результат работы метода с
@KafkaListener. Эффект обработчика стоит проверять отдельно: так транспортная интеграция и бизнес-логика не маскируют ошибки друг друга.