jstorm集成kafka，kafka-reader向zk写入offset失败

alibaba / jstorm

Enterprise Stream Process Engine

http://jstorm.io

Apache License 2.0

3.92k stars 1.8k forks source link

Open gohitbear opened 7 years ago

gohitbear commented 7 years ago

jstorm-kafka版本2.2.4 jstorm-core版本2.2.4 kafka-reader从kafka中取出数据后没有向zk写入实时的offset 3个partition的kafka topic，kafka-reader的并行度为3 zk集群中kafka自身的offset正常

longdafeng commented 7 years ago

你再debug 一下呢，按道理是ok的，你关注一下ack里面有没有更新offset的操作

tongh-qtl commented 7 years ago

请问你的jstorm-kafka是在哪里下的 @gohitbear