From 4a039270b3b35b5e8d653a858d4d5fa619d4a421 Mon Sep 17 00:00:00 2001
From: abbccdda <boyang@confluent.io>
Date: Fri, 3 Apr 2020 20:54:46 -0700
Subject: [PATCH] hotfix build

---
 .../src/main/java/org/apache/kafka/streams/StreamsConfig.java   | 2 +-
 1 file changed, 1 insertion(+), 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
index 068fcb869de10..e1d6315a72574 100644
--- 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);
         }