В последние несколько дней я изучал kafka и проводил тесты для мелочей и прочее.
Я уже мог успешно получать сообщения на моем локальном хосте, даже от другого p c в той же сети. Но теперь, когда я пытаюсь подключиться к удаленному серверу (на самом деле это тот же p c, и тот же брокер и topi c, у меня просто есть два поставщика услуг inte rnet, поэтому я просто переключился, чтобы попробовать с publi c ip) я не получаю никаких сообщений. Кроме того, я получаю это в консоли:
[main] DEBUG org.apache.kafka.common.network.Selector - [Consumer clientId=consumer-1, groupId=0a396775-94e2-46a0-a6bf-08f0d848ffc9] Connection with /xxx.xx.xxx.xxx disconnected
java.net.ConnectException: Connection timed out: no further information
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)
at org.apache.kafka.common.network.PlaintextTransportLayer.finishConnect(PlaintextTransportLayer.java:50)
at org.apache.kafka.common.network.KafkaChannel.finishConnect(KafkaChannel.java:216)
at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:531)
at org.apache.kafka.common.network.Selector.poll(Selector.java:483)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:539)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:262)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:212)
at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:249)
at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:326)
at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1251)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1220)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1159)
at com.okta.javakafka.kafkajava.SimpleConsumer.main(SimpleConsumer.java:39)
Я попробовал пару тестов проверки связи, и соединение прошло успешно. Так что, может быть, я пропускаю что-то другое в случае удаленного подключения к kafka?
Если кто-то может помочь, я был бы очень признателен
******** ****** РЕДАКТИРОВАТЬ ****************************
слушателей на моем server.properties:
listeners = PLAINTEXT: //192.168.1.101: 9092 (локальный ip)
advertised.listeners = PLAINTEXT: //200.x.xxx.xxx: 9092 (publi c ip)