[KAFKA-8157] Missing "key.serializer" exception when setting "segment index bytes"

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.2.0
• Fix Version/s: 2.3.0, 2.2.1
• Component/s: streams
• Labels: beginner newbie
• Environment: ubuntu 18.10, localhost and Aiven too
• Assignee: Guozhang Wang
• Reporter: Cristian D
• Created: 26/Mar/19 09:29
• Updated: 08/Apr/19 16:50
• Resolved: 08/Apr/19 16:50

Description

As a `kafka-streams` user,

When I set the "segment index bytes" property

Then I would like to have internal topics with the specified allocated disk space

 

At the moment, when setting the "topic.segment.index.bytes" property, the application is exiting with following exception: 

Exception in thread "main" org.apache.kafka.common.config.ConfigException: Missing required configuration "key.serializer" which has no default value.

Tested with `kafka-streams` v2.0.0 and v2.2.0.

 

Stack trace:

Exception in thread "main" org.apache.kafka.common.config.ConfigException: Missing required configuration "key.serializer" which has no default value.
 at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:474)
 at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:464)
 at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:62)
 at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:75)
 at org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:392)
 at org.apache.kafka.streams.StreamsConfig.getMainConsumerConfigs(StreamsConfig.java:1014)
 at org.apache.kafka.streams.processor.internals.StreamThread.create(StreamThread.java:666)
 at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:718)
 at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:634)
 at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:544)
 at app.Main.main(Main.java:36)

A demo application simulating the exception:

https://github.com/razorcd/java-snippets-and-demo-projects/tree/master/kafkastreamsdemo

 

 

Issue Links

• links to: GitHub Pull Request #6535
• links to: GitHub Pull Request #6547