Hi, all. There are two problems when we use kafka about partitions assigned
to consumers.
Problem 1: Partitions will be reassigned to consumers when consumer online
or offline, then the messages latency become higher.
Problem 2: If we have two partitions, only two consumers can consume
Hi,all! Our program uses the high level consumer api(the version is 0.8.x).
Sometimes the program will throw an exception in the 42th row in
kafka.utils.IteratorTemplate class，the content is "throw new
IllegalStateException("Expected item but none found.")".
I think it is a race condition
Hi, all. I use the kafka which the version is 0.8.2.1. When partiton
transferring， KafkaProducer needs about 5mins to recovery, so do you know how
to fix it.
Thanks!!!
rg.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode
for /consumers"
can you help me? thx!
--
揣立武
美团网技术工程部基础服务组
手机： 13522216605
邮箱： chuail...@meituan.com
地址： 北京市朝阳区望京东路6号望京国际研发园三期F座
邮编： 100102
