Yes, that is the case from my usage. FWIW I have a Jira ticket (KAFKA-2902) and have submitted a PR (#596) to address the issue.
Thanks, Bill > On Nov 28, 2015, at 1:27 AM, Guozhang Wang <[email protected]> wrote: > > I think the problem is that "getConsumerConfigs" called in StreamThread. > createConsumer() triggers getRestoreConsumerConfigs instead of > getBaseConsumerConfigs, which seems a bug to me. > > Guozhang > > On Fri, Nov 27, 2015 at 8:01 PM, Yasuhiro Matsuda < > [email protected]> wrote: > >> The group id is removed from the restore consumer config because the >> restore consumer should not participate in the specified consumer group. I >> don't know why it is failing. >> >> On Fri, Nov 27, 2015 at 12:37 PM, Guozhang Wang <[email protected]> >> wrote: >> >>> Hello Bill, >>> >>> Thanks for reporting it, this is a valid issue, could you create a >> ticket? >>> >>> Guozhang >>> >>>> On Fri, Nov 27, 2015 at 6:19 AM, Bill Bejeck <[email protected]> wrote: >>>> >>>> All, >>>> >>>> When starting KafkaStreaming I'm getting the following error (even when >>>> explicitly setting the groupId with props.put("group.id >>>> ","test-consumer-group") >>>> ); >>>> >>>> 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 >>>> >>>> I've traced the source of the issue to the >>>> StreamingConfig.getConsumerConfigs method as it calls >>>> getRestoreConsumerConfigs (which explicitly removes the groupId >> property) >>>> vs using getBaseConsumerConfigs which returns the passed in configs >>>> unaltered. >>>> >>>> When I switched the method call, KafkaStreaming starts up fine. >>>> >>>> If you agree with this change/fix, I'll create a Jira ticket and put in >>> the >>>> PR, yada yada yada...... >>>> >>>> Thanks, >>>> Bill >>> >>> >>> >>> -- >>> -- Guozhang > > > > -- > -- Guozhang
