You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:07:45 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 ]
Matthias J. Sax updated KAFKA-2902:
-----------------------------------
Affects Version/s: 0.10.0.0
> 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: streams
> Affects Versions: 0.10.0.0
> Reporter: Bill Bejeck
> Assignee: Bill Bejeck
> Fix For: 0.10.0.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.15#6346)