依赖

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

配置文件

spring:kafka:producer:value-serializer: org.springframework.kafka.support.serializer.JsonSerializerbootstrap-servers: 192.168.20.75:9907kafka:spark:task:topic: platform-model-spark-topic1

生产者

方法一：添加@RunWith(SpringRunner.class)、@SpringBootTest(classes = DataComputingModelApplication.class)实现初始化配置注入kafkaTemplate，调用send()
@Autowired
private KafkaTemplate kafkaTemplate;@Testpublic void kafkaSend() {final ProducerRecord<String, String> record = new ProducerRecord("test20201228", "{\"key\":\"27\"}");kafkaTemplate.send(record);log.info("------------send success!----------------");}方法二：不需要注解@RunWith、@SpringBootTest，但是初始化Properties，同样调用send()
@Testpublic void kafkaSend2() {Properties props = new Properties();props.put("bootstrap.servers", "192.168.20.75:9907");props.put("key.serializer", StringSerializer.class);props.put("value.serializer", StringSerializer.class);KafkaProducer<String,String> producer = new KafkaProducer<>(props);ProducerRecord record = new ProducerRecord<String, String>("test20201228", "key", "{\"key\":\"20\"}");producer.send(record);log.info("------------send success!----------------");producer.close();}

消费者

说明：
① Topic主题用来区分不同类型的消息
② GroupId用来解决同一个Topic主题下重复消费问题，比如一条消费需要多个消费者接收到，就可以通过设置不同的GroupId实现，实际消息是存一份的，只是通过逻辑上设置标识来区分，系统会记录Topic主题下–》GroupId分组下–》partition分区下的offsert，来标识是否消费过。

@KafkaListener(topics = "big_data_task_state", groupId = "bigDataTaskState")public void taskStateConsumer(String msg) {log.info("----receive:{}----", msg);}

SpringBoot使用Kafka生产者、消费者相关推荐

Spring Kafka生产者/消费者样本
我的目的是演示Spring Kafka如何为原始Kafka Producer和Consumer API提供一种易于使用且对具有Spring背景的人熟悉的抽象. 示例场景示例场景是一个简单的场景,我有 ...
Kafka生产者消费者模型
一.Kafka回顾 1.AMQP协议消息队列中消息交互规范,多数分布式消息中间件基于该协议进行消息传输 2.Broker 对于kafka,将生产者发送的消息,动态的添加到磁盘,一个Broker等同于 ...
java kafka 集群消费_kafka集群搭建和使用Java写kafka生产者消费者
转自:http://chengjianxiaoxue.iteye.com/blog/2190488 1 kafka集群搭建 1.zookeeper集群搭建在110, 111,112 2.kafka使 ...
java生产者消费者代码_Java实现Kafka生产者消费者代码实例
Kafka的结构与RabbitMQ类似,消息生产者向Kafka服务器发送消息,Kafka接收消息后,再投递给消费者. 生产者的消费会被发送到Topic中,Topic中保存着各类数据,每一条数据都使用键 ...
SpringBoot集成Kafka
SpringBoot集成Kafka 知识索引 SpringBoot集成Kafka工程搭建 SpringBoot集成Kafka配置 SpringBoot集成Kafka生产消息 SpringBoot集成K ...
从现在开始学 Kafka：SpringBoot 集成 Kafka，生产者与消费者示例
从现在开始学 Kafka:SpringBoot 集成 Kafka,生产者与消费者示例前言加依赖生产者加配置生产者代码示例消费者加配置消费者监听器示例调用关于 Serializer ...
SpringBoot整合kafka实战之带回调的生产者
本文来说下SpringBoot整合kafka部分知识内容文章目录带回调的生产者方式一方式二本文小结带回调的生产者前面我们说了简单的生产和消费,本文说下带回调的生产者.kafkaTempl ...
RabbitMQ消息队列讲解（涵盖生产者消费者以及Springboot整合）
文章目录什么是消息队列为什么用消息队列常见MQ产品 RabbitMQ 特性下载与安装 erlang RabbitMQ 工作原理工作流程消息模型基本消息模型生产者消费者消息确认机制( ...
kafka生产者和消费者端的数据不一致
撸了今年阿里.头条和美团的面试,我有一个重要发现.......>>> kafka生产者生产30条数据,而消费者却不一定消费了30条数据,经过探索发现了main线程执行完成了而kafk ...

SpringBoot使用Kafka生产者、消费者

文章目录

依赖

配置文件

生产者

消费者

SpringBoot使用Kafka生产者、消费者相关推荐

最新文章

热门文章