柚子快報邀請碼778899分享：分布式 kafka操作的一些坑

http://yzkb.51969.com/

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

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

consumer.commitAsync();

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

2.如果一直報錯Attempt to heart beat failed since the group is rebalancing，此時需要修改心跳時間，一般改為200的時候就可以解決問題

props.put(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG,200);

成功解決此問題

柚子快報邀請碼778899分享：分布式 kafka操作的一些坑

http://yzkb.51969.com/

好文推薦