You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2015/12/03 03:41:11 UTC
[jira] [Updated] (KAFKA-2902) StreamingConfig getConsumerConfiigs
uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs
[ https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Guozhang Wang updated KAFKA-2902:
---------------------------------
Resolution: Fixed
Status: Resolved (was: Patch Available)
Issue resolved by pull request 596
[https://github.com/apache/kafka/pull/596]
> 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)