Spring Boot学习笔记：kafka应用
2024-09-17 23:31:04
Kafka作为众多Java消息中间件之一，有诸多优点。本文讲解Kafka的应用。学习一个新的知识点，建议先找一个demo，越简单越好的demo，跑通这个demo，了解大致原理，然后在分析细节，详细了解概念。
首先需要三个文件，分别是：
- 官网下载kafka_2.11-0.11.0.0的压缩包，下载地址是 http://kafka.apache.org/downloads ，解压之
- SpringBoot搭建的kafka的生产者（项目名KafkaProducer），负责产生消息，推送到kafka集群中，项目地址：https://gitee.com/colin220/KafkaProducer
- SpringBoot搭建的Kafka的消费者（项目名KafkaConsumer），负责接收消息，从kafka集群中接收消息，项目地址：https://gitee.com/colin220/KafkaConsumer
接下来就是启动项目了，步骤如下：
- 进入kafka_2.11-0.11.0.0目录下，打开命令行界面，输入./bin/windows/zookeeper-server-start.bat ./config/zookeeper.properties 可以启动zookeeper
- 仍在kafka_2.11-0.11.0.0目录下，另外再打开一个命令行界面，输入 ./bin/windows/kafka-server-start.bat ./config/server.properties 可以启动kafka
- 启动项目KafkaProducer
- 启动项目KafkaConsumer
然后就是验证阶段，步骤如下：
- 在浏览器访问 http://localhost:8080/jsa/kafka/producer?data=Hello 这样KafkaProducer就向kafka集群中（本次应用只部署了一个kafka服务）发送一条消息
- 然后可在KafkaConsumer控制台下看到下图，说明消费者监听并接收到了这个消息
至此，这个demo就运行成功了
（非原创 侵删 文章来源http://javasampleapproach.com/java-integration/distributed-system/how-to-start-spring-kafka-application-with-spring-boot）
最新文章
- Java深度历险（五）——Java泛型
- Android Studio常见问题 -- uses-sdk:minSdkVersion 8 cannot be smaller than version 9 declared in library
- VerbalExpressions ——另类正则表达式
- Visual Studio 2008 使用 WinCE 5.0 Emulator
- MATLAB学习笔记（三）——程序设计
- Front End中Javascript兼容问题收集（转）
- tomcat 6.0 压缩功能
- 账户管理groupadd groupmod groupdel usermod usermod userdel
- Error Correct System（模拟）
- burpsuite + sqlmap 日志导出批量扫描
- 传Lua对象到Cpp
- 开源框架Slidingmenu的基本使用
- 0. General-purpose tools （通用工具 8个）
- MongoDB 和 NoSQL简介
- python下彻底解决浏览器多标签打开与切换问题
- DAG 模型 stacking boxes 动态规划
- PHP操作MySQL数据库--PHP的应用
- https方式下 git push 每次都要输入密码的解决办法
- Android之使用枚举利弊及替代方案
- FTP列出文件列表