apache-flink - flink 应用程序在使用来自 kafka 的消息后停止

Question

我正在使用 Flink 连接器 Kafka 1.8.0。（取决于 kafka-clients 2.0.1）在处理了来自 kafka 的几条消息后，我得到了这些错误，然后应用程序被停止

•   2019-12-26 06:37:39,843 INFO 
org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction - FlinkKafkaProducer 3/4 - 
checkpoint 266 complete, committing transaction TransactionHolder{handle=KafkaTransactionState 
[transactionalId=null, producerId=-1, epoch=-1], transactionStartTime=1577341934732} from checkpoint 
266
•   2019-12-26 06:42:39,043 INFO org.apache.kafka.clients.FetchSessionHandler - [Consumer 
clientId=consumer-22, groupId=com.citi.gsp.onepx.raw_positions] Node 1001 was unable to process the 
fetch request with (sessionId=965915581, epoch=1603): FETCH_SESSION_ID_NOT_FOUND.

你能帮忙吗？

标签： apache-flink