Hello community!
When using AWS MSK as KafkaSourc...
# troubleshootingc
chankyeong won
10/11/2023, 9:52 AMHello community!
When using AWS MSK as KafkaSource, Has anyone experienced an issue where the offset of the consumer group is not committed even though checkpointing is completed After MSK's
security patchd
Danny Cranmer
10/11/2023, 11:11 AMWhich Flink version? It could be related to this issue. fixed in Flink 1.16.0: https://issues.apache.org/jira/browse/FLINK-28060
c
chankyeong won
10/11/2023, 11:13 AMI’m using flink 1.16.1..
d
Danny Cranmer
10/11/2023, 11:14 AMAha, probably not that then
c
chankyeong won
10/13/2023, 7:50 AMI checked the dependencies of my flink application repo, I found that it was using confluent kafka-clients, which is compatible with version 2.8.x of Apache Kafka. If there are no problems with the next security patch, this is the cause.