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 wrote:
>
> I think the problem is that "getConsumerConfigs" called in StreamThread.
> createConsumer() trigg
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
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 wrote:
> Hello Bill,
>
> Thanks for reporting it, this is a valid issue, c
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 wrote:
> All,
>
> When starting KafkaStreaming I'm getting the following error (even when
> explicitly setting the groupId with props.put("group.id
> ","
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
