这里写目录标题
- 启动kafk
- 创建一个测试主题
- 查看所有主题
- 查看first详细信息
- 修改分区数(分区数只能增加 不能减少)
- 删除主题
- 生产者生产数据
- 消费命令
启动kafk
安装目录下
.\bin\windows\kafka-server-start.bat .\config\server.properties
创建一个测试主题
安装目录下
.\bin\windows\kafka-topics.bat --create --topic first --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
参数 描述
- 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> 更新系统默认的配置。
查看所有主题
.\bin\windows\kafka-topics.bat --bootstrap-server localhost:9092 --list
查看first详细信息
.\bin\windows\kafka-topics.bat --bootstrap-server localhost:9092 --describe --topic first
- PartitionCount
- ReplicationFactor
- Partition
修改分区数(分区数只能增加 不能减少)
.\bin\windows\kafka-topics.bat --bootstrap-server
localhost:9092 --alter --topic first --partitions 3
删除主题
.\bin\windows\kafka-topics.bat --bootstrap-server
localhost:9092 --delete--topic first
生产者生产数据
.\bin\windows\kafka-console-producer.bat --bootstrap-server localhost:9092 --topic first
消费命令
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic first --from-beginning
- bootstrap-server <String: server toconnect to> 连接的 Kafka Broker 主机名称和端口号。
- topic <String: topic> 操作的 topic 名称
- from-beginning 从头开始消费。
- group <String: consumer group id> 指定消费者组名称。
