Hi Yun and Oran,
Thanks for your time. Much appreciated!
Below are my configs:
val env = StreamExecutionEnvironment.getExecutionEnvironment
env.setParallelism(1)
env.enableCheckpointing(2000)
//env.setDefaultSavepointDirectory("file:home/siddhesh/Desktop/savepoints/")
env.getCheck
Hi Siddhesh,
The root cause is that the configuration of group.id is missing for the Flink
program. The configuration of restart strategy has no relationship with this.
I think you should pay your attention to kafka related configurations.
Best
Yun Tang
From: S
