柚子快報(bào)邀請(qǐng)碼778899分享:分布式 kafka操作的一些坑
敦煌網(wǎng)絲綢之路綜合2025-05-05540
柚子快報(bào)邀請(qǐng)碼778899分享:分布式 kafka操作的一些坑
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操作的一些坑
好文推薦
評(píng)論可見(jiàn),查看隱藏內(nèi)容
大家都在看:
本文內(nèi)容根據(jù)網(wǎng)絡(luò)資料整理,出于傳遞更多信息之目的,不代表金鑰匙跨境贊同其觀點(diǎn)和立場(chǎng)。
轉(zhuǎn)載請(qǐng)注明,如有侵權(quán),聯(lián)系刪除。