- 当前位置：首页 >系统运维 >轻松上手 Spring Boot & Kafka 实战！
轻松上手 Spring Boot & Kafka 实战！
发布时间：2025-11-05 07:39:25 来源：创站工坊 作者：系统运维
Kafka集群安装、轻松配置和启动
Kafka需要依赖zookeeper，上手a实并且自身集成了zookeeper，轻松zookeeper至少需要3个节点保证集群高可用，上手a实下面是轻松在单机linux下创建kafka3个节点伪集群模式。
1、上手a实下载包
下载地址：http://kafka.apache.org/downloads
2、轻松解压包
tar -zxvf kafka_2.11-1.0.0.tgz\mv kafka_2.11-1.0.0 kafka1\mv kafka_2.11-1.0.0 kafka2\mv kafka_2.11-1.0.0 kafka33、上手a实创建ZK集群
修改ZK配置文件：kafka1-3/config/zookeeper.properties分别修改对应的轻松参数。
dataDir=/usr/local/kafka/zookeeper1 dataLogDir=/usr/local/kafka/zookeeper/log clientPort=2181 maxClientCnxns=0 tickTime=2000 initLimit=100 syncLimit=5 server.1=127.0.0.1:2888:3888 server.2=127.0.0.1:4888:5888 server.3=127.0.0.1:6888:7888/usr/local/kafka/zookeeper1-3目录下分别创建myid文件，云服务器上手a实内容对应1~3
启动ZK，轻松分别进行Kafka1-3目录:
bin/zookeeper-server-start.sh config/zookeeper.properties &启动报文件失败，上手a实需要手动创建文件目录并赋予对应的轻松权限。
4、上手a实创建Kafka集群
配置文件：kafka1-3/config/server.properties分别修改对应的轻松参数。
broker.id=1 zookeeper.connect=localhost:2181,localhost:2182,localhost:2183 listeners=PLAINTEXT://192.168.12.11:9091 log.dirs=/tmp/kafka-logs-1启动Kafka，分别进行Kafka1-3目录:
bin/kafka-server-start.sh config/server.properties &启动报文件失败，需要手动创建文件目录并赋予对应的权限。香港云服务器
5、集群测试
在kafka1上面发送消息：
bin/kafka-console-producer.sh --broker-list localhost:9091 --topic test在kafka2、kafka3消费消息：
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic my-replicated-topicSpring Boot 集成 Kafka 实战
1、添加spring-kafka依赖
<spring-kafka.version>2.1.0.RELEASE</spring-kafka.version> <!-- spring-kafka--> <dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka</artifactId> <version>${spring-kafka.version}</version> </dependency>2、添加Spring Boot的自动配置
自动配置类：
org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration配置属性类：
org.springframework.boot.autoconfigure.kafka.KafkaProperties Spring: kafka: bootstrap-servers: - 192.168.101.137:9091 - 192.168.101.137:9092 - 192.168.101.137:9093 producer: retries: 0 batch-size: 16384 buffer-memory: 33554432 key-serializer: org.apache.kafka.common.serialization.StringSerializer value-serializer: org.apache.kafka.common.serialization.StringSerializer consumer: group-id: foo auto-offset-reset: earliest enable-auto-commit: true auto-commit-interval: 100 key-deserializer: org.apache.kafka.common.serialization.StringDeserializer value-deserializer: org.apache.kafka.common.serialization.StringDeserializer3、发送消息
@Autowired private KafkaTemplate kafkaTemplate; @GetMapping("/send") public Object send(String msg) { kafkaTemplate.send("test", "name", msg); return "send ok"; }4、接收消息
在任何bean里面，添加@KafkaListener，支持消息接收。
@KafkaListener(topics = "test") public void processMessage(String content) { logger.info("收到消息, topic:test, msg:{}", content); } 服务器租用服务器租用源码下载亿华云IT技术网益华科技企商汇IT资讯网源码库香港云服务器技术快报益华IT技术论坛云站无忧亿华灵动IT资讯网极客码头云智核运维纵横益强前沿资讯益强智未来亿华云计算码力社全栈开发益强IT技术网益强编程堂编程之道极客编程汇智坊益强智囊团亿华智造创站工坊亿华科技益强科技益强科技益华科技科技前瞻益华科技益强资讯优选亿华智慧云益强编程舍智能时代思维库多维IT资讯码上建站
- Copyright © 2025 Powered by 轻松上手 Spring Boot & Kafka 实战！,创站工坊 滇ICP备2023006006号-44sitemap