[
https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-2902:
-------------------------------
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
was: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.
> StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of
> getBaseConsumerConfigs
> -----------------------------------------------------------------------------------------------------
>
> Key: KAFKA-2902
> URL: https://issues.apache.org/jira/browse/KAFKA-2902
> Project: Kafka
> Issue Type: Bug
> Components: kafka streams
> Reporter: Bill Bejeck
> Assignee: Bill Bejeck
> Fix For: 0.9.1.0
>
>
> 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
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
