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
