在执行kafka命令增加或删除topic的时候,发现总是报错。
Address in use?端口还是ip被占用了。只能禁用了,再执行命令。
禁用代码:
然后就可以拉~
总体步骤:
1.先进入k8s的kafka pod
2.进入kafka的bin目录
3.两个unset
4.执行
kafka-topics.sh --create xxxxxxxxx --zookeeper xxxx1:2181,xxxx2:2181,xxxx3:2181 --topic xxxxxxxx --replication-factor 1 --partitions 1