kafkatemplate无法注入_Spring-Kafka（三）-KafkaTemplate发送消息及结果回调

我们使用KafkaTemplate.send(String data)这个方法发送消息到Kafka中，显然这个方法并不能满足我们系统的需求，那我们需要查看一下KafkaTemplate所实现的接口，看看还提供了什么方法。

当我们发送消息到Kafka后，我们又怎么去确认消息是否发送成功呢？这就涉及到KafkaTemplate的发送回调方法了。

接下来我们开始正式讲解

查看发送接口

首先我们Ctrl+鼠标左键进入KafkaTemplate的源代码中查看一下，可以看到有关发送的接口如下。

这里的参数还是比较简单的，值得一提的事，方法中有个Long类型的时间戳(timestamp)参数，这是Kafka0.10版本提供的新功能，主要用来使用时间索引进行查询数据以及日志切分清除策略。

还有一个ProducerRecord参数，这个类其实就是整合了topic、partition、data等数据的消费实体类。

topic：这里填写的是Topic的名字

partition：这里填写的是分区的id，其实也是就第几个分区，id从0开始。表示指定发送到该分区中

timestamp：时间戳，一般默认当前时间戳

key：消息的键

data：消息的数据

ProducerRecord：消息对应的封装类，包含上述字段

Message>：Spring自带的Message封装类，包含消息及消息头

Listena

kafkatemplate无法注入_Spring-Kafka（三）-KafkaTemplate发送消息及结果回调相关推荐

【kafka系列】kafka之生产者发送消息实践
目录一.准备工作二.终端命令生产者命令消费者命令三.Java实践搭建项目异步发送-无回调异步发送-有回调同步发送一.准备工作进入实战之前先熟悉一下topic的相关命令,使用终端命 ...
如何使用Kafka可靠地发送消息-《Kafka权威指南（第二版）》阅读笔记
可靠性是系统而不是某个独立组件的一个属性,所以,在讨论Kafka的可靠性保证时,需要从系统的整体出发.说到可靠性,那些与Kafka集成的系统与Kafka本身一样重要.正因为可靠性是系统层面的概念,所以 ...
kafka生产者的发送消息的流程以及代码案例
一 kafka发送消息流程 1.1 发送流程原理 kafka在发送消息的过程中,主要涉及两个线程main 线程和 Sender 线程. 在 main 线程中创建了一个双端队列 RecordAccum ...
【GNZ48-章泽婷应援会】基于Java的SNH48Group应援会机器人（三）发送消息
这一部分是我也看了好久,才决定用Java的Robot + User32来实现.Robot是java.awt下的一个类,该类用于为测试自动化.自运行演示程序和其他需要控制鼠标和键盘的应用程序生成本机系统 ...
异步消息服务器,Spring-Kafka中如何通过KafkaTemplate 对象异步和同步发送消息
Kafka Producer默认是异步发送. 在初始化producer实例时,会创建一个sender线程负责批量发送消息: producer将消息暂存在缓冲区,消息根据topic-partition分 ...
Kafka 发送消息
– Start 点击此处观看本系列配套视频在上个例子中,我们使用了脚本来发送消息,来吧,让我们来自己写点代码来发送消息.首先还是按照上个例子,先启动 ZooKeeper 和启动 Kafka bor ...
kafka实现异步发送_Kafka Producer 异步发送消息居然也会阻塞？
Kafka 一直以来都以高吞吐量的特性而家喻户晓,就在上周,在一个性能监控项目中,需要使用到 Kafka 传输海量消息,在这过程中遇到了一个 Kafka Producer 异步发送消息会被阻塞的问题, ...
t-io 入门篇（三）即时消息发送demo学习
前言 t-io作者在开源其框架的同时还附带了几个demo,如:简单的hello world.im等.接下来这篇博客将会围绕tio-examples-im-simple-client.tio-examp ...
kafka 基础概念、命令行操作（查看所有topic、创建topic、删除topic、查看某个Topic的详情、修改分区数、发送消息、消费消息、查看消费者组、更新消费者的偏移位置）
文章目录前言 1. 基础概念 Broker Producer Consumer Consumer Group Topic Partition Replica 2. 命令行操作 2.1 查看所有top ...

kafkatemplate无法注入_Spring-Kafka（三）-KafkaTemplate发送消息及结果回调

kafkatemplate无法注入_Spring-Kafka（三）-KafkaTemplate发送消息及结果回调相关推荐

最新文章

热门文章