10得票2回答
Flink Kafka EXACTLY_ONCE导致KafkaException:ByteArraySerializer不是Serializer的实例

所以,我试图在我的Flink Kafka流处理作业中启用EXACTLY_ONCE语义,同时进行检查点。 然而,我无法让它工作,所以我尝试从Github下载测试示例代码: https://github.com/apache/flink/blob/c025407e8a11dff344b58732...