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);

成功解决此问题

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注