junaiddshaukat commented on issue #38616: URL: https://github.com/apache/beam/issues/38616#issuecomment-4583004600
> Hi @junaiddshaukat, I’m interested in working on this issue and have started studying the existing Kafka Streams runner skeleton merged in #38534 along with the follow-up design discussion. > > I’ll first sync with the latest integration branch and review the Flink portable runner translation flow (FlinkStreamingPortablePipelineTranslator) to align the implementation patterns before starting work on the translation framework and Impulse translator. > > My plan is to focus on: > > * URN-based translator dispatch infrastructure > * KafkaStreamsTranslationContext topology + PCollection mapping > * ImpulseTranslator using the dedicated bootstrap-topic approach > * TopologyTestDriver coverage for one-time Impulse emission and unsupported URN validation > > I’ll keep the implementation incremental and Beam-style compliant (nullness-clean, tests included, no unnecessary suppressions). Thanks for your interest, but this is a reserve for Google summary of code -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
