kafka send方法详解（同步异步）小白使用记录

生产者发送消息调用send方法

下面介绍了官方提供的三种方式。

import org.apache.kafka.clients.producer.Callback;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.RecordMetadata;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;import java.util.Properties;/*** @Auther: le* @Date: 2019/4/23 22:05* @Description:*/
public class MyProducer implements Job {private static KafkaProducer<String,String> producer;static {Properties properties = new Properties();properties.put("bootstrap.servers","127.0.0.1:9092");properties.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");properties.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");producer = new KafkaProducer<String, String>(properties);}/*** 第一种直接发送，不管结果 有些异常捕捉不到  异步发送*/private static void sendMessageForgetResult(){ProducerRecord<String,String> record = new ProducerRecord<String,String>("kafka-study","name","Forget_result");producer.send(record);producer.close();}/*** 第二种同步发送，等待执行结果 同步发送* @return* @throws Exception*/private static RecordMetadata sendMessageSync() throws Exception{ProducerRecord<String,String> record = new ProducerRecord<String,String>("kafka-study","name","sync");RecordMetadata result = producer.send(record).get();System.out.println(result.topic());System.out.println(result.partition());System.out.println(result.offset());return result;}/*** 第三种执行回调函数  异步发送*/private static void sendMessageCallback(){ProducerRecord<String,String> record = new ProducerRecord<String,String>("kafka-study","name","callback");producer.send(record,new MyProducerCallback());}

kafka send方法详解（同步异步）小白使用记录相关推荐

python 生成器 send_python(可迭代对象，迭代器，生成器及send方法详解)
一.可迭代对象对象必须提供一个__iter__()方法,如果有,那么就是可迭代对象, 像列表,元祖,字典等都是可迭代对象可使用isinstance(obj,Iterable)方法判断 1 from ...
ret php,php生成器的send方法详解,php yield send
[一].基本用法首先看看官方对send方法的解释:Sets the return value of the yield expression and resumes the generator (u ...
mysql master 配置_MySQL双Master配置的方法详解
刚刚抽空做了一下MYSQL 的主主同步.把步骤写下来,至于会出现的什么问题,以后随时更新.这里我同步的数据库是TEST1.环境描述.主机:192.168.0.231(A)主机:192.168.0.23 ...
PHP连接redis并执行redis相关命令的方法详解
PHP连接redis并执行redis相关命令的方法详解连接redis库的方法共性的运算归类 redis服务类函数 set 操作增删改查 List栈的结构,注意表头表尾,创建更新分开操作 Set,没 ...
线程池invokeAll方法详解
线程池invokeAll方法详解问题起源与抽象问题排查与猜测猜测一:invokeAll 在异步执行后会不会同步等待线程执行完毕获取最终结果猜测二:队列里面可能存在第一次调用 invokeAll ...
小程序setdata优化_微信小程序 setData的使用方法详解
微信小程序 setData的使用方法详解微信小程序 setData的使用方法详解最近在使用微信小程序的setData时,遇到了以下问题.如下: 官网文档在使用setData()设置数组对象的某个元 ...
【前端用法】$.ajax()方法详解，以及$.ajax()标准写法
使用JQuery中的异步请求$.ajax()方法,经常记不全参数,所以在这里记录一下,方便后续使用. 首先看一个标准的写法: $(document).ready(function () {$.ajax ...
PHP宽带自动拨号,window_Win10怎么设置宽带自动连接 win10开机自动连接宽带设置方法详解，对于没有使用路由器中转，每 - phpStudy...
Win10怎么设置宽带自动连接 win10开机自动连接宽带设置方法详解对于没有使用路由器中转,每次开机都需要进行宽带连接拨号上网的用户来说,每次打开电脑都需要打开宽带连接进行拨号才能正常上网是不是很 ...
linux expect 输入密码,shell脚本无密码登录 expect的使用方法详解
shell脚本无密码登录 expect的使用方法详解今天需要做一个定时任务脚本将最新的数据包文件传到远程的服务器上,虽然有密钥但也是要求输入密码的那种,所以只能另想办法实现让脚本自动输入密码了. 从 ...

kafka send方法详解（同步异步）小白使用记录

kafka send方法详解（同步异步）小白使用记录相关推荐

最新文章

热门文章

kafka send方法详解 （同步异步） 小白使用记录

kafka send方法详解 （同步异步） 小白使用记录相关推荐

最新文章

热门文章

kafka send方法详解（同步异步）小白使用记录

kafka send方法详解（同步异步）小白使用记录相关推荐