我的卡夫卡消费者有问题。当我在 localhost 中运行我的消费者时,他运行正确,但是当我在另一个环境中运行我的消费者时,他显示此错误
%6|1629836068.968|rdkafka#consumer-1| [thrd:ssl://kafka-events:11101/12101]:ssl://kafka-events:11101/12101:断开连接(在 684744 毫秒后处于 UP 状态)
我不知道这个错误的根本原因是什么。
我的 kafka 消费者是在 python 3 中使用 confluent kafka DeserializingConsumer 开发的。