Я разрабатываю потоковый API с Apache версией Kafka (2.1.0). У меня есть кластер Kafka и внешний сервер. Внешний сервер будет генерировать данные для использования в кластере Kafka.
Обозначим внешний Сервер как E , а кластер - C. E не имеет установленной Kafka. Я запускаю на нем JAR-файл для создания сообщений. Вот фрагмент кода для Свойства производителя:
properties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "bootstrapIp:9092");
properties.put(ProducerConfig.CLIENT_ID_CONFIG, "producer");
Я установил bootstrapIp для IP-адреса брокера Kafka.
На стороне кластера я запускаю консоль потребителя с помощью этой команды:
kafka-console-consumer --bootstrap-server bootstrapIp:9092 --topic T1 --from-beginning
Я задаю bootstrapIp для кластера bootstrap IP-адрес сервера.
Когда работает производитель и потребитель в кластере, он работает очень хорошо, но когда я запускаю производителя на внешнем сервере ( E ) и потребителя в кластере (C ) данные не используются.
В localhost все работает нормально, даже когда я запускаю производителя и потребителя в кластере (C), все работает нормально, при запуске внешне я не могу использовать данные в кластере.
Пинг из кластера (C) на внешний сервер ( E ) работает, но я не могу понять, где именно проблема.
Я не могу понять, как использовать сообщения с внешнего сервера.
РЕДАКТИРОВАТЬ
С внешнего сервера ( E ), т.е. lnet ( bootstrapIp ): te lnet bo otstrapIp 9092 и это работает, я не понимаю проблемы