泉州响应式网站建设,招商网站平网站平台,企业信息化系统包括哪些内容,网站设计原理1.如果Offset Explorer能够检测到kafka中的数据#xff0c;但是自己的kafka无法读取到
这个问题主要是由于kafka中的信息已经被消费掉了造成的
consumer.commitAsync();这里如果已经消费掉了kafka的信息#xff0c;那么已经被消费掉的kafka数据就不会被再读取掉#xff0c…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);成功解决此问题
