Hi All, We recently upgraded kafka from 0.8 to 0.10 with security features enabled (ssl/sasl/acls). One thing noticed is the offset is not longer kept on zookeeper any more in 0.10 release. Though this is new feature for new version, we like to still keep the offsets stored on zookeeper in short terms without breaking the scripts/monitoring utilities that use old style offset. By following the documentation, I have enabled dual.commit.enabled=true and offset.storage=zookeeper. After rolling restarted, the offsets are still not saved in zookeeper. There is no errors recorded in server or zookeeper logs. Can someone suggest how I can further debug this issue? BTW, I am using logstash as kafka client to read data from kafka topic.
Thanks, Wei
