HOTFIX: fix compilation error
Reviewers: Matthias J. Sax Chia-Ping Tsai Guozhang Wang
@@ -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);
}
