@VisibleForTesting @Internal public static class FlinkKafkaProducer011.KafkaTransactionContext extends Object
FlinkKafkaProducer011
. User for keeping track of the
transactionalIds.Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.