root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: cleanup for postProcessAndValidateIdempotenceConfigs method (#12069) 

Reviewers: Luke Chen <showuon@gmail.com>
This commit is contained in:
RivenSun 2022-04-21 14:34:35 +08:00 committed by GitHub
parent 25457377e3
commit 6b07f42ecd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
View File

@ -490,11 +490,11 @@ public class ProducerConfig extends AbstractConfig {
if (userConfiguredIdempotence) { if (userConfiguredIdempotence) {
throw new ConfigException("Must set " + RETRIES_CONFIG + " to non-zero when using the idempotent producer."); throw new ConfigException("Must set " + RETRIES_CONFIG + " to non-zero when using the idempotent producer.");
} }
log.info("Idempotence will be disabled because {} is set to 0.", RETRIES_CONFIG, retries); log.info("Idempotence will be disabled because {} is set to 0.", RETRIES_CONFIG);
shouldDisableIdempotence = true; shouldDisableIdempotence = true;
} }
final short acks = Short.valueOf(acksStr); final short acks = Short.parseShort(acksStr);
if (acks != (short) -1) { if (acks != (short) -1) {
if (userConfiguredIdempotence) { if (userConfiguredIdempotence) {
throw new ConfigException("Must set " + ACKS_CONFIG + " to all in order to use the idempotent " + throw new ConfigException("Must set " + ACKS_CONFIG + " to all in order to use the idempotent " +