1.如果Offset Explorer能够检测到kafka中的数据，但是自己的kafka无法读取到
这个问题主要是由于kafka中的信息已经被消费掉了造成的
consumer.commitAsync();
这里如果已经消费掉了kafka的信息，那么已经被消费掉的kafka数据就不会被再读取掉，除非修改offset偏移量
同步提交可以解决消息丢失的问题，但是提交的速度会太慢。
2.如果一直报错Attempt to heart beat failed since the group is rebalancing，此时需要修改心跳时间，一般改为200的时候就可以解决问题
props.put(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG,200);
成功解决此问题
本文转载自: https://blog.csdn.net/znevegiveup1/article/details/134550017
版权归原作者 唐僧爱吃唐僧肉 所有， 如有侵权，请联系我们删除。
版权归原作者 唐僧爱吃唐僧肉 所有， 如有侵权，请联系我们删除。