Open hejiaji opened 6 years ago
The config:
[general] pidfile="burrow.pid" [zookeeper] servers=[ "localhost:2181" ] timeout=6 root-path="/burrow" [evaluator.mystorage] class-name="caching" minimum-complete=1.0 [cluster.test] class-name="kafka" servers=[ "localhost:9092" ] [consumer.test] class-name="kafka" cluster="test" servers=[ "localhost:9092" ] [consumer.consumer-group-id] class-name="kafka" cluster="test" servers=[ "localhost:9092" ] [httpserver.default] address=":8000" timeout=300 [storage.default] class-name="inmemory" workers=20 intervals=30 min-distance=60
From the screenshot we can see that the consumer offset is committed
Any insight of this?
BTW, the Kafka version is 2.0, it works well in kafka 1.0.1
I think there is an issue with Kafka 2.0. I believe it is related to this library that burrow uses https://github.com/Shopify/sarama
The config:
From the screenshot we can see that the consumer offset is committed
Any insight of this?