主题操作 kafka-topics.sh脚本可以用来管理主题. --topic 指定操作的主题名，除了创建之外都可以使用正则表达式，但是要使用\转义。另外命名不要使用两个下划线开头（__表示系统内建的主题，比如__consumer_offset），主题命名中不要将.和_混用(kafka会将.最终转换成_)。 创建主题 注意: --bootstrap-server 后不要使用localhost, 而是跟上主机名 --zookeeper localhost:2181/kafka 这... ... [查看更多]
Views: 623