[FLINK-27509] update table-walkthrough playground for Flink 1.14
[flink-playgrounds.git] / table-walkthrough / src / main / java / org / apache / flink / playgrounds / spendreport / SpendReport.java
index 1a8cb8320384d8e3753710171ac882c85f18b5ab..d25710221990dd1def68ef8705186b720439a51d 100644 (file)
@@ -45,6 +45,7 @@ public class SpendReport {
                 "    'connector' = 'kafka',\n" +
                 "    'topic'     = 'transactions',\n" +
                 "    'properties.bootstrap.servers' = 'kafka:9092',\n" +
+                "    'scan.startup.mode' = 'earliest-offset',\n" +
                 "    'format'    = 'csv'\n" +
                 ")");