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
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.
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