新手学习kakfa消息推送问题记录篇
今天去网上找了几篇kafka入门的文章看了下,linux配置好了kafka,zookeeper环境,测试消息发送接受都正常,于是开始动手写java代码,代码如下:
Properties pro=new Properties();
pro.put("bootstrap.servers","ip:9092");
pro.put("acks", "all");
pro.put("retries", 0);
pro.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
pro.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
producer = new KafkaProducer<String, String>(pro);
ProducerRecord<String, String> record=new ProducerRecord<>("test","收到消息2");
producer.send(record);
尝试发送了几次都接收不到消息,对比了一下几篇文章的代码,发现没有关闭生产者,增加producer.close()就行了。 同时看了下源码,producer在调用close方法时判断了进程是否关闭,如果关闭则认为发送消息完毕了,于是将原先存在缓冲区的消息推送出去,关闭进程,还可以调用producer.send(record).get()关闭进程。
初学kafka做个记录
(adsbygoogle = window.adsbygoogle || []).push({});- selenium 学习笔记 ---新手学习记录(4) 问题总结(java)-autoit3脚本使用
- selenium 学习笔记 ---新手学习记录(8) 问题总结(java)
- 新手学习之Exchange2007,问题记录
- selenium 学习笔记 ---新手学习记录(3) 问题总结(java)
- 问题记录:关于APP推送消息的问题
- selenium 学习笔记 ---新手学习记录(5) 问题总结(java)
- selenium 学习笔记 ---新手学习记录(6) 问题总结(java)
- selenium 学习笔记 ---新手学习记录(10) 问题总结(java)--poi--excel 操作
- selenium 学习笔记 ---新手学习记录(9) 问题总结(java)
- selenium 学习笔记 ---新手学习记录(2) 问题总结
- selenium 学习笔记 ---新手学习记录(7) 问题总结(java)
- 新手安家--记录我的学习过程
- openerp学习笔记 跟踪状态,记录日志,发送消息
- C++ 学习拾遗 —— 点滴记录C++学习过程中遇到的问题以及整理
- WCF学习问题之:响应消息的内容类型 multipart/related; type="application/xop+xml"……
- 记录点学习的东西-调用swf的跨域问题
- [项目过程中所遇到的各种问题记录]学习篇——对工作以来的学习过的开源项目进行总结—DiscuzNt
- Android学习过程中问题记录
- C#中ArrayList 与 string、string[]数组 的转换 (转学习:今天做项目时遇到一个arrylist转换问题,做记录)