Kafka系列2:深入理解Kafka生产者( 八 )
如果Kafka返回错误 , onComplete方法会抛出一个非空异常 。 在调用send()方法的时候会传入这个callback对象 , 根据发送的结果决定调用异常处理方法还是发送结果处理方法 。
生产者配置
在创建生产者的时候 , 介绍了三个必须的属性 , 本节再一一介绍下其他的生产者属性:
acks
acks 参数指定了必须要有多少个分区副本收到消息 , 生产者才会认为消息写入是成功的:
-
acks=0 : 消息发送出去就认为已经成功了 , 不会等待任何来自服务器的响应;
-
acks=1 : 只要集群的首领节点收到消息 , 生产者就会收到一个来自服务器成功响应;
-
acks=all :只有当所有参与复制的节点全部收到消息时 , 生产者才会收到一个来自服务器的成功响应 。
- |阴阳哲学探索系列之一百零八十四(以组织层级为例)
- 使命召唤手游|整个仙剑系列,修仙的角色一抓一大把,但真正成仙的又有哪些呢?
- 世界观|《真.女神转生V》系列回顾与测评:奇幻世界,现代视角,与魔为伴
- 皮卡丘|庆祝《宝可梦》系列25周年,官方推限量25尊「水晶皮卡丘」
- 大话西游2|大话西游2:这么全面的万金油神兽从鎏金宝鉴系列里可以说是”大哥“的存在了!
- |LOLM神龙和光明哨兵,哪个系列皮肤更受欢迎?玩家:主要看价格
- 开罗|《Let's Build a Zoo》No More Robots 系列新作,开罗向游戏上架steam
- |新作只排第四! 《银河战士》系列排名TOP10
- 炉石传说|炉石传说:迷你系列,1费新卡快攻德质变,胜率最高直逼最强卡组
- iqoo8|游戏表现“天花板”非它莫属!KPL选手同款的iQOO 8系列