我通过zk获取到了这些信息,但是从zk获取的groupid和我实际的groupid怎么对应?百度说一个是low level一个是high level的
本机不需要有kafka运行 本机有kafka的那些脚本和依赖lib就行 把ip换成运行的kafka的ip就可以
我这个代码不在kafka那台机上运行,怎么去执行这个脚本呢?
我的正常执行,你可以检查一下hosts,jdk环境变量 消费者组参数是否正确 第二个和第三个命令结果是一样的
执行脚本报错org/apache/kafka/common/protocol/SecurityProtocol;这个和jar包没关系吧,你那边java怎么去执行命令的?