Skip to content

Pull requests: apache/beam

New pull request New
Clear current search query, filters, and sorts
8 Open 296 Closed
8 Open 296 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

Default offset deduplication for KafkaIO redistribute. io java kafka
#36690 opened Oct 30, 2025 by tomstepp • Draft
Only log Kafka commit failures every 10m and if failing for > 10m. io java kafka Next Action: Reviewers
#36685 opened Oct 30, 2025 by tomstepp Loading…
6
Add Kerberos Authentication Support to KafkaTable extensions io java kafka python sql
#36652 opened Oct 28, 2025 by fozzie15 • Draft
3 tasks
Remove temporary KafkaSourceDescriptor.create function io java kafka Next Action: Reviewers reassigned-reviewers slow-review
#36357 opened Oct 2, 2025 by HurSungYun Loading…
3 tasks done
8
Kerberos auth python io java kafka python
#36211 opened Sep 19, 2025 by fozzie15 Loading…
3 tasks
2
[KafkaIO] Extract expiring memoizing supplier as a separate utility and run end offset refreshes in the current thread io java kafka Next Action: Reviewers reassigned-reviewers slow-review
#36075 opened Sep 6, 2025 by sjvanrossum Loading…
3 tasks
23
Added Filter and Projection Pushdown support to ParquetIO and Beam SQL's ParquetTable aws bigtable build core dataflow direct docker examples extensions flink fn-execution gcp go hadoop hbase hcatalog healthcare infra io java jdbc jet jms kafka learning local model mongodb mqtt Next Action: Reviewers parquet prism protobuf python runners samza sketching spanner spark sql synthetic tests thrift twister2 typescript vendor website yaml
#35589 opened Jul 15, 2025 by talatuyarer Loading…
3 tasks
1
21
Create new SubProject to not depend on Dataflow in Kafka build io java kafka Next Action: Author
#35452 opened Jun 26, 2025 by fozzie15 Loading…
3 tasks
6
ProTip! Find all pull requests that aren't related to any open issues with -linked:issue.