Kafka系列2:深入理解Kafka生产者( 四 )
ProducerRecord<String String> record = new ProducerRecord<>(topicName \"k\" + i \"v\" + i);
/* 发送消息*/
producer.send(record);
/*关闭生产者*/
producer.close();
这个样例中只配置了必须的这三个属性 , 其他都使用了默认的配置 。
发送消息Kafka
实例化生产者对象后 , 接下来就可以开始发送消息了 。 发送消息主要有三种方式:
-
发送并忘记(fire-and-forget):把消息发送给服务器 , 但并不关心消息是否正常到达 , 也就是上面样例中的方式 。 大多数情况下 , 消息会正常到达 , 这可以由Kafka的高可用性和自动重发机制来保证 。 不过有时候也会丢失消息 。
-
同步发送:使用send()方法发送消息 , 它会返回一个Future对象 , 调用get()方法进行等待 , 我们就可以知道消息是否发送成功 。
- |阴阳哲学探索系列之一百零八十四(以组织层级为例)
- 使命召唤手游|整个仙剑系列,修仙的角色一抓一大把,但真正成仙的又有哪些呢?
- 世界观|《真.女神转生V》系列回顾与测评:奇幻世界,现代视角,与魔为伴
- 皮卡丘|庆祝《宝可梦》系列25周年,官方推限量25尊「水晶皮卡丘」
- 大话西游2|大话西游2:这么全面的万金油神兽从鎏金宝鉴系列里可以说是”大哥“的存在了!
- |LOLM神龙和光明哨兵,哪个系列皮肤更受欢迎?玩家:主要看价格
- 开罗|《Let's Build a Zoo》No More Robots 系列新作,开罗向游戏上架steam
- |新作只排第四! 《银河战士》系列排名TOP10
- 炉石传说|炉石传说:迷你系列,1费新卡快攻德质变,胜率最高直逼最强卡组
- iqoo8|游戏表现“天花板”非它莫属!KPL选手同款的iQOO 8系列