[ https://issues.apache.org/jira/browse/FLINK-19099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek closed FLINK-19099. ------------------------------------ Resolution: Not A Problem I'm closing this for now since I don't think it's a problem with Kafka or Flink. Please re-open if you disagree. > consume kafka message repeat > ---------------------------- > > Key: FLINK-19099 > URL: https://issues.apache.org/jira/browse/FLINK-19099 > Project: Flink > Issue Type: Bug > Components: API / DataStream, Connectors / Kafka > Affects Versions: 1.11.0 > Reporter: zouwenlong > Priority: Major > Attachments: image-2020-08-31-19-23-59-038.png, > image-2020-08-31-19-25-09-548.png > > > when taksmanager be killed ,my job consume some message , but the offset in > not commit, > then restart it ,my job consume kafka message repeat, I used checkpoint and > set 5 seconds , > I think this is a very common problem,how to solve this problem? -- This message was sent by Atlassian Jira (v8.3.4#803005)