先测试一下。
1、换个新的zk,3.4.9
2、换个新版本的kafka。
3、什么都不用动,复制上面代码执行。
13:42:12.432 [StreamThread-1] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Group coordinator lookup for group streams-pipe1 failed: The group coordinator is not available.