python - Confluent_kafka Producer 不向主题发布消息
问题描述
我试图在我的 Raspberry 上安装 Kafka。并在“hello-kafka”主题上进行测试:
~ $ /usr/local/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic hello-kafka
>Test message 1
>Test message 2
>Test message 3
>^Z
[4]+ Stopped /usr/local/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic hello-kafka
$ /usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic hello-kafka --from-beginning
Test message 1
Test message 2
Test message 3
^CProcessed a total of 3 messages
然后我试图检查服务器是否在另一台机器上工作。检查动物园管理员:
(venv)$ telnet 192.168.1.10 2181
Trying 192.168.1.10...
Connected to 192.168.1.10.
Escape character is '^]'.
srvr
Zookeeper version: 3.6.0--b4c89dc7f6083829e18fae6e446907ae0b1f22d7, built on 02/25/2020 14:38 GMT
Latency min/avg/max: 0/0.8736/59
Received: 10146
Sent: 10149
Connections: 2
Outstanding: 0
Zxid: 0x96
Mode: standalone
Node count: 139
Connection closed by foreign host.
还有卡夫卡:
(venv) $ telnet 192.168.1.10 9092
Trying 192.168.1.10...
Connected to 192.168.1.10.
Escape character is '^]'.
tets
Connection closed by foreign host.
然后我写了一个 Python 脚本:
# -*- coding: utf-8 -*-
from confluent_kafka import Producer
def callback(err, msg):
if err is not None:
print(f'Failed to deliver message: {str(msg)}: {str(err)}')
else:
print(f'Message produced: {str(msg)}')
config = {
'bootstrap.servers': '192.168.1.10:9092'
}
producer = Producer(config)
producer.produce('hello-kafka', value=b"Hello from Python", callback=callback)
producer.poll(5)
有脚本输出(没有任何打印):
(venv) $ python kafka-producer.py
(venv) $ python kafka-producer.py
(venv) $
Kafka 中没有新消息:
$ /usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic hello-kafka --from-beginning
Test message 1
Test message 2
Test message 3
^CProcessed a total of 3 messages
$ ^C
有人可以告诉我我做错了什么吗?
解决方案
正确的解决方法是更新您的代理配置server.properties
以正确设置广告侦听器。如果您的客户端无法解析raspberrypi
,则将广告侦听器更改为您的客户端可以访问的内容,即 IP 地址:
advertised.listeners=PLAINTEXT://192.168.1.10:9092
更改/etc/hosts
客户端上的文件是一种解决方法,对于使用 Raspberry Pi 的测试项目来说是可以的,但作为一般的最佳实践应该不鼓励(因为客户端一旦移动到另一台没有/etc/hosts
黑客)
推荐阅读
- html - 如何在底部修复页脚?
- javascript - 设置 sessionStorage,更改图像
- ruby-on-rails - 如何从 Rails Admin 的搜索过滤器中排除字段?
- .net - .net core 2.1 VS 2017 basic web api 抛出“无法访问此站点”
- reactjs - React - 变量/范围问题
- html - css - div 顶部的 svg 圆角曲线形状
- excel - 双击可在表格列的顶部和底部之间跳转
- c - 使用类型转换将 char 数组分配给结构
- java - java中带茎的星形图案左帕斯卡箭头
- sql - 困难的 SQL Server 查询 - 将 12 小时时间转换为 24 小时时间