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 <[email protected]>
AuthorDate: Sat Apr 4 11:12:05 2020 -0700
HOTFIX: fix compilation error (#8424)
Reviewers: Matthias J. Sax <[email protected]>, Chia-Ping Tsai
<[email protected]>, Guozhang Wang <[email protected]
---
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);
}
