我从kafka消费一条数据，然后将消息进行切分，再发送到下游的kafka中，但是这样不能保证在一个事务里面。 例如：我将一条数据切分成10条，然后再第五条的时候抛出一个异常，但是前四条已经发送到下游的kafka了。 我设置了事务id，隔离级别，client id，enable.idempotence,max.in.flight.requests.per.connection,retries 但是没有效果。
-- Sent from: http://apache-flink.147419.n8.nabble.com/
