You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by Hongshun Wang <lo...@gmail.com> on 2023/04/21 06:50:45 UTC
[VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
Dear Flink Developers,
Thank you for providing feedback on FLIP-288: Enable Dynamic Partition
Discovery by Default in Kafka Source[1] on the discussion thread[2].
The goal of the FLIP is to enable partition discovery by default and set
EARLIEST offset strategy for later discovered partitions.
I am initiating a vote for this FLIP. The vote will be open for at least 72
hours, unless there is an objection or insufficient votes.
[1]: [
https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source](https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
[2]: [
https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6](https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6)
Best regards,
Hongshun
Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
Posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org>.
+1
On Thu, Apr 20, 2023 at 11:52 PM Hongshun Wang <lo...@gmail.com>
wrote:
> Dear Flink Developers,
>
>
> Thank you for providing feedback on FLIP-288: Enable Dynamic Partition
> Discovery by Default in Kafka Source[1] on the discussion thread[2].
>
> The goal of the FLIP is to enable partition discovery by default and set
> EARLIEST offset strategy for later discovered partitions.
>
>
> I am initiating a vote for this FLIP. The vote will be open for at least 72
> hours, unless there is an objection or insufficient votes.
>
>
> [1]: [
>
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source](https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> <https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)>
> [2]: [
>
> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6](https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6)
>
>
> Best regards,
> Hongshun
>
Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
Posted by Leonard Xu <xb...@gmail.com>.
+1(binding)
Best,
Leonard
> On Apr 21, 2023, at 2:50 PM, Hongshun Wang <lo...@gmail.com> wrote:
>
> Dear Flink Developers,
>
>
> Thank you for providing feedback on FLIP-288: Enable Dynamic Partition
> Discovery by Default in Kafka Source[1] on the discussion thread[2].
>
> The goal of the FLIP is to enable partition discovery by default and set
> EARLIEST offset strategy for later discovered partitions.
>
>
> I am initiating a vote for this FLIP. The vote will be open for at least 72
> hours, unless there is an objection or insufficient votes.
>
>
> [1]: [
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source](https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> [2]: [
> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6](https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6)
>
>
> Best regards,
> Hongshun
Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
Posted by Hongshun Wang <lo...@gmail.com>.
Thanks, everyone, I'm closing this vote now. I'll follow up with the result
in a separate email.
Best
Hongshun
On Tue, Apr 25, 2023 at 1:54 PM Jing Ge <ji...@ververica.com.invalid> wrote:
> +1(binding)
>
> Best regards,
> Jing
>
> On Tue, Apr 25, 2023 at 5:17 AM Rui Fan <19...@gmail.com> wrote:
>
> > +1 (binding)
> >
> > Best,
> > Rui Fan
> >
> > On Tue, Apr 25, 2023 at 10:06 AM Biao Geng <bi...@gmail.com> wrote:
> >
> > > +1 (non-binding)
> > > Best,
> > > Biao Geng
> > >
> > > Martijn Visser <ma...@apache.org> 于2023年4月24日周一 20:20写道：
> > >
> > > > +1 (binding)
> > > >
> > > > On Mon, Apr 24, 2023 at 4:10 AM Feng Jin <ji...@gmail.com>
> > wrote:
> > > >
> > > > > +1 (non-binding)
> > > > >
> > > > >
> > > > > Best,
> > > > > Feng
> > > > >
> > > > > On Mon, Apr 24, 2023 at 9:55 AM Hang Ruan <ru...@gmail.com>
> > > > wrote:
> > > > >
> > > > > > +1 (non-binding)
> > > > > >
> > > > > > Best,
> > > > > > Hang
> > > > > >
> > > > > > Paul Lam <pa...@gmail.com> 于2023年4月23日周日 11:58写道：
> > > > > >
> > > > > > > +1 (non-binding)
> > > > > > >
> > > > > > > Best,
> > > > > > > Paul Lam
> > > > > > >
> > > > > > > > 2023年4月23日 10:57，Shammon FY <zj...@gmail.com> 写道：
> > > > > > > >
> > > > > > > > +1 (non-binding)
> > > > > > > >
> > > > > > > > Best,
> > > > > > > > Shammon FY
> > > > > > > >
> > > > > > > > On Sun, Apr 23, 2023 at 10:35 AM Qingsheng Ren <
> > > renqschn@gmail.com
> > > > > > > <ma...@gmail.com>> wrote:
> > > > > > > >
> > > > > > > >> Thanks for pushing this FLIP forward, Hongshun!
> > > > > > > >>
> > > > > > > >> +1 (binding)
> > > > > > > >>
> > > > > > > >> Best,
> > > > > > > >> Qingsheng
> > > > > > > >>
> > > > > > > >> On Fri, Apr 21, 2023 at 2:52 PM Hongshun Wang <
> > > > > > loserwang1024@gmail.com>
> > > > > > > >> wrote:
> > > > > > > >>
> > > > > > > >>> Dear Flink Developers,
> > > > > > > >>>
> > > > > > > >>>
> > > > > > > >>> Thank you for providing feedback on FLIP-288: Enable
> Dynamic
> > > > > > Partition
> > > > > > > >>> Discovery by Default in Kafka Source[1] on the discussion
> > > > > thread[2].
> > > > > > > >>>
> > > > > > > >>> The goal of the FLIP is to enable partition discovery by
> > > default
> > > > > and
> > > > > > > set
> > > > > > > >>> EARLIEST offset strategy for later discovered partitions.
> > > > > > > >>>
> > > > > > > >>>
> > > > > > > >>> I am initiating a vote for this FLIP. The vote will be open
> > for
> > > > at
> > > > > > > least
> > > > > > > >> 72
> > > > > > > >>> hours, unless there is an objection or insufficient votes.
> > > > > > > >>>
> > > > > > > >>>
> > > > > > > >>> [1]: [
> > > > > > > >>>
> > > > > > > >>>
> > > > > > > >>
> > > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source](https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> <https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)>
> > <
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> >
> > > <
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > >
> > > > <
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > >
> > > > > <
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > >
> > > > > > <
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > > >
> > > > > > > <
> > > > > >
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > > > >
> > > > > > > >> <
> > > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > > > > >
> > > > > > > >>> <
> > > > > > > >>
> > > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > > > > <
> > > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > > > > >
> > > > > > > >>>
> > > > > > > >>> [2]: [
> > > > > > > >>>
> > > > > > > >>>
> > > > > > > >>
> > > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6]
> > > > <
> > > > > > >
> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6
> > > ]>(
> > > > > > >
> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6
> > <
> > > > > > >
> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6
> > >)
> > > > > > > >>>
> > > > > > > >>>
> > > > > > > >>> Best regards,
> > > > > > > >>> Hongshun
> > > > > > >
> > > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
>
Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
Posted by Jing Ge <ji...@ververica.com.INVALID>.
+1(binding)
Best regards,
Jing
On Tue, Apr 25, 2023 at 5:17 AM Rui Fan <19...@gmail.com> wrote:
> +1 (binding)
>
> Best,
> Rui Fan
>
> On Tue, Apr 25, 2023 at 10:06 AM Biao Geng <bi...@gmail.com> wrote:
>
> > +1 (non-binding)
> > Best,
> > Biao Geng
> >
> > Martijn Visser <ma...@apache.org> 于2023年4月24日周一 20:20写道：
> >
> > > +1 (binding)
> > >
> > > On Mon, Apr 24, 2023 at 4:10 AM Feng Jin <ji...@gmail.com>
> wrote:
> > >
> > > > +1 (non-binding)
> > > >
> > > >
> > > > Best,
> > > > Feng
> > > >
> > > > On Mon, Apr 24, 2023 at 9:55 AM Hang Ruan <ru...@gmail.com>
> > > wrote:
> > > >
> > > > > +1 (non-binding)
> > > > >
> > > > > Best,
> > > > > Hang
> > > > >
> > > > > Paul Lam <pa...@gmail.com> 于2023年4月23日周日 11:58写道：
> > > > >
> > > > > > +1 (non-binding)
> > > > > >
> > > > > > Best,
> > > > > > Paul Lam
> > > > > >
> > > > > > > 2023年4月23日 10:57，Shammon FY <zj...@gmail.com> 写道：
> > > > > > >
> > > > > > > +1 (non-binding)
> > > > > > >
> > > > > > > Best,
> > > > > > > Shammon FY
> > > > > > >
> > > > > > > On Sun, Apr 23, 2023 at 10:35 AM Qingsheng Ren <
> > renqschn@gmail.com
> > > > > > <ma...@gmail.com>> wrote:
> > > > > > >
> > > > > > >> Thanks for pushing this FLIP forward, Hongshun!
> > > > > > >>
> > > > > > >> +1 (binding)
> > > > > > >>
> > > > > > >> Best,
> > > > > > >> Qingsheng
> > > > > > >>
> > > > > > >> On Fri, Apr 21, 2023 at 2:52 PM Hongshun Wang <
> > > > > loserwang1024@gmail.com>
> > > > > > >> wrote:
> > > > > > >>
> > > > > > >>> Dear Flink Developers,
> > > > > > >>>
> > > > > > >>>
> > > > > > >>> Thank you for providing feedback on FLIP-288: Enable Dynamic
> > > > > Partition
> > > > > > >>> Discovery by Default in Kafka Source[1] on the discussion
> > > > thread[2].
> > > > > > >>>
> > > > > > >>> The goal of the FLIP is to enable partition discovery by
> > default
> > > > and
> > > > > > set
> > > > > > >>> EARLIEST offset strategy for later discovered partitions.
> > > > > > >>>
> > > > > > >>>
> > > > > > >>> I am initiating a vote for this FLIP. The vote will be open
> for
> > > at
> > > > > > least
> > > > > > >> 72
> > > > > > >>> hours, unless there is an objection or insufficient votes.
> > > > > > >>>
> > > > > > >>>
> > > > > > >>> [1]: [
> > > > > > >>>
> > > > > > >>>
> > > > > > >>
> > > > > >
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source](https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> <https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)>
> > <
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> >
> > > <
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > >
> > > > <
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > >
> > > > > <
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > >
> > > > > > <
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > > >
> > > > > > >> <
> > > > > >
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > > > >
> > > > > > >>> <
> > > > > > >>
> > > > > >
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > > > <
> > > > > >
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > > > >
> > > > > > >>>
> > > > > > >>> [2]: [
> > > > > > >>>
> > > > > > >>>
> > > > > > >>
> > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6]
> > > <
> > > > > > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6
> > ]>(
> > > > > > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6
> <
> > > > > > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6
> >)
> > > > > > >>>
> > > > > > >>>
> > > > > > >>> Best regards,
> > > > > > >>> Hongshun
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
>
Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
Posted by Rui Fan <19...@gmail.com>.
+1 (binding)
Best,
Rui Fan
On Tue, Apr 25, 2023 at 10:06 AM Biao Geng <bi...@gmail.com> wrote:
> +1 (non-binding)
> Best,
> Biao Geng
>
> Martijn Visser <ma...@apache.org> 于2023年4月24日周一 20:20写道：
>
> > +1 (binding)
> >
> > On Mon, Apr 24, 2023 at 4:10 AM Feng Jin <ji...@gmail.com> wrote:
> >
> > > +1 (non-binding)
> > >
> > >
> > > Best,
> > > Feng
> > >
> > > On Mon, Apr 24, 2023 at 9:55 AM Hang Ruan <ru...@gmail.com>
> > wrote:
> > >
> > > > +1 (non-binding)
> > > >
> > > > Best,
> > > > Hang
> > > >
> > > > Paul Lam <pa...@gmail.com> 于2023年4月23日周日 11:58写道：
> > > >
> > > > > +1 (non-binding)
> > > > >
> > > > > Best,
> > > > > Paul Lam
> > > > >
> > > > > > 2023年4月23日 10:57，Shammon FY <zj...@gmail.com> 写道：
> > > > > >
> > > > > > +1 (non-binding)
> > > > > >
> > > > > > Best,
> > > > > > Shammon FY
> > > > > >
> > > > > > On Sun, Apr 23, 2023 at 10:35 AM Qingsheng Ren <
> renqschn@gmail.com
> > > > > <ma...@gmail.com>> wrote:
> > > > > >
> > > > > >> Thanks for pushing this FLIP forward, Hongshun!
> > > > > >>
> > > > > >> +1 (binding)
> > > > > >>
> > > > > >> Best,
> > > > > >> Qingsheng
> > > > > >>
> > > > > >> On Fri, Apr 21, 2023 at 2:52 PM Hongshun Wang <
> > > > loserwang1024@gmail.com>
> > > > > >> wrote:
> > > > > >>
> > > > > >>> Dear Flink Developers,
> > > > > >>>
> > > > > >>>
> > > > > >>> Thank you for providing feedback on FLIP-288: Enable Dynamic
> > > > Partition
> > > > > >>> Discovery by Default in Kafka Source[1] on the discussion
> > > thread[2].
> > > > > >>>
> > > > > >>> The goal of the FLIP is to enable partition discovery by
> default
> > > and
> > > > > set
> > > > > >>> EARLIEST offset strategy for later discovered partitions.
> > > > > >>>
> > > > > >>>
> > > > > >>> I am initiating a vote for this FLIP. The vote will be open for
> > at
> > > > > least
> > > > > >> 72
> > > > > >>> hours, unless there is an objection or insufficient votes.
> > > > > >>>
> > > > > >>>
> > > > > >>> [1]: [
> > > > > >>>
> > > > > >>>
> > > > > >>
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source](https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> <https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)>
> > <
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> >
> > > <
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > >
> > > > <
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > >
> > > > > <
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > >
> > > > > >> <
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > > >
> > > > > >>> <
> > > > > >>
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > > <
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > > >
> > > > > >>>
> > > > > >>> [2]: [
> > > > > >>>
> > > > > >>>
> > > > > >>
> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6]
> > <
> > > > > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6
> ]>(
> > > > > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6 <
> > > > > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6>)
> > > > > >>>
> > > > > >>>
> > > > > >>> Best regards,
> > > > > >>> Hongshun
> > > > >
> > > > >
> > > >
> > >
> >
>
Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
Posted by Biao Geng <bi...@gmail.com>.
+1 (non-binding)
Best,
Biao Geng
Martijn Visser <ma...@apache.org> 于2023年4月24日周一 20:20写道：
> +1 (binding)
>
> On Mon, Apr 24, 2023 at 4:10 AM Feng Jin <ji...@gmail.com> wrote:
>
> > +1 (non-binding)
> >
> >
> > Best,
> > Feng
> >
> > On Mon, Apr 24, 2023 at 9:55 AM Hang Ruan <ru...@gmail.com>
> wrote:
> >
> > > +1 (non-binding)
> > >
> > > Best,
> > > Hang
> > >
> > > Paul Lam <pa...@gmail.com> 于2023年4月23日周日 11:58写道：
> > >
> > > > +1 (non-binding)
> > > >
> > > > Best,
> > > > Paul Lam
> > > >
> > > > > 2023年4月23日 10:57，Shammon FY <zj...@gmail.com> 写道：
> > > > >
> > > > > +1 (non-binding)
> > > > >
> > > > > Best,
> > > > > Shammon FY
> > > > >
> > > > > On Sun, Apr 23, 2023 at 10:35 AM Qingsheng Ren <renqschn@gmail.com
> > > > <ma...@gmail.com>> wrote:
> > > > >
> > > > >> Thanks for pushing this FLIP forward, Hongshun!
> > > > >>
> > > > >> +1 (binding)
> > > > >>
> > > > >> Best,
> > > > >> Qingsheng
> > > > >>
> > > > >> On Fri, Apr 21, 2023 at 2:52 PM Hongshun Wang <
> > > loserwang1024@gmail.com>
> > > > >> wrote:
> > > > >>
> > > > >>> Dear Flink Developers,
> > > > >>>
> > > > >>>
> > > > >>> Thank you for providing feedback on FLIP-288: Enable Dynamic
> > > Partition
> > > > >>> Discovery by Default in Kafka Source[1] on the discussion
> > thread[2].
> > > > >>>
> > > > >>> The goal of the FLIP is to enable partition discovery by default
> > and
> > > > set
> > > > >>> EARLIEST offset strategy for later discovered partitions.
> > > > >>>
> > > > >>>
> > > > >>> I am initiating a vote for this FLIP. The vote will be open for
> at
> > > > least
> > > > >> 72
> > > > >>> hours, unless there is an objection or insufficient votes.
> > > > >>>
> > > > >>>
> > > > >>> [1]: [
> > > > >>>
> > > > >>>
> > > > >>
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source](https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> <https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)>
> > <
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> >
> > > <
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > >
> > > > <
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > >
> > > > >> <
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > >
> > > > >>> <
> > > > >>
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > <
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > > >
> > > > >>>
> > > > >>> [2]: [
> > > > >>>
> > > > >>>
> > > > >> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6]
> <
> > > > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6]>(
> > > > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6 <
> > > > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6>)
> > > > >>>
> > > > >>>
> > > > >>> Best regards,
> > > > >>> Hongshun
> > > >
> > > >
> > >
> >
>
Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
Posted by Martijn Visser <ma...@apache.org>.
+1 (binding)
On Mon, Apr 24, 2023 at 4:10 AM Feng Jin <ji...@gmail.com> wrote:
> +1 (non-binding)
>
>
> Best,
> Feng
>
> On Mon, Apr 24, 2023 at 9:55 AM Hang Ruan <ru...@gmail.com> wrote:
>
> > +1 (non-binding)
> >
> > Best,
> > Hang
> >
> > Paul Lam <pa...@gmail.com> 于2023年4月23日周日 11:58写道：
> >
> > > +1 (non-binding)
> > >
> > > Best,
> > > Paul Lam
> > >
> > > > 2023年4月23日 10:57，Shammon FY <zj...@gmail.com> 写道：
> > > >
> > > > +1 (non-binding)
> > > >
> > > > Best,
> > > > Shammon FY
> > > >
> > > > On Sun, Apr 23, 2023 at 10:35 AM Qingsheng Ren <renqschn@gmail.com
> > > <ma...@gmail.com>> wrote:
> > > >
> > > >> Thanks for pushing this FLIP forward, Hongshun!
> > > >>
> > > >> +1 (binding)
> > > >>
> > > >> Best,
> > > >> Qingsheng
> > > >>
> > > >> On Fri, Apr 21, 2023 at 2:52 PM Hongshun Wang <
> > loserwang1024@gmail.com>
> > > >> wrote:
> > > >>
> > > >>> Dear Flink Developers,
> > > >>>
> > > >>>
> > > >>> Thank you for providing feedback on FLIP-288: Enable Dynamic
> > Partition
> > > >>> Discovery by Default in Kafka Source[1] on the discussion
> thread[2].
> > > >>>
> > > >>> The goal of the FLIP is to enable partition discovery by default
> and
> > > set
> > > >>> EARLIEST offset strategy for later discovered partitions.
> > > >>>
> > > >>>
> > > >>> I am initiating a vote for this FLIP. The vote will be open for at
> > > least
> > > >> 72
> > > >>> hours, unless there is an objection or insufficient votes.
> > > >>>
> > > >>>
> > > >>> [1]: [
> > > >>>
> > > >>>
> > > >>
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source](https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> <https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)>
> > <
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> >
> > > <
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > >
> > > >> <
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > >
> > > >>> <
> > > >>
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > <
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > > >
> > > >>>
> > > >>> [2]: [
> > > >>>
> > > >>>
> > > >> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6] <
> > > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6]>(
> > > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6 <
> > > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6>)
> > > >>>
> > > >>>
> > > >>> Best regards,
> > > >>> Hongshun
> > >
> > >
> >
>
Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
Posted by Feng Jin <ji...@gmail.com>.
+1 (non-binding)
Best,
Feng
On Mon, Apr 24, 2023 at 9:55 AM Hang Ruan <ru...@gmail.com> wrote:
> +1 (non-binding)
>
> Best,
> Hang
>
> Paul Lam <pa...@gmail.com> 于2023年4月23日周日 11:58写道：
>
> > +1 (non-binding)
> >
> > Best,
> > Paul Lam
> >
> > > 2023年4月23日 10:57，Shammon FY <zj...@gmail.com> 写道：
> > >
> > > +1 (non-binding)
> > >
> > > Best,
> > > Shammon FY
> > >
> > > On Sun, Apr 23, 2023 at 10:35 AM Qingsheng Ren <renqschn@gmail.com
> > <ma...@gmail.com>> wrote:
> > >
> > >> Thanks for pushing this FLIP forward, Hongshun!
> > >>
> > >> +1 (binding)
> > >>
> > >> Best,
> > >> Qingsheng
> > >>
> > >> On Fri, Apr 21, 2023 at 2:52 PM Hongshun Wang <
> loserwang1024@gmail.com>
> > >> wrote:
> > >>
> > >>> Dear Flink Developers,
> > >>>
> > >>>
> > >>> Thank you for providing feedback on FLIP-288: Enable Dynamic
> Partition
> > >>> Discovery by Default in Kafka Source[1] on the discussion thread[2].
> > >>>
> > >>> The goal of the FLIP is to enable partition discovery by default and
> > set
> > >>> EARLIEST offset strategy for later discovered partitions.
> > >>>
> > >>>
> > >>> I am initiating a vote for this FLIP. The vote will be open for at
> > least
> > >> 72
> > >>> hours, unless there is an objection or insufficient votes.
> > >>>
> > >>>
> > >>> [1]: [
> > >>>
> > >>>
> > >>
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source](https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> <https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)>
> > <
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> >
> > >> <
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > >
> > >>> <
> > >>
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > <
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> > >
> > >>>
> > >>> [2]: [
> > >>>
> > >>>
> > >> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6] <
> > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6]>(
> > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6 <
> > https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6>)
> > >>>
> > >>>
> > >>> Best regards,
> > >>> Hongshun
> >
> >
>
Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
Posted by Hang Ruan <ru...@gmail.com>.
+1 (non-binding)
Best,
Hang
Paul Lam <pa...@gmail.com> 于2023年4月23日周日 11:58写道：
> +1 (non-binding)
>
> Best,
> Paul Lam
>
> > 2023年4月23日 10:57，Shammon FY <zj...@gmail.com> 写道：
> >
> > +1 (non-binding)
> >
> > Best,
> > Shammon FY
> >
> > On Sun, Apr 23, 2023 at 10:35 AM Qingsheng Ren <renqschn@gmail.com
> <ma...@gmail.com>> wrote:
> >
> >> Thanks for pushing this FLIP forward, Hongshun!
> >>
> >> +1 (binding)
> >>
> >> Best,
> >> Qingsheng
> >>
> >> On Fri, Apr 21, 2023 at 2:52 PM Hongshun Wang <lo...@gmail.com>
> >> wrote:
> >>
> >>> Dear Flink Developers,
> >>>
> >>>
> >>> Thank you for providing feedback on FLIP-288: Enable Dynamic Partition
> >>> Discovery by Default in Kafka Source[1] on the discussion thread[2].
> >>>
> >>> The goal of the FLIP is to enable partition discovery by default and
> set
> >>> EARLIEST offset strategy for later discovered partitions.
> >>>
> >>>
> >>> I am initiating a vote for this FLIP. The vote will be open for at
> least
> >> 72
> >>> hours, unless there is an objection or insufficient votes.
> >>>
> >>>
> >>> [1]: [
> >>>
> >>>
> >>
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source](https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> <https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)>
> >> <
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> >
> >>> <
> >>
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> <
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> >
> >>>
> >>> [2]: [
> >>>
> >>>
> >> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6] <
> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6]>(
> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6 <
> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6>)
> >>>
> >>>
> >>> Best regards,
> >>> Hongshun
>
>
Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
Posted by Paul Lam <pa...@gmail.com>.
+1 (non-binding)
Best,
Paul Lam
> 2023年4月23日 10:57，Shammon FY <zj...@gmail.com> 写道：
>
> +1 (non-binding)
>
> Best,
> Shammon FY
>
> On Sun, Apr 23, 2023 at 10:35 AM Qingsheng Ren <renqschn@gmail.com <ma...@gmail.com>> wrote:
>
>> Thanks for pushing this FLIP forward, Hongshun!
>>
>> +1 (binding)
>>
>> Best,
>> Qingsheng
>>
>> On Fri, Apr 21, 2023 at 2:52 PM Hongshun Wang <lo...@gmail.com>
>> wrote:
>>
>>> Dear Flink Developers,
>>>
>>>
>>> Thank you for providing feedback on FLIP-288: Enable Dynamic Partition
>>> Discovery by Default in Kafka Source[1] on the discussion thread[2].
>>>
>>> The goal of the FLIP is to enable partition discovery by default and set
>>> EARLIEST offset strategy for later discovered partitions.
>>>
>>>
>>> I am initiating a vote for this FLIP. The vote will be open for at least
>> 72
>>> hours, unless there is an objection or insufficient votes.
>>>
>>>
>>> [1]: [
>>>
>>>
>> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source](https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
>> <https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)>
>>> <
>> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source) <https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)>
>>>
>>> [2]: [
>>>
>>>
>> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6] <https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6]>(https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6 <https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6>)
>>>
>>>
>>> Best regards,
>>> Hongshun
Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
Posted by Shammon FY <zj...@gmail.com>.
+1 (non-binding)
Best,
Shammon FY
On Sun, Apr 23, 2023 at 10:35 AM Qingsheng Ren <re...@gmail.com> wrote:
> Thanks for pushing this FLIP forward, Hongshun!
>
> +1 (binding)
>
> Best,
> Qingsheng
>
> On Fri, Apr 21, 2023 at 2:52 PM Hongshun Wang <lo...@gmail.com>
> wrote:
>
> > Dear Flink Developers,
> >
> >
> > Thank you for providing feedback on FLIP-288: Enable Dynamic Partition
> > Discovery by Default in Kafka Source[1] on the discussion thread[2].
> >
> > The goal of the FLIP is to enable partition discovery by default and set
> > EARLIEST offset strategy for later discovered partitions.
> >
> >
> > I am initiating a vote for this FLIP. The vote will be open for at least
> 72
> > hours, unless there is an objection or insufficient votes.
> >
> >
> > [1]: [
> >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source](https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> <https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)>
> > <
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> >
> > [2]: [
> >
> >
> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6](https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6)
> >
> >
> > Best regards,
> > Hongshun
> >
>
Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
Posted by Qingsheng Ren <re...@gmail.com>.
Thanks for pushing this FLIP forward, Hongshun!
+1 (binding)
Best,
Qingsheng
On Fri, Apr 21, 2023 at 2:52 PM Hongshun Wang <lo...@gmail.com>
wrote:
> Dear Flink Developers,
>
>
> Thank you for providing feedback on FLIP-288: Enable Dynamic Partition
> Discovery by Default in Kafka Source[1] on the discussion thread[2].
>
> The goal of the FLIP is to enable partition discovery by default and set
> EARLIEST offset strategy for later discovered partitions.
>
>
> I am initiating a vote for this FLIP. The vote will be open for at least 72
> hours, unless there is an objection or insufficient votes.
>
>
> [1]: [
>
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source](https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)
> <https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source%5D(https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source)>
> [2]: [
>
> https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6](https://lists.apache.org/thread/581f2xq5d1tlwc8gcr27gwkp3zp0wrg6)
>
>
> Best regards,
> Hongshun
>