已安装Zookeeper 并启动
1、下载安装包
https://link.zhihu.com/?target=https%3A//archive.apache.org/dist/kafka/2.4.1/kafka_2.12-2.4.1.tgz
2.解压后将config目录下server.properties文件的log.dirs值修改为如:自己解压的地址的data目录下,如图所示:
启动监听如图
3.打开cmd窗口,进入解压的bin目录里的windos的bat脚本所在的目录并执行如下命令
kafka-server-start.bat ..\..\config\server.properties
如果没看到报错,基本就算启动成功了
4、创建一个topic为test 打开一个新的cmd窗口
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
———————————————————————————————————————————
查看 test主题的详情 kafka-topics.bat --bootstrap-server localhost:9092 --describe --topic test
Topic:test:主体的名称是test。
Partition:分区编号是0,代表只有一个分区,编号从0开始
Leader:每个分区多个副本的主节点编号,这个在集群中才会是其它值,这里是单机模式,值等于唯一副本编号
Replicas:副本编号,也是从0开始。
修改分区数 注意:分区数只能增加,不能减少
kafka-topics.bat --bootstrap-server localhost:9092 --alter --topic test --partitions 2
删除 topic
kafka-topics.bat --bootstrap-server localhost:9092 --delete --topic test
———————————————————————————————————————————
5、在刚才创建topic的窗口里创建一个消息的生产者
kafka-console-producer.bat --broker-list localhost:9092 --topic test
———————————————————————————————————————————
新打开一个cmd窗口,来创建一个消费者来接收生产者生产的消息
1)消费 test主题中的数据。 只能消费消费者出现之后的数据
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
2)把主题中所有的数据都读取出来(包括历史数据)
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
———————————————————————————————————————————
6、然后我们用刚才的生产者来发送消息,看看消费者能不能收到:
————————————————