spring-kafka这kafka的访问客户端jar包,与srping的项目集成在一想,这个问题是 kafka的客户端jar与kafka服务端的版本不一致产生。为什么要删除/kafka-acl/DelegationToken,是因为这个路径是错误的客户端创建的,所以要删除
sparing-Kafka 是在集群内部环境嘛? 在哪里? 为什么删除/kafka-acl/BelegationToken就恢复了,原理什么的可以简单说明一下吗?(或者给一个参考博客)
上面 zkClient.sh更正为 zkCli.sh
在zookeeper中,使用 zkClient.sh -server localhost 登陆到zk中, broker 的版本是 0.11的