卡夫卡消费者调用休息电话时出错
Kafka Consumer Error On Calling Rest Call
当消费者调用rest模板但远程主机不可用时如何处理以下错误。
[kafka-coordinator-heartbeat-thread | dirty_node] INFO o.a.k.c.c.i.AbstractCoordinator - [Consumer clientId=consumer-dirty_node-7, groupId=dirty_node] Member consumer-dirty_node-7-8fdc41f2-4a8a-41ca-9234-b6b56490d28d sending LeaveGroup request to coordinator kafka-2.qat.test.net:9093 (id: 2147483645 rack: null) due to consumer poll timeout has expired. This means the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time processing messages. You can address this either by increasing max.poll.interval.ms or by reducing the maximum size of batches returned in poll() with max.poll.records.
错误：读取 tcp 127.0.0.:443:: 现有连接被远程主机强行关闭。
注意：我没有设置任何轮询超时。这是默认的。
我应该增加轮询时间还是减少轮询时间。
根据 documentation，max.poll.interval.ms 是使用消费者组管理时 poll() 调用之间的最大延迟。
因此您应该增加 max.poll.interval.ms 并使其比您的其余模板的超时时间长。
当消费者调用rest模板但远程主机不可用时如何处理以下错误。
[kafka-coordinator-heartbeat-thread | dirty_node] INFO o.a.k.c.c.i.AbstractCoordinator - [Consumer clientId=consumer-dirty_node-7, groupId=dirty_node] Member consumer-dirty_node-7-8fdc41f2-4a8a-41ca-9234-b6b56490d28d sending LeaveGroup request to coordinator kafka-2.qat.test.net:9093 (id: 2147483645 rack: null) due to consumer poll timeout has expired. This means the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time processing messages. You can address this either by increasing max.poll.interval.ms or by reducing the maximum size of batches returned in poll() with max.poll.records.
错误：读取 tcp 127.0.0.:443:: 现有连接被远程主机强行关闭。
注意：我没有设置任何轮询超时。这是默认的。 我应该增加轮询时间还是减少轮询时间。
根据 documentation，max.poll.interval.ms 是使用消费者组管理时 poll() 调用之间的最大延迟。
因此您应该增加 max.poll.interval.ms 并使其比您的其余模板的超时时间长。