[KAFKA-4715] Consumer/Producer config does not work with related enums

• Type: Improvement
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: clients, config
• Assignee: Unassigned
• Reporter: Bryan Baugher
• Created: 30/Jan/17 18:42
• Updated: 20/Oct/20 15:55

Description

We have some code that builds producer/consumer config and sometimes uses the related enum like this,

Properties properties = new Properties();

properties.setProperty(ProducerConfig.COMPRESSION_TYPE_CONFIG, CompressionType.SNAPPY.name());
...

Producer producer = new KafkaProducer(properties);

We get,

org.apache.kafka.common.KafkaException: Failed to construct kafka producer
...
Caused by: java.lang.IllegalArgumentException: Unknown compression name: SNAPPY

We've seen the same for others like ConsumerConfig.AUTO_OFFSET_RESET_CONFIG and its OffsetResetStrategy enum.

Issue Links

• links to: GitHub Pull Request #9369