Skip to content
Navigation Menu
Sign in
Products
Platform
GitHub
Repository hosting, code review, and collaboration
Copilot
AI coding agent for tasks, projects and automated work
Build & Ship
Actions
CI/CD and automation
Code Quality
Quality analysis, fixes, and enforcement
Codespaces
Cloud development environments
Secure
Code Security
Vulnerability detection and remediation
Secret Protection
Secret scanning and leak prevention
All Features
Developers
Learn
Documentation
Training
Certifications
Build
Build with Copilot
Customize Copilot
Integrations
Explore
Trending repos
GitHub Sponsors
Events
Changelog
Changelog
Your source for the latest features, improvements, and fixes across GitHub products, all in one place.
Businesses
By Stage
Enterprises
Team
Startups
Nonprofits
By Industry
Healthcare
Financial services
Manufacturing
Government
See all industries
Evaluate GitHub
Why GitHub
Customer Stories
Business insights
Trust Center
Add-ons
GitHub Advanced Security
Enterprise-grade code security
Copilot for business
Enterprise-grade AI features
Premium Support
Enterprise-grade 24/7 support
Resources
Learn & Connect
Documentation
Resource center
Blog
Events & webinars
Community Forum
Customer Stories
Integrations
Support
Customer support
Training
GitHub Status
Company
About
Partners
Changelog
GitHub Universe
GitHub Universe
The event for developers, by developers — talks, workshops, and what’s next for GitHub.
Pricing
Search
/
Sign in
Sign up
Appearance settings
You signed in with another tab or window.
Reload
to refresh your session.
You signed out in another tab or window.
Reload
to refresh your session.
You switched accounts on another tab or window.
Reload
to refresh your session.
Dismiss alert
{{ message }}
apache
beam
Repository navigation
Code
Issues
3.7k
(3.7k)
Pull requests
155
(155)
Actions
Projects
Security and quality
Insights
More
items
[DO NOT MERGE] Feat/18479 kafka streams runner skeleton master merged
- #39787
#39787
Closed
je-ik
wants to merge 44 commits into
master
apache/beam:master
from
feat/18479-kafka-streams-runner-skeleton-master-merged
apache/beam:feat/18479-kafka-streams-runner-skeleton-master-merged
Copy head branch name to clipboard
Conversation
Commits
44
(44)
Checks
Files changed
Closed
[DO NOT MERGE] Feat/18479 kafka streams runner skeleton master merged
#39787
je-ik
wants to merge 44 commits into
master
apache/beam:master
from
feat/18479-kafka-streams-runner-skeleton-master-merged
apache/beam:feat/18479-kafka-streams-runner-skeleton-master-merged
Copy head branch name to clipboard
Commits
Commits on May 19, 2026
Add Kafka Streams runner skeleton module and portable entry points
junaiddshaukat
committed
2e44530
View commit details
Copy full SHA for 2e44530
Browse repository at this point
Address review notes on KafkaStreamsPipelineResult and state dir
Show description for 61c891a
junaiddshaukat
committed
61c891a
View commit details
Copy full SHA for 61c891a
Browse repository at this point
Commits on May 21, 2026
Address review feedback on Kafka Streams Runner skeleton
junaiddshaukat
committed
cef6544
View commit details
Copy full SHA for cef6544
Browse repository at this point
Commits on May 22, 2026
Drop setRunner(null) suppression; make applicationId required
junaiddshaukat
committed
0d445f7
View commit details
Copy full SHA for 0d445f7
Browse repository at this point
Commits on May 23, 2026
Catch Exception in KafkaStreamsRunner.run() to avoid job-server leak
junaiddshaukat
committed
d4c7dae
View commit details
Copy full SHA for d4c7dae
Browse repository at this point
Merge pull request #38534: [GSoC 2026] Kafka Streams runner skeleton module + portable entry points
je-ik
authored
64ad482
View commit details
Copy full SHA for 64ad482
Browse repository at this point
Commits on May 28, 2026
[GSoC 2026] Kafka Streams runner — translation framework + Impulse translator (#38689)
Show description for faefc95
junaiddshaukat
authored
faefc95
View commit details
Copy full SHA for faefc95
Browse repository at this point
Add temporary feature-branch CI for Kafka Streams runner (#38725)
Show description for 0f875a0
junaiddshaukat
authored
0f875a0
View commit details
Copy full SHA for 0f875a0
Browse repository at this point
Commits on Jun 7, 2026
[GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator (#38764)
Show description for ff554f7
junaiddshaukat
authored
ff554f7
View commit details
Copy full SHA for ff554f7
Browse repository at this point
Commits on Jun 10, 2026
[GSoC 2026] Kafka Streams runner — Redistribute translator + ExecutableStage type-agnostic edge (#38843)
Show description for 4c02a77
junaiddshaukat
authored
4c02a77
View commit details
Copy full SHA for 4c02a77
Browse repository at this point
Commits on Jun 15, 2026
#38957: Add in-memory WatermarkManager core (per-source-partition tracking
junaiddshaukat
authored
4636b1f
View commit details
Copy full SHA for 4636b1f
Browse repository at this point
Commits on Jun 18, 2026
[GSoC 2026] Kafka Streams runner #38987: Wire WatermarkManager into ExecutableStageProcessor
junaiddshaukat
authored
1058e94
View commit details
Copy full SHA for 1058e94
Browse repository at this point
Commits on Jun 27, 2026
[GSoC 2026] Kafka Streams runner #39051: Add KStreamsPayload Serde for crossing topic boundaries
junaiddshaukat
authored
3e963a6
View commit details
Copy full SHA for 3e963a6
Browse repository at this point
Commits on Jun 30, 2026
[GSoC 2026] Kafka Streams runner #39141: Add GroupByKey (GlobalWindow, fire at watermark)
junaiddshaukat
authored
5e65d47
View commit details
Copy full SHA for 5e65d47
Browse repository at this point
Commits on Jul 7, 2026
[GSoC 2026] Kafka Streams runner #39211: Add KafkaStreamsTestRunner test harness
junaiddshaukat
authored
4d5847f
View commit details
Copy full SHA for 4d5847f
Browse repository at this point
Commits on Jul 9, 2026
[GSoC 2026] Kafka Streams runner #39249: Support Create
junaiddshaukat
authored
27c4522
View commit details
Copy full SHA for 27c4522
Browse repository at this point
Commits on Jul 15, 2026
[GSoC 2026] Kafka Streams runner #39273: Kafka Streams runner: Flatten support
junaiddshaukat
authored
ff323eb
View commit details
Copy full SHA for ff323eb
Browse repository at this point
Commits on Jul 16, 2026
[GSoC 2026] Kafka Streams runner: surface SDK-harness metrics as MetricResults (#39341)
junaiddshaukat
authored
75adf49
View commit details
Copy full SHA for 75adf49
Browse repository at this point
Commits on Jul 17, 2026
[GSoC 2026] Kafka Streams runner: TestPipeline-dispatchable test runner (PAssert works) (#39362)
junaiddshaukat
authored
87911f0
View commit details
Copy full SHA for 87911f0
Browse repository at this point
Commits on Jul 20, 2026
[GSoC 2026] Kafka Streams runner: validatesRunner task; Create and Flatten suites green (#39380)
junaiddshaukat
authored
d9cea58
View commit details
Copy full SHA for d9cea58
Browse repository at this point
Commits on Jul 22, 2026
[GSoC 2026] Kafka Streams runner: multi-output executable stages (#39410)
junaiddshaukat
authored
fca1435
View commit details
Copy full SHA for fca1435
Browse repository at this point
Commits on Jul 23, 2026
[GSoC 2026] Kafka Streams runner: enable ParDoTest in the ValidatesRunner suite (#39451)
junaiddshaukat
authored
b615ae8
View commit details
Copy full SHA for b615ae8
Browse repository at this point
Commits on Jul 28, 2026
[GSoC 2026] Kafka Streams runner: windowed GroupByKey via ReduceFnRunner (#39494)
Show description for 47614a9
junaiddshaukat
authored
47614a9
View commit details
Copy full SHA for 47614a9
Browse repository at this point
Commits on Aug 1, 2026
[GSoC 2026] Kafka Streams runner: run on a real broker, correctly across partitions (#39546)
Show description for 2719876
junaiddshaukat
authored
2719876
View commit details
Copy full SHA for 2719876
Browse repository at this point
Commits on Aug 3, 2026
[GSoC 2026] Kafka Streams runner: bound a bundle by element count (#39578)
Show description for cf1f10b
junaiddshaukat
authored
cf1f10b
View commit details
Copy full SHA for cf1f10b
Browse repository at this point
Commits on Aug 4, 2026
[GSoC 2026] Kafka Streams runner: CombineTest coverage and two review follow-ups (#39610)
Show description for fc36301
junaiddshaukat
authored
fc36301
View commit details
Copy full SHA for fc36301
Browse repository at this point
[GSoC 2026] Kafka Streams runner: read unbounded sources (#39611)
Show description for 5861f31
junaiddshaukat
authored
5861f31
View commit details
Copy full SHA for 5861f31
Browse repository at this point
Commits on Aug 9, 2026
[GSoC 2026] Kafka Streams runner: user documentation, marked experimental (#39627)
Show description for cb30afd
junaiddshaukat
authored
cb30afd
View commit details
Copy full SHA for cb30afd
Browse repository at this point
Commits on Aug 10, 2026
[GSoC 2026] Kafka Streams runner: Python wrapper that starts its own job server (#39680)
Show description for e051e06
junaiddshaukat
authored
e051e06
View commit details
Copy full SHA for e051e06
Browse repository at this point
Commits on Aug 11, 2026
[GSoC 2026] Kafka Streams runner: terminate a bounded pipeline when it is drained (#39700)
Show description for 4ff6180
junaiddshaukat
authored
4ff6180
View commit details
Copy full SHA for 4ff6180
Browse repository at this point
Commits on Aug 13, 2026
[GSoC 2026] Kafka Streams runner: portable ValidatesRunner suite for Python (#39736)
Show description for 5f1658f
junaiddshaukat
authored
5f1658f
View commit details
Copy full SHA for 5f1658f
Browse repository at this point
Commits on Aug 14, 2026
[GSoC 2026] Kafka Streams runner: separate the source's poll size from the bundle size, and expose the session timeout (#39748)
junaiddshaukat
authored
511a40e
View commit details
Copy full SHA for 511a40e
Browse repository at this point
Commits on Aug 16, 2026
[GSoC 2026] Kafka Streams runner: bound a source poll in time, not only in elements (#39761)
Show description for 65a2e40
junaiddshaukat
authored
65a2e40
View commit details
Copy full SHA for 65a2e40
Browse repository at this point
[GSoC 2026] Kafka Streams runner: ask for primitive reads in the Java wrapper (#39766)
Show description for 104dc27
junaiddshaukat
authored
104dc27
View commit details
Copy full SHA for 104dc27
Browse repository at this point
[GSoC 2026] Kafka Streams runner: put the runner behind an opt-in build flag (#39762)
junaiddshaukat
authored
49d459a
View commit details
Copy full SHA for 49d459a
Browse repository at this point
[GSoC 2026] Kafka Streams runner: an application for measuring instances coming and going (#39752)
Show description for 10ff557
junaiddshaukat
authored
10ff557
View commit details
Copy full SHA for 10ff557
Browse repository at this point
Commits on Aug 17, 2026
[GSoC 2026] Kafka Streams runner: license header and Python formatting for master CI
Show description for 5b37024
junaiddshaukat
committed
5b37024
View commit details
Copy full SHA for 5b37024
Browse repository at this point
[GSoC 2026] Kafka Streams runner: shorten the explanation comments
Show description for b12bfc1
junaiddshaukat
committed
b12bfc1
View commit details
Copy full SHA for b12bfc1
Browse repository at this point
Merge pull request #39781: [GSoC 2026] Kafka Streams runner: shorten comments, and fix the license header and Python formatting
je-ik
authored
8d5f651
View commit details
Copy full SHA for 8d5f651
Browse repository at this point
Build Kafka Streams runner during javaPreCommit (#18479)
je-ik
committed
e268108
View commit details
Copy full SHA for e268108
Browse repository at this point
Merge pull request #39784: Build Kafka Streams runner during javaPreCommit (#18479)
je-ik
authored
8b3b08d
View commit details
Copy full SHA for 8b3b08d
Browse repository at this point
[GSoC 2026] Kafka Streams runner: update the CHANGES.md entry
Show description for b67cf23
junaiddshaukat
committed
b67cf23
View commit details
Copy full SHA for b67cf23
Browse repository at this point
Merge pull request #39786: [GSoC 2026] Kafka Streams runner: update the CHANGES.md entry
je-ik
authored
52dadba
View commit details
Copy full SHA for 52dadba
Browse repository at this point
Merge remote-tracking branch 'origin/master' into feat/18479-kafka-streams-runner-skeleton
je-ik
committed
fd8a626
View commit details
Copy full SHA for fd8a626
Browse repository at this point
You can’t perform that action at this time.
