private void abortTransactions(Set<String> transactionalIds) {
		for (String transactionalId : transactionalIds) {
			try (FlinkKafkaInternalProducer<byte[], byte[]> kafkaProducer =
				initTransactionalProducer(transactionalId, false)) {
				// it suffice to call initTransactions - this will abort any lingering transactions
				kafkaProducer.initTransactions();
			}
		}
	}
private void abortTransactions ( Set < String > transactionalIds ) { for ( String transactionalId : transactionalIds ) { try ( FlinkKafkaInternalProducer < byte [ ] , byte [ ] > kafkaProducer = initTransactionalProducer ( transactionalId , false ) ) { kafkaProducer . initTransactions ( ) ; } } }
----------------------------------- Utilities --------------------------