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 <
yasuhiro.mats...@gmail.com> 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 <wangg...@gmail.com>
> 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 <bbej...@gmail.com> 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
