To add to Stephen's answer, you might want to change your zkroot from /broker to something else as Kafka uses it to maintain the metadata.
Nevertheless, you will need to check zk for existence of offset and not local directories of Kafka cluster.
To add to Stephen's answer, you might want to change your zkroot from /broker to something else as Kafka uses it to maintain the metadata.
Nevertheless, you will need to check zk for existence of offset and not local directories of Kafka cluster.