我在独立服务器上安装kafka,并尝试将数据流传输到mongodb。当启动kafka服务时,bin/kafka-server-start.sh config/server.properties我收到一个警告:警告试图通过没有打开连接的通道发送响应,连接id为0(kafka.network.processor)
尽管如此,在生产者处输入的数据和在消费者处显示的数据并没有问题。
但我认为这会导致数据写入mongodb。启动数据流后,我没有数据写入mongodb。
有人能帮忙解决这个问题吗?非常感谢。
1条答案
按热度按时间llycmphe1#
因此,通道被选择器关闭,因为它空闲的时间太长