答复: kafka streams consumer ERROR The coordinator is not aware of this member.

2018-04-10 Thread 杰 杨
Kafka 1.0.0 Kafka-stream 1.0.0 发送自 Windows 10 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>应用 发件人: Guozhang Wang 发送时间: Wednesday, April 11, 2018 1:39:17 AM 收件人: users@kafka.apache.org 主题: Re: kafka streams consumer ERROR The coordinator is not

Re: kafka streams consumer ERROR The coordinator is not aware of this member.

2018-04-10 Thread Guozhang Wang
1) It means the consumer has not call poll() for quite some time and hence be kicked out by the consumer coordinator (the new consumer use heartbeat as the failure detection protocol, you can read more on the wiki docs about its design). If you have high variance of record processing latency, e.g.

kafka streams consumer ERROR The coordinator is not aware of this member.

2018-04-10 Thread 杰 杨
Hi: when I run kafka streams applications for a period of time and will be throw ERROR .1) questions org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.error.301|[Consumer clientId=filter-StreamThread-1-consumer, groupId=filter] Offset commit failed on partition sample-1 at offset