Arvid Heise questions

Arvid Heise answers

• how to achieve exactly once semantics in apache kafka connector
• What is a watermark in Flink with respect to Event time processing? Why is it needed.?
• Flink serialization of java.util.List and java.util.Map
• Flink metric `flink_taskmanager_Status_JVM_CPU_Load{}` is not accurate in Grafana Dashboard
• Flink - Async IO operator for series of API calls
• Can I write sync code in RichAsyncFunction
• flink kafkaproducer send duplicate message in exactly once mode when checkpoint restore
• Flink RichSinkFunction constructor VS open()
• Flink Kinesis Consumer not storing last successfully processed sequence nos
• Is one Task one thread in Apache Flink