Topics命令
kafka-topics.sh --option1 value1 --option2 value2 ...
参数名称 | 说明 |
---|---|
–create | 创建新的主题 |
–delete | 删除主题 |
–describe | 列出给定主题的详细信息 |
–help | 打印使用信息 |
–list | 列出所有可用的主题 |
–zookeeper | 必需(仅当使用旧的使用者时)连接zookeeper的字符串。可以给出多个URL以允许故障转移 |
–bootstrap-server <String: server to connect to> | 指定要连接的Kafka服务器。如果提供了此选项,则不需要直接连接到Zookeeper |
Producer命令
kafka-console-producer.sh --broker-list <broker-list>