docs: 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();
  			}
  		}
  	}