Kafka程序例子

深藏阁楼爱情的钟 2021-11-24 00:38 190阅读 0赞

### Kafka安装 ###

安装Kafka前需要安装Zookeeper，因为Kafka需要Zookeeper做协调（Zookeeper不会参考[Linux安装Zookeeper][Linux_Zookeeper]，我是安装在windows环境下，步骤差不多）安装好了之后安装Kafka [Kafka下载地址][Kafka]  
安装完成后：  
1、启动zookeeper  
2、启动Kafka cmd命令进入Kafka安装目录 ，目录位置如下  
![目录][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0OTI2NjU_size_16_color_FFFFFF_t_70]  
进入这个目录之后 输入启动命令 ： .\\bin\\windows\\kafka-server-start.bat .\\config\\server.properties  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0OTI2NjU_size_16_color_FFFFFF_t_70 1]  
启动成功！

### 用Kafka自带消息生产者消费者演示消息队列 ###

在安装目录下用topic创建topic：  
cmd命令：.\\bin\\windows\\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic test-kafka-topic (不懂参数可以参考博主上一篇博客[基础概念][Link 1]）  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0OTI2NjU_size_16_color_FFFFFF_t_70 2]  
可以看见创建了一个test-kafka-topic 的topic

查看已经存在的主题： .\\bin\\windows\\kafka-topics.bat --list --zookeeper localhost:2181  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0OTI2NjU_size_16_color_FFFFFF_t_70 3]

创建一个生产者命令：.\\bin\\windows\\kafka-console-producer.bat --broker-list localhost:9092 --topic test-kafka-topic  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0OTI2NjU_size_16_color_FFFFFF_t_70 4]  
例外启动一个cmd 创建消费者： .\\bin\\windows\\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-kafka-topic --from-beginning  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0OTI2NjU_size_16_color_FFFFFF_t_70 5]  
–from-beginning 指从头开始消费

谢谢观看，下一篇用Java代码编写Kafka简单入门例子

[Linux_Zookeeper]: https://blog.csdn.net/u014492665/article/details/85198809
[Kafka]: https://www.apache.org/dyn/closer.cgi?path=/kafka/2.2.1/kafka_2.11-2.2.1.tgz
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0OTI2NjU_size_16_color_FFFFFF_t_70]: /images/20211122/31d39d5011db475eac7f10db2a59cf76.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0OTI2NjU_size_16_color_FFFFFF_t_70 1]: /images/20211122/5fac747ed16b481ab650f874512c7e23.png
[Link 1]: https://blog.csdn.net/u014492665/article/details/97421797
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0OTI2NjU_size_16_color_FFFFFF_t_70 2]: /images/20211122/416c790d59c9447dbe6dfffab87afa66.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0OTI2NjU_size_16_color_FFFFFF_t_70 3]: /images/20211122/bf30209b79604f93aa5fe56fca22494e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0OTI2NjU_size_16_color_FFFFFF_t_70 4]: /images/20211122/ddee85092b3144478d236ba66ac26fbe.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0OTI2NjU_size_16_color_FFFFFF_t_70 5]: /images/20211122/d1c991db5e4b4973adafd7bfff8126ab.png