Skip to content

Issues: apache/beam

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Clear current search query, filters, and sorts
59 Open 272 Closed
59 Open 272 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
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Issues list

[ManagedIO] Single source of truth for ManagedIO configs io java kafka python website
#34720 opened Apr 24, 2025 by ahmedabu98 Loading…
2
[KafkaIO] Fix concurrent consumer bug in KafkaIOIT io java kafka
#34711 opened Apr 22, 2025 by sjvanrossum Loading…
3 tasks
1
Fail Fast if Resources Do Not Exist in Kafka Cluster. io java kafka Next Action: Reviewers
#34659 opened Apr 17, 2025 by fozzie15 Loading…
3 tasks
3
Fail Fast if Resources Do Not Exist in Kafka Cluster. io java kafka
#34658 opened Apr 17, 2025 by fozzie15 • Draft
3 tasks
1
[WIP] Open Telemetry Tracing for java sdk build dataflow gcp io java kafka runners
#34544 opened Apr 4, 2025 by stankiewicz Loading…
3 tasks
7
[ManagedIO] Fail expansion when encountering extra or unknown configuration io java kafka Next Action: Reviewers python
#34525 opened Apr 2, 2025 by ahmedabu98 Loading…
4
Passing in key metadata when Reading From Kafka build io java kafka
#34426 opened Mar 25, 2025 by svetakvsundhar Loading…
3 tasks
1
11
[KafkaIO] Improve caching in backlog estimation and processing io java kafka Next Action: Reviewers
#34331 opened Mar 18, 2025 by sjvanrossum Loading…
3 tasks
13
[KafkaIO] Update tracker and watermark for non-visible progress io java kafka Next Action: Reviewers
#34202 opened Mar 7, 2025 by sjvanrossum Loading…
3 tasks
12
[KafkaIO] Remove duplicate offset in range check build io java kafka Next Action: Reviewers
#34201 opened Mar 7, 2025 by sjvanrossum Loading…
3 tasks
9
Upgrade Kafka client version to 3.7.0 build io java kafka
#33960 opened Feb 12, 2025 by tomstepp Loading…
5
[Feature Request]: Splittable DoFn Kafka reader in Python io kafka new feature P3 python
#28535 opened Sep 19, 2023 by alexandergirardet
2 of 15 tasks
[Bug]: KafkaIO missing initial messages when using automatic topic creation bug java kafka P2
#27246 opened Jun 26, 2023 by bvolpato
2 of 15 tasks
1
[Bug]: Potential performance regression in KafkaIO and schema registry bug java kafka P2
#26262 opened Apr 13, 2023 by aromanenko-dev
1 of 15 tasks
1
[Bug]: Backlog Does Not Track Consumer Lag for DataFlow Python Kafka Pipeline bug kafka
#25502 opened Feb 16, 2023 by pof-declaneaston
3 of 15 tasks
4
[Bug]: KafkaIO Batch Write Failing due to producer cannot commit messages within timeout bug io java kafka
#24963 opened Jan 10, 2023 by Abacn
2 of 15 tasks
4
[Bug]: Add a Python Kafka read test that uses the with_metadata option bug io kafka P2 python
#23314 opened Sep 21, 2022 by chamikaramj
2
Legacy (SDF wrapper-based) KafkaIO reader degrades when Kafka poll latency is hign improvement io java kafka P2
#21630 opened Jun 5, 2022 by damccorm
1
Support for reading Kafka topics from any startReadTime in Java io java kafka new feature P2
#21610 opened Jun 5, 2022 by damccorm
4
Running Apache Beam pipeline on Azure Databricks bug io java kafka P2 runners spark
#21572 opened Jun 5, 2022 by damccorm
Remove compatibility testing related code from KafkaIO.Read after SDF implementation has fully replaced the legacy read io java kafka P4 task
#21482 opened Jun 4, 2022 by damccorm
Create KafkaIO SchemaTransform io java kafka P2 sub-task
#21414 opened Jun 4, 2022 by damccorm
@pabloem
1
Coder information lost in Kafka Read bug io java kafka P3
#21332 opened Jun 4, 2022 by damccorm
Add "withResults()" for KafkaIO.write ideas io java kafka P2 sub-task
#21330 opened Jun 4, 2022 by damccorm
1
KafkaIO should raise an error if both .withReadCommitted() and .commitOffsetsInFinalize() are used improvement io java kafka P3
#21227 opened Jun 4, 2022 by damccorm
1
ProTip! Type g i on any issue or pull request to go back to the issue listing page.