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

StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.10.0.0
    • Fix Version/s: 0.10.0.0
    • Component/s: streams
    • Labels:
      None

      Description

      When starting a KafkaStreaming instance the StreamingConfig.getConsumerConfigs method uses the getRestoreConsumerConfigs to retrieve properties. But this method removes the groupId property which causes an error and the KafkaStreaming instance shuts down. On KafkaStreaming startup StreamingConfig should use getBaseConsumerConfigs instead.

      Exception in thread "StreamThread-1" org.apache.kafka.common.KafkaException: org.apache.kafka.common.errors.ApiException: The configured groupId is invalid
      at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:309)
      at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:198)
      Caused by: org.apache.kafka.common.errors.ApiException: The configured groupId is invalid

        Attachments

          Activity

            People

            • Assignee:
              bbejeck Bill Bejeck
              Reporter:
              bbejeck Bill Bejeck
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: