我在 VirtualBox 来宾上有两台服务器,每个服务器都是 ubuntu。我可以从我的主机通过 SSH 连接到两台机器,以及两台机器之间的 SSH,这样它们都具有 natnetwork。
我在一台服务器 kafka 上运行,如下所述:
https://kafka.apache.org/quickstart https://kafka.apache.org/quickstart
所以我提出了单节点zookeeper
卡夫卡接着开始了。我添加了测试主题。
(全部在机器上。10.75.1.247)
我正在尝试从另一台机器列出该节点上的主题:
bin/kafka-topics.sh --list --bootstrap-server 10.75.1.247:9092
来自机器B (10.75.1.2)
这样做会一遍又一遍地导致错误:
[2019-09-16 23:57:07,864] WARN [AdminClient clientId=adminclient-1] Error connecting to node ubuntukafka:9092 (id: 0 rack: null) (org.apache.kafka.clients.NetworkClient)
java.net.UnknownHostException: ubuntukafka
at java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)
at java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1505)
at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1364)
at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1298)
at org.apache.kafka.clients.ClientUtils.resolve(ClientUtils.java:104)
at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.currentAddress(ClusterConnectionStates.java:403)
at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.access$200(ClusterConnectionStates.java:363)
at org.apache.kafka.clients.ClusterConnectionStates.currentAddress(ClusterConnectionStates.java:151)
at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:943)
at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:288)
at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.sendEligibleCalls(KafkaAdminClient.java:925)
at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1140)
at java.base/java.lang.Thread.run(Thread.java:834)
它确实解析了名称
(说 ubuntukafka 而不是 ubuntukafkanode)但失败了。
我缺少什么?我使用kafka错误吗?我想我可以拥有一个不错的 kafka 服务器,所有其他带有数据的服务器也可以生成信息。那么其他很多消费者可以从哪里读取到这些信息呢?
最终我想测试的是我是否可以向我的 kafka 服务器发送消息:
bin/kafka-console-producer.sh --broker-list 10.75.1.247:9092 --topic test
甚至稍后使用 python 向服务器生成消息。
from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='10.75.1.247:9092')
for _ in range(100):
try:
producer.send('test', b'some_message_bytes')
except:
print('doh')