Hi Rex,

I believe this section answers your question [1]

Piotrek

[1]
https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#kafka-consumers-start-position-configuration

pon., 18 sty 2021 o 09:00 赵一旦 <hinobl...@gmail.com> napisał(a):

> If you changed the consumer group in your new job, the group id will be
> the new one you set.
> The job will continue to consumer the topics from the savepoint/checkpoint
> you specified no matter whether the group id is the original one?
>
> Rex Fenley <r...@remind101.com> 于2021年1月18日周一 下午12:53写道:
>
>> Hello,
>>
>> When using the Kafka consumer connector, if we restore a from a
>> checkpoint or savepoint using a differently named consumer group than the
>> one we originally ran a job with will it still pick up exactly where it
>> left off or are you locked into using the same consumer group as before?
>>
>> Thanks!
>>
>> --
>>
>> Rex Fenley  |  Software Engineer - Mobile and Backend
>>
>>
>> Remind.com <https://www.remind.com/> |  BLOG <http://blog.remind.com/>
>>  |  FOLLOW US <https://twitter.com/remindhq>  |  LIKE US
>> <https://www.facebook.com/remindhq>
>>
>

Reply via email to