This is an automated email from the ASF dual-hosted git repository. je-ik pushed a commit to branch feat/18479-kafka-streams-runner-skeleton in repository https://gitbox.apache.org/repos/asf/beam.git
commit 64ad482f9de606d51b4653b49424f80126eed789 Merge: 55eb624e5cd d4c7dae98b8 Author: Jan Lukavský <[email protected]> AuthorDate: Sat May 23 18:02:38 2026 +0200 Merge pull request #38534: [GSoC 2026] Kafka Streams runner skeleton module + portable entry points .../beam_PreCommit_Java_Kafka_Streams_Runner.json | 4 + .github/workflows/README.md | 1 + .../beam_PreCommit_Java_Kafka_Streams_Runner.yml | 118 +++++++++++++++++++++ CHANGES.md | 1 + build.gradle.kts | 1 + runners/kafka-streams/build.gradle | 67 ++++++++++++ .../kafka/streams/KafkaStreamsJobInvoker.java | 96 +++++++++++++++++ .../kafka/streams/KafkaStreamsJobServerDriver.java | 106 ++++++++++++++++++ .../kafka/streams/KafkaStreamsPipelineOptions.java | 81 ++++++++++++++ .../kafka/streams/KafkaStreamsPipelineResult.java | 77 ++++++++++++++ .../kafka/streams/KafkaStreamsPipelineRunner.java | 45 ++++++++ .../runners/kafka/streams/KafkaStreamsRunner.java | 101 ++++++++++++++++++ .../kafka/streams/KafkaStreamsRunnerRegistrar.java | 48 +++++++++ .../beam/runners/kafka/streams/package-info.java | 20 ++++ .../KafkaStreamsPipelineTranslator.java | 70 ++++++++++++ .../KafkaStreamsTranslationContext.java | 47 ++++++++ .../kafka/streams/translation/package-info.java | 20 ++++ .../streams/KafkaStreamsJobServerDriverTest.java | 71 +++++++++++++ .../streams/KafkaStreamsPipelineOptionsTest.java | 90 ++++++++++++++++ .../KafkaStreamsPipelineTranslatorTest.java | 113 ++++++++++++++++++++ settings.gradle.kts | 1 + 21 files changed, 1178 insertions(+)
