Leo*_*rfk 5 python-3.x apache-kafka confluent-kafka-python
我的卡夫卡消费者有问题。当我在本地主机中运行我的消费者时,他运行正确,但是当我在另一个环境中运行我的消费者时,他显示此错误
%6|1629836068.968|rdkafka#consumer-1| [thrd:ssl://kafka-events:11101/12101]:ssl://kafka-events:11101/12101:已断开连接(处于状态 UP 684744 毫秒后)
我不知道这个错误的根本原因是什么。
我的 kafka 消费者是用 python 3 开发的,具有汇合的 kafka DeserializingConsumer。
| 归档时间: |
|
| 查看次数: |
1007 次 |
| 最近记录: |