HOTFIX: fix compilation error (#8424)

Reviewers: Matthias J. Sax <[email protected]>, Chia-Ping Tsai <[email protected]>, Guozhang Wang <[email protected]
apache · Apr 4, 2020 · 0eab920 · 0eab920
1 parent 23b4d87
commit 0eab920
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
@@ -1268,7 +1268,7 @@ public Map<String, Object> getProducerConfigs(final String clientId) {
         props.putAll(clientProvidedProps);
 
         // When using EOS alpha, stream should auto-downgrade the transactional commit protocol to be compatible with older brokers.
-        if (StreamThread.eosAlphaEnabled(this)) {
+        if (StreamThread.processingMode(this) == StreamThread.ProcessingMode.EXACTLY_ONCE_ALPHA) {
             props.put("internal.auto.downgrade.txn.commit", true);
         }