diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java b/clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java index 8fec07a2974..6c258933af6 100644 --- a/clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java +++ b/clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java @@ -490,11 +490,11 @@ public class ProducerConfig extends AbstractConfig { if (userConfiguredIdempotence) { 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; } - final short acks = Short.valueOf(acksStr); + final short acks = Short.parseShort(acksStr); if (acks != (short) -1) { if (userConfiguredIdempotence) { throw new ConfigException("Must set " + ACKS_CONFIG + " to all in order to use the idempotent " +