flink kafka source使用注意事项

kafka_source(consumer) setStartFromLatest Flink从topic中最新的数据开始消费,不管哪个消费者是否同个消费组 如果设置了保存点,则会记录自己的offect,不管其他的消费者是否消费了 setStartFromGroupOffsets 必须配置group.id参数 启动会获取最新的groupid对应的offect 如果同个groupid其他的消费者消费

>>阅读原文<<