启动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> 指定消费者组名称。