kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch trunk updated: HOTFIX: fix compilation error (#8424)
Date Sat, 04 Apr 2020 18:12:37 GMT
This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 0eab920  HOTFIX: fix compilation error (#8424)
0eab920 is described below

commit 0eab92012bdba3f4b8b3afafc41fbea751179671
Author: Boyang Chen <boyang@confluent.io>
AuthorDate: Sat Apr 4 11:12:05 2020 -0700

    HOTFIX: fix compilation error (#8424)
    
    Reviewers: Matthias J. Sax <matthias@confluent.io>, Chia-Ping Tsai <chia7712@gmail.com>,
Guozhang Wang <guozhang@confluent.io
---
 streams/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 068fcb8..e1d6315 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 class StreamsConfig extends AbstractConfig {
         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);
         }
 


Mime
View raw message