Skip to content
Navigation Menu
Sign in
Appearance settings
Platform
AI CODE CREATION
GitHub Copilot
Write better code with AI
GitHub Copilot app
Direct agents from issue to merge
MCP Registry
Integrate external tools
DEVELOPER WORKFLOWS
Actions
Automate any workflow
Codespaces
Instant dev environments
Issues
Plan and track work
Code Review
Manage code changes
Code Quality
Enforce quality at merge
APPLICATION SECURITY
GitHub Advanced Security
Find and fix vulnerabilities
Code security
Secure your code as you build
Secret protection
Stop leaks before they start
EXPLORE
Why GitHub
Documentation
Blog
Changelog
Marketplace
View all features
Solutions
BY COMPANY SIZE
Enterprises
Small and medium teams
Startups
Nonprofits
BY USE CASE
App Modernization
DevSecOps
DevOps
CI/CD
View all use cases
BY INDUSTRY
Healthcare
Financial services
Manufacturing
Government
View all industries
View all solutions
Resources
EXPLORE BY TOPIC
AI
Software Development
DevOps
Security
View all topics
EXPLORE BY TYPE
Customer stories
Events & webinars
Ebooks & reports
Business insights
GitHub Skills
SUPPORT & SERVICES
Documentation
Customer support
Community forum
Trust center
Partners
View all resources
Open Source
COMMUNITY
GitHub Sponsors
Fund open source developers
PROGRAMS
Security Lab
Maintainer Community
GitHub Stars
Archive Program
REPOSITORIES
Topics
Trending
Collections
Enterprise
ENTERPRISE SOLUTIONS
Enterprise platform
AI-powered developer platform
AVAILABLE ADD-ONS
GitHub Advanced Security
Enterprise-grade security features
Copilot for Business
Enterprise-grade AI features
Premium Support
Enterprise-grade 24/7 support
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
Public
Notifications
You must be signed in to change notification settings
Fork
4.7k
Star
8.7k
Code
Issues
3.8k
Pull requests
155
Actions
Projects
Security and quality
0
Insights
Additional navigation options
Code
Issues
Pull requests
Actions
Projects
Security and quality
Insights
[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.
