阿八博客
  • 100000+

    文章

  • 23

    评论

  • 20

    友链

  • 最近新加了很多技术文章,大家多来逛逛吧~~~~
  • 喜欢这个网站的朋友可以加一下QQ群,我们一起交流技术。

SpringBoot整合Apache Kafka

欢迎来到阿八个人博客网站。本 阿八个人博客 网站提供最新的站长新闻,各种互联网资讯。 喜欢本站的朋友可以收藏本站,或者加QQ:我们大家一起来交流技术! URL链接:https://www.abboke.com/grfx/253071.html

Kafka安装

1 、下载:2.2.0版本下载

2 、解压:

tar-xzfkafka_2.12-2.2.0.tgz
cdkafka_2.12-2.2.0

3、启动Zookeeper:

bin/zookeeper-server-start.shconfig/zookeeper.properties

如果需要后台启动,可以这样:

nohupbin/zookeeper-server-start.shconfig/zookeeper.properties&

4、启动Kafka服务端

bin/kafka-server-start.shconfig/server.properties

这样就启动完成啦!

与SpringBoot整合

1、搭建Springboot

该步骤就略掉啦,我们已经与百度达成了战略合作关系,所以如果不会,可以问一下度娘!

2、引入Jar包

<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>

3、配置

在application.yml中

spring

kafka:
bootstrap-servers: ip:9092
template:
default-topic: myTopic
consumer:
group-id: test

4、编写客户端代码

  • 编写生产者

@Component
publicclassKafkaProducerManger{

@Autowired
privateKafkaTemplatekafkaTemplate;


@SuppressWarnings("unchecked")
publicvoidsendData(Stringdata){
System.out.println("发送消息:"+data);
kafkaTemplate.send("myTopic",data);
}

}
  • 编写消费者

@Component
publicclassKafkaConsumerManager{

@KafkaListener(topics="myTopic")
publicvoidprocessMessage(Stringcontent){
System.out.println("接收消息:"+content);
}

}

5、编写测试代码

@RequestMapping("/")
@ResponseBody
publicStringtest(){
kafkaProducerManger.sendData("来啦老弟!"):
return"success!";
}

浏览器直接请求,看到控制台打印相关信息就大功告成啦,是不是很简单!

原创作者: 何鑫

尊重原创,人人有责

来源:发布于阿八个人博客,内容来源于网络,如有错误评论区内纠正,学习使人快乐(*^▽^*)

相关文章