flink kafka source使用注意事項

kafka_source(consumer) setStartFromLatest Flink從topic中最新的數據開始消費,不管哪個消費者是否同個消費組 如果設置了保存點,則會記錄自己的offect,不管其他的消費者是否消費了 setStartFromGroupOffsets 必須配置group.id參數 啓動會獲取最新的groupid對應的offect 如果同個groupid其他的消費者消費

>>阅读原文<<