1. 常用命令
# 查看
root@redis01:/usr/local/kafka# ./bin/kafka-topics.sh --bootstrap-server redis01:9092 --list
# 创建
root@redis01:/usr/local/kafka# ./bin/kafka-topics.sh --bootstrap-server redis01:9092 --topic first --create --partitions 1 --replication-factor 3
# 查看详细信息
root@redis01:/usr/local/kafka# ./bin/kafka-topics.sh --bootstrap-server redis01:9092 --topic first --describe
# 修改分区,分区只能增加,不能减少!!!
root@redis01:/usr/local/kafka# ./bin/kafka-topics.sh --bootstrap-server redis01:9092 --topic first --alter --partitions 3
- --replication-factor 3 副本数
参数 描述
--bootstrap-server <String: server toconnect to> 连接的Kafka Broker 主机名称和端口号。
--topic <String: topic> 操作的topic 名称。
--create 创建主题。
--delete 删除主题。
--alter 修改主题。
--list 查看所有主题。
--describe 查看主题详细描述。
--partitions <Integer: # of partitions> 设置分区数。
--replication-factor<Integer: replication factor> 设置分区副本。
--config <String: name=value> 更新系统默认的配置。