+1 (binding) On Tue, Apr 8, 2025 at 12:14 PM Őrhidi Mátyás <matyas.orh...@gmail.com> wrote:
> Hi Leonard, > > Your findings are correct. Users have to implement their own > KafkaMetadataService. KafkaMetadataServiceImpl is an example for API usage > in the docs. > > Best, > Matyas > > On Tue, Apr 8, 2025 at 1:32 AM Leonard Xu <xbjt...@gmail.com> wrote: > > > Hi @Matyas, > > > > First of all, apologies for jumping into the vote thread. Could you > kindly > > reply to Hongshun’s question in the discussion thread when you have a > > moment? > > > > Additionally, I have a question regarding the KafkaMetadataServiceImpl > > class mentioned in your proposed Public Interface. I revisited FLIP-246: > > Dynamic Kafka Source (originally Multi-Cluster Kafka Source)[1], where > it > > was documented that: > > > > // Some default implementations will be provided (file-based, statically > > defined streams) > > .setKafkaMetadataService(new KafkaMetadataServiceImpl()) > > However, I couldn’t find this class in the latest codebase[2]. Could you > > confirm whether users can connect to their Multi-Cluster Kafka after > > FLIP-515 without having to implement their own KafkaMetadataService? > > > > Looking forward to your clarification. > > > > Best, > > Leonard > > > > [1] > > > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=217389320 > > > > [2]https://github.com/apache/flink-connector-kafka/tree/main > > > > > > > 2025 4月 8 02:13，Alexander Fedulov <alexander.fedu...@gmail.com> 写道： > > > > > > +1 (binding) > > > > > > Best, > > > Alex > > > > > > On Mon, 7 Apr 2025 at 18:26, Maximilian Michels <m...@apache.org> > wrote: > > > > > >> +1 (binding) > > >> > > >> Cheers, > > >> Max > > >> > > >> On Thu, Apr 3, 2025 at 2:04 PM Gabor Somogyi < > gabor.g.somo...@gmail.com > > > > > >> wrote: > > >>> > > >>> +1 (binding) > > >>> > > >>> BR, > > >>> G > > >>> > > >>> > > >>> On Thu, Apr 3, 2025 at 11:49 AM <gyula.f...@gmail.com> wrote: > > >>> > > >>>> +1 (binding) > > >>>> > > >>>> Gyula > > >>>> Sent from my iPhone > > >>>> > > >>>>> On 3 Apr 2025, at 00:32, Őrhidi Mátyás <matyas.orh...@gmail.com> > > >> wrote: > > >>>>> > > >>>>> Hi devs, > > >>>>> > > >>>>> I would like to start the vote for FLIP-515: Dynamic Kafka Sink [1] > > >>>>> > > >>>>> This FLIP was discussed in this thread [2]. > > >>>>> > > >>>>> 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-515:+Dynamic+Kafka+Sink > > >>>>> > > >>>>> [2] > https://lists.apache.org/thread/n03bc8o53yj5llnr5xhcnqdxr0goxm5v > > >>>>> > > >>>>> Thanks, > > >>>>> Matyas Orhidi > > >>>> > > >> > > > > >
