>>>>??????????
>>>>??Flink 
??kafka??????????????????????????checkpoint????????????????EXACTLY_ONCE
>>??????????????
Producer attempted an operation with an old epoch.Either there is a newer 
producer with the same transactionalId, or the producer's transaction has been 
expired by the broker


>>??????????????????
>>??????????

回复