[hotfix][kafka] Add claryfiying comment in FlinkKafkaProducer011

mbalassi · Aug 17, 2018 · 552ae2b · 552ae2b
1 parent 741aa43
commit 552ae2b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java b/...0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
@@ -916,6 +916,7 @@ private void abortTransactions(Set<String> transactionalIds) {
  for (String transactionalId : transactionalIds) {
  try (FlinkKafkaProducer<byte[], byte[]> kafkaProducer =
  initTransactionalProducer(transactionalId, false)) {
+ // it suffice to call initTransactions - this will abort any lingering transactions
  kafkaProducer.initTransactions();
  }
  }