Hi Matyas, could you please provide more details on the KafkaMetadataService? Where does it live? How does it work? How does "Metadata state will be stored in Flink state as the source of truth for the Flink job" work?
Also nit: the test plan contains copy&paste errors. Best, Arvid On Thu, Mar 13, 2025 at 10:04 PM Őrhidi Mátyás <matyas.orh...@gmail.com> wrote: > > Hi devs, > > I'd like to start a discussion on FLIP-515: Dynamic Kafka Sink [1]. This is > an addition to the existing Dynamic Kafka Source [2] to make the > functionality complete. > > Feel free to share your thoughts and suggestions to make this feature > better. > > + Mason Chen > > Thanks, > Matyas > > [1] > https://cwiki.apache.org/confluence/display/FLINK/FLIP-515%3A+Dynamic+Kafka+Sink > > [2] > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=217389320
