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
