Flink设置走事务提交cursor的方式,事务冲突异常

client日志:


broker端:
2022-09-16T16:03:43,176+0800 [BookKeeperClientWorker-OrderedExecutor-4-0] ERROR org.apache.pulsar.broker.transaction.pendingack.impl.PendingAckHandleImpl -
[persistent://test/topic/topic-0916-02-partition-0-my_subscription_flink_test-RETRY][my_subscription_flink_test] Transaction:(2,61) try to ack message:203:2988 in pending ack status.

flink版本1.14.4
pulsar 1.10.1

老哥我也我也遇到了这个问题,请问解决了吗?

上面的报错是 retry的问题,可以关掉,建议使用streamnative维护的connector版本 或者关注最新版本的情况