Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-8157

Missing "key.serializer" exception when setting "segment index bytes"

    XMLWordPrintableJSON

    Details

    • 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:
    • Environment:
      ubuntu 18.10, localhost and Aiven too

      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

       

       

        Attachments

          Activity

            People

            • Assignee:
              guozhang Guozhang Wang
              Reporter:
              razorcd Cristian D
            • Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: