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 > >>>> > >> > >
