轻松上手 Spring Boot & Kafka 实战 _Spring

Kafka集群安装、配置和启动Kafka需要依赖zookeeper，并且自身集成了zookeeper，zookeeper至少需要3个节点保证集群高可用，下面是在单机linux下创建kafka3个节点伪集群模式。
1、下载包

下载地址：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 kafka3

3、创建ZK集群
修改ZK配置文件：kafka1-3/config/zookeeper.properties分别修改对应的参数。

dataDir=/usr/local/kafka/zookeeper1dataLogDir=/usr/local/kafka/zookeeper/logclientPort=2181maxClientCnxns=0tickTime=2000initLimit=100syncLimit=5server.1=127.0.0.1:2888:3888server.2=127.0.0.1:4888:5888server.3=127.0.0.1:6888:7888

/usr/local/kafka/zookeeper1-3目录下分别创建myid文件，内容对应1~3
启动ZK，分别进行Kafka1-3目录:

bin/zookeeper-server-start.sh config/zookeeper.properties &

启动报文件失败，需要手动创建文件目录并赋予对应的权限。
4、创建Kafka集群
配置文件：kafka1-3/config/server.properties分别修改对应的参数。

broker.id=1 zookeeper.connect=localhost:2181,localhost:2182,localhost:2183listeners=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-topic

Spring 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.StringDeserializer

3、发送消息

@Autowiredprivate 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);}

5、参考资料
Spring Boot & Kafka官方文档：

【轻松上手 Spring Boot & Kafka 实战】https://docs.spring.io/spring-boot/docs/current-SNAPSHOT/reference/htmlsingle/#boot-features-kafka

Spring for Apache Kafka官方文档：

https://docs.spring.io/spring-kafka/reference/htmlsingle/

点击了解更多链接关注我，分享更主流的JAVA技术～

轻松上手 Spring Boot & Kafka 实战

推荐阅读

怀孕期间老公出轨了该怎么办呢,我怀孕老公出轨我到底该怎么办-

文章|这3个原因, 让鲁迅的文章不得不慢慢地从课本中删除！

中药颗粒剂的特点

2020年各领域销量最好的6款车销量最好的车

茅盾的农村三部曲指哪三部作品？

Android系统服务DropBoxManagerService详解与实践应用

收手吧刘晓庆！70岁演“少女”雷人又无脑，网友：实在是辣眼睛！

向日葵为什么向着太阳的原因向日葵为什么向着太阳

合资车|长得帅，操控好，全新宝马3系销量稳定，备受消费者喜爱

以微笑直面人生|成绩不好的差生笑话

济南新房装修注意事项、预算

[认真钓鱼]都会改变中钩率，只有这几种情况，才应该调漂，不是什么时候调钓

[崛起吧大国科技]芯片和系统都成功了，为什么造不出光刻机？，华为投入大量资金

有关钱塘江大潮的诗?描写钱塘江大潮的著名诗句

大表姐的穿衣经|秦岚41岁状态依旧不输少女，穿刺绣针织配百褶裙，配色活泼好显嫩

公司起名常用字公司起名常用字库

眼泪私逃|有一种闺蜜叫祝绪丹，晒与迪丽热巴同玩合照，只P对方故意丑化自己

|他拍“抗日神剧”已成瘾，一部比一部吓人，这是要把观众逼走啊！

午间时刻|寸头惊艳众人的男明星们，宋威龙李现有男友感，吴亦凡杨洋太精致

虎扑篮球|还没有与球队合练，兰斯-托马斯和东塔-霍尔仍然在隔离