午 06:32:02---Hi, One more thing. If you switch to the new group.id and would like toFrom: Attila Simon <s...@cloudera.com>To: user@flume.apache.org, d...@flume.apache.orgDate: 2016-10-13 下午 06:32Subject: Re: how to make KafkaSource consume the existing messages
Hi,One more thing. If you
ameter "auto.offset.reset = latest" to
"earliest", but this does not work.
tier2.sources.source1.kafka.consumer.group.id = test-consumer-group-new
tier2.sources.source1.kafka.consumer.auto.offset.reset = earliest
Anyone knows how to make KafkaSource consume the existing messages?
Thanks a lot for any advice!
mer group and update the parameter "auto.offset.reset = latest" to
>>> "earliest", but this does not work.
>>>
>>> tier2.sources.source1.kafka.consumer.group.id = test-consumer-group-new
>>> tier2.sources.source1.kafka.consumer.auto.offset.r
re received while the old existing message not. I tried to use a
>> new consumer group and update the parameter "auto.offset.reset = latest" to
>> "earliest", but this does not work.
>>
>> tier2.sources.source1.kafka.consumer.group.id = test-consumer-
roup.id = test-consumer-group-new
> tier2.sources.source1.kafka.consumer.auto.offset.reset = earliest
>
> Anyone knows how to make KafkaSource consume the existing messages?
> Thanks a lot for any advice!
>
> Best Regards,
>
> Wang Ping (王苹)
> InfoSphere BigInsights, CDL
> Email: wpw
ier2.sources.source1.kafka.consumer.group.id = test-consumer-group-newtier2.sources.source1.kafka.consumer.auto.offset.reset = earliestAnyone knows how to make KafkaSource consume the existing messages?Thanks a lot for any advice!
Best Regards,Wang Ping (王苹)InfoSphere BigInsights, CDLEmail: wpw...@cn.ibm.com P
ier2.sources.source1.kafka.consumer.group.id = test-consumer-group-newtier2.sources.source1.kafka.consumer.auto.offset.reset = earliestAnyone knows how to make KafkaSource consume the existing messages?Thanks a lot for any advice!
