首先我们来看看producer的例子:
下来我们来看看和我们打交道的ProductData类。
ProducerData类相对来说还是很简单明了的,里面持有给哪个topic发送消息,它的key决定超那个partition发送,里面的data就是producer产生的消息
首先我们先看单元测试ProducerTest这个类里面的发送消息的代码:
@Test public void testSend() { Jafka jafka = createJafka(); Properties producerConfig = new Properties(); producerConfig.setProperty( "broker.list", "0:localhost:" +jafka.getPort()); producerConfig.setProperty("serializer.class" , StringEncoder.class .getName()); Producer<String, String> producer = new Producer<String, String>(new ProducerConfig(producerConfig)); for (int i = 0; i < 1000; i++) { producer.send( new StringProducerData("demo" ).add("Hello jafka").add("https://github.com/adyliu/jafka")); } producer.close(); //////////////////////////////////////////////// close(jafka); }这个里面其实感觉还是挺简单的,配置broker的地址,encoder的class类型,最后构建消息并发送。
我先稍微花点时间看一下边边角角的类,Producer的配置类,从这个里面可以看出来,它的父类呢是ZKConfig,里面持有一个同步的producer的config和一个异步的producer的config。
下来我们来看看和我们打交道的ProductData类。
ProducerData类相对来说还是很简单明了的,里面持有给哪个topic发送消息,它的key决定超那个partition发送,里面的data就是producer产生的消息
相关推荐
ProShow Producer模板,玫瑰婚礼,绚丽多彩的画面,替换图片即可。
Photodex ProShow Producer 模板资源和插件5G,爱好制作电子相册的朋友一定喜欢,一定能满足你的需求,资源难得。
Easy RealMedia Producer V1.94
Laravel开发-producer 基于规则的简单类解析
Helix Producer Plus设置
v10内核,根据实际使用的需要提供了比Helix RealMedia Producer和RealProducer10还要多的过滤设置。 基本上可以用它来替代Helix RealMedia Producer和RealProducer v10,使用Real v10内核时,全面支持Real10文件...
amazon-kinesis-producer, 亚马逊Kinesis制作库 室Producer库简介在亚马逊 Kinesis Producer Producer Producer Producer Producer Producer Producer performs performs performs per
配合Helix先进的功能,Realnetworks推出了第10代的流媒体压缩软件Helix Producer。Realnetworks全新改写代码的图形化专业流媒体文件制作工具。利用它,你可以轻松地实现RealAudio8、RealAudio9文件格式到实时文件的...
Kafka Producer机制优化-提高发送消息可靠性
Helix Producer Plus V9.01 拷贝gui.rpui到安装文件夹"Helix Producer Plus\resources"目录下替换同名文件(若想恢复E文版的可先备份该文件)
kettle kafka 生产者插件,在plugins 下新建steps文件夹,把zip文件解压放到里面。
spring-boot-activemq-producer 源码
利用信号量实现的多线程之间的同步与互斥,详情看博客文章Linux多线程编程(二)---线程之间的同步与互斥进阶实验
Proshow能够轻易地制作漂亮的幻灯片,只需将选择的图片拖入即可,还可以将自己的解说或cd音轨作为声音背景,提供超过280种幻灯变换...相对于Gold版,Producer版有更多的一些功能,主要是为了那些商业设计专家而准备的。
想简单的做直播吗,这里给大家提供一个简单的方案。该文章主要介绍怎样搭建Helix Server以及简单的配置,和怎样配合Helix producer做直播详细方法。
Helix Producer Plus V9.01 realmedia专业转码器的算号器 不用资源分哦
最为方便快捷的CD转MP3工具,占用资源小,运行稳定,破解版
ProducerConsumer(生产者消费者问题的单线程模拟) vs2008
无需安装的绿色版OidProducer,
ProShow Producer转场 好几个漂亮的转场呢