Проверка кафки потребителя без запуска сервиса на докере

Question

У меня есть несколько микросервисов (пружинная загрузка), и некоторые из них взаимодействуют с другими с помощью сообщения kafka.

Когда я хочу протестировать потребителя kafka в службе 1 (проверьте, что kafka может получать сообщения от других), Мне нужно запустить Docker для службы 1, затем запустить Docker для службы 2, а затем выполнить отладку для службы 2 с некоторыми изменениями в тесте.

Может ли он отправить kafka в службу 1 (запустить в Docker) беззапустить сервис 2?Как это можно сделать.Спасибо

Answer 1

Если вам нужно только

, проверьте, что kafka может получать сообщения от других

, вы можете запустить службу 1, а затем прочитать сообщения на kafka, используяkafka-console-consumer.sh

Посмотрите здесь: Как просмотреть сообщение kafka