欧美free性护士vide0shd,老熟女,一区二区三区,久久久久夜夜夜精品国产,久久久久久综合网天天,欧美成人护士h版

目錄

柚子快報(bào)邀請(qǐng)碼778899分享:分布式 kafka操作的一些坑

柚子快報(bào)邀請(qǐng)碼778899分享:分布式 kafka操作的一些坑

http://yzkb.51969.com/

1.如果Offset Explorer能夠檢測(cè)到kafka中的數(shù)據(jù),但是自己的kafka無(wú)法讀取到

這個(gè)問(wèn)題主要是由于kafka中的信息已經(jīng)被消費(fèi)掉了造成的

consumer.commitAsync();

這里如果已經(jīng)消費(fèi)掉了kafka的信息,那么已經(jīng)被消費(fèi)掉的kafka數(shù)據(jù)就不會(huì)被再讀取掉,除非修改offset偏移量 同步提交可以解決消息丟失的問(wèn)題,但是提交的速度會(huì)太慢。

2.如果一直報(bào)錯(cuò)Attempt to heart beat failed since the group is rebalancing,此時(shí)需要修改心跳時(shí)間,一般改為200的時(shí)候就可以解決問(wèn)題

props.put(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG,200);

成功解決此問(wèn)題

柚子快報(bào)邀請(qǐng)碼778899分享:分布式 kafka操作的一些坑

http://yzkb.51969.com/

好文推薦

評(píng)論可見(jiàn),查看隱藏內(nèi)容
大家都在看:

本文內(nèi)容根據(jù)網(wǎng)絡(luò)資料整理,出于傳遞更多信息之目的,不代表金鑰匙跨境贊同其觀點(diǎn)和立場(chǎng)。

轉(zhuǎn)載請(qǐng)注明,如有侵權(quán),聯(lián)系刪除。

本文鏈接:http://gantiao.com.cn/post/19392080.html

發(fā)布評(píng)論

您暫未設(shè)置收款碼

請(qǐng)?jiān)谥黝}配置——文章設(shè)置里上傳

掃描二維碼手機(jī)訪問(wèn)

文章目錄