Kafka4:Topic命令

Kafka4:Topic命令

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
notion image
  • --partitions 1 分区
  • --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> 更新系统默认的配置。
notion image