目录
- 1 问题
- 2 下载
1 问题
本地启动一个kafka ,然后可以实现生产者 消费者
2 下载
https://downloads.apache.org/kafka/
 
选择一个版本下载
 
下载之后解压

 
 修改配置
 
 
 
 修改好之后,就保存,之后先启动zookper ,之后再启动 kafka
 
zookeeper-server-start.bat ....\config\zookeeper.properties &
kafka-server-start.bat    D:\kafka\kafka_2.13-3.6.0\config\server.properties

 
 命令行 链接zookper

 2.4.1、创建topics
 以管理员权限新开一个命令提示窗口,进入D:\bigdata\kafka\2.12-3.5.1\bin\windows目录,执行以下命令,创建topics:
kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
2.4.2、查看topics
 查看topics列表:
bin/kafka-topics.sh --bootstrap-server kafkahost:9092 --list
2.4.3、打开一个producer(生产者)
 以管理员权限新开一个命令提示窗口,进入D:\bigdata\kafka\2.12-3.5.1\bin\windows目录,
执行以下命令,打开一个producer(生产者):
kafka-console-producer.bat --broker-list localhost:9092 --topic test
2.4.4、打开一个consumer(消费者)
 以管理员权限新开一个命令提示窗口,进入D:\bigdata\kafka\2.12-3.5.1\bin\windows目录,执行以下命令,打开一个consumer(消费者):
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
2.4.5、测试发送和接受消息
 以上打开的窗口不要关闭,然后就可以在producer(生产者)控制台窗口输入消息并回车。在消息输入过后,很快consumer(消费者)窗口就会显示出producer(生产者)发送的消息。
2.4.5.1、producer(生产者)发送消息
 在producer(生产者)控制台窗口输入消息:
2.4.5.2、consumer(消费者)接收消息
 在consumer(消费者)控制台窗口查看消息:
我们发现,producer(生产者)发送的消息被consumer(消费者)接受到了。
 这里乱码是字符集的问题。
2.4.5、收不到消息,常见情况
 在consumer没有打开之前,就在producer里面发送了消息
 producer和consumer使用的topic不一致
 
 
 以上就是 本地启动成功 kafka
![Mybatis-Plus 3.3.2 发布,新增优雅的数据安全保护姿势[MyBatis-Plus系列]](https://img-blog.csdnimg.cn/img_convert/2f2356937db21222bc8858daf57b2793.png)


















