Issue tuyển chọn

Issue cho người mới về Stream Processing

Duyệt những issue mã nguồn mở được xếp vào Stream Processing. Nếu trong metadata của issue chủ đề này còn mang tên cũ, những tên đó cũng được khớp.

Stream Processing

Danh sách này trông như thế nào

Độ khó đã chú thích trung bình: 4.1/5 trên 7,345 issue.
3% trong số 7,345 ước lượng thời gian là từ một ngày trở xuống.

Phù hợp cho người mới Tất cả

Đang mở Tất cả

[Bug] Streaming read of a postpone primary-key table drops pending rows under bucket-key filter pushdown Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 78/100

apache/paimon#10084 · Mở ngày 22/9/2026
is_live: true is ignored for a :stream input (normalized to a 3-tuple that input_realtime?/1 does not match) Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 86/100

membraneframework/boombox#149 · 1 người được giao · Mở ngày 18/9/2026
[Serverless security] [kafka_input_otel] Failing test daily: policy test: test-kerberos-auth.yml in kafka_input_otel. Đang mở

automation flaky-test Integration:kafka_input_otel Team:obs-ds-intake-services

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 70/100

elastic/integrations#21346 · Mở ngày 17/9/2026
[Bug] openai-compatible 流式解析把 tool_calls:[]（空数组）误判为工具调用阶段，思考过程被逐 token 碎片化（一词一行） Đang mở

priority: P2

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 72/100

zai-org/feedback#678 · 1 bình luận · Mở ngày 16/9/2026
`drop_on_error` default value inconsistency with `drop_on_abort` Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 82/100

vectordotdev/vector#26389 · Mở ngày 15/9/2026
Kafka engine: KafkaSource takes IStorage::id_mutex once per row (for `_table`), so consumers of one table contend on it Đang mở

comp-message-queues external performance

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 78/100

ClickHouse/ClickHouse#120032 · Mở ngày 14/9/2026
VizPanelRenderer: useClearPreviousData truncates StreamingDataFrame field values in place (silent data loss for streaming panels) Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 76/100

grafana/scenes#1644 · Mở ngày 13/9/2026
pubsub.kafka : mTLS panics without caCert instead of using system CA trust Đang mở

kind/bug

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 78/100

dapr/components-contrib#4583 · Mở ngày 13/9/2026
NATS source declares can_acknowledge() = true while its docs declare acknowledgements: no, suppressing the end-to-end acknowledgement warning Đang mở

source: nats

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 85/100

vectordotdev/vector#26345 · 1 reaction · Mở ngày 10/9/2026
Flaky parallel e2e: batch_refresh_periodic retry window expires under high barrier latency Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 84/100

risingwavelabs/risingwave#27029 · Mở ngày 10/9/2026
[BUG] Kafka sink throws NullPointerException on every shutdown when thread_wait_time is not set Đang mở

bug untriaged

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 88/100

opensearch-project/data-prepper#7130 · Mở ngày 10/9/2026
Helm: Kafka data claim is mounted at /var/lib/kafka, but the apache/kafka JVM image declares VOLUME /var/lib/kafka/data, so the log lands on the node disk Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 72/100

grafana/mimir#16546 · 2 bình luận · 2 reaction · Mở ngày 9/9/2026
[BUG] Scoped event subscriptions apply absolute depth instead of depth relative to namespace prefixes Đang mở

bug

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 86/100

aegra/aegra#587 · 1 bình luận · Mở ngày 8/9/2026
cherry-pick fix(meta): avoid snapshot race during resubscribe (#25728) to branch release-3.0 Đang mở

cherry-pick

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 68/100

risingwavelabs/risingwave#26969 · Mở ngày 8/9/2026
`generate_demo_data` crashes with `BufferError: Local: Queue full` Đang mở

bug

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 78/100

PostHog/posthog#96037 · Mở ngày 7/9/2026
ChunkMerger.chunkToChatCompletion throws OpenAIInvalidDataException when a streamed chunk omits `id` or `model` (only `created` is guarded) Đang mở

status: waiting-for-triage

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 74/100

spring-projects/spring-ai#6928 · 1 bình luận · Mở ngày 7/9/2026
Spark: Async micro-batch preload does not stop when either limit is reached Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 90/100

apache/iceberg#17951 · Mở ngày 4/9/2026
Mute ydb/tests/stress/kafka_serverless/tests/test_kafka_streams.py.TestYdbTopicWorkload.test in main Đang mở

ai_reviewed area/topics

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 65/100

ydb-platform/ydb#52226 · 3 bình luận · Mở ngày 4/9/2026
Community Sample: NEX Agent Co. — first live A2A + x402 dual-protocol on Base Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 65/100

a2aproject/a2a-samples#696 · Mở ngày 31/8/2026
StreamProcessor.selectMediaInfo() never settles without a representation controller Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 76/100

Dash-Industry-Forum/dash.js#5124 · Mở ngày 30/8/2026
bug(mysql-cdc): TableMapEventMetadataDeserializer EOFException with Percona 8.0.33 and binlog_row_metadata=FUL Đang mở

type/bug

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 68/100

risingwavelabs/risingwave#26837 · 1 bình luận · Mở ngày 28/8/2026
StreamChannel.tee(): only one branch sees a source error, the rest end cleanly Đang mở

external

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 88/100

langchain-ai/langgraph#8716 · 3 bình luận · Mở ngày 25/8/2026
[CH] ReadFromGlutenStorageKafka stores column_names as a dangling const Names& reference Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 78/100

apache/gluten#12843 · Mở ngày 20/8/2026
Rust transform SDK discards the input record offset that the ABI provides (Go SDK exposes Record.Offset) Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 78/100

redpanda-data/redpanda#31624 · Mở ngày 18/8/2026
TraceDataEncoder fails after a truncated trace record Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 70/100

apache/rocketmq#10837 · 1 bình luận · Mở ngày 8/8/2026
[Bug] CDC streaming job with offset=latest/earliest fails on SSL-required MySQL because SSL properties are applied after JDBC connection Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 76/100

apache/doris#66558 · 1 bình luận · Mở ngày 6/8/2026
Bug: DROP CASCADE should drop initial or creating streaming jobs Đang mở

type/bug

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 84/100

risingwavelabs/risingwave#26550 · Mở ngày 3/8/2026
ArrangementBackfill degrades to one-row-per-barrier under high upstream rate, causing iceberg-engine tables to miss backfill data Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 78/100

risingwavelabs/risingwave#26421 · Mở ngày 23/7/2026
Kafka middleware: document when to use Kafka client directly for advanced scenarios Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 70/100

knative-extensions/func-go#178 · Mở ngày 3/7/2026
stream: actor failure notification (recovery trigger) is delayed seconds by backtrace symbolization in exit logging Đang mở

A-streaming no-issue-activity type/bug

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 86/100

risingwavelabs/risingwave#26158 · 1 bình luận · Mở ngày 3/7/2026
Minor issue with slack_post component in Redpanda Connect. Đang mở

needs investigation

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 65/100

redpanda-data/connect#4511 · 1 bình luận · Mở ngày 12/6/2026
Channel with server-side failure stays valid indefinitely when using getLatestCommittedOffsetTokens() Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 65/100

snowflakedb/snowflake-ingest-java#1154 · 1 bình luận · Mở ngày 5/6/2026
[CRITICAL][BUG] flusher_kafka_v2 can hang due to Sarama broker throttle timer race Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 76/100

alibaba/loongcollector#2581 · 2 bình luận · Mở ngày 5/6/2026
[Databricks] Add typechecking support for READ_KAFKA Đang mở

adapter:databricks area:static-analysis engine:v2 status:triage type:feature

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 74/100

dbt-labs/dbt#14907 · 1 bình luận · Mở ngày 26/5/2026
Add Kafka Consumer Group to Kafka Instrumentation Đang mở

feature-request

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 68/100

open-telemetry/opentelemetry-python-contrib#4593 · Mở ngày 18/5/2026
pulsar: support debezium protocol Đang mở

contribution type/enhancement

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 75/100

pingcap/ticdc#5056 · 1 bình luận · Mở ngày 15/5/2026
[bug-hunter] kafka_input_otel auth passwords are rendered unescaped and break YAML parsing Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 85/100

elastic/integrations#18873 · Mở ngày 7/5/2026
[bug-hunter] Streaming input drops cursor-only updates when CEL emits zero events Đang mở

needs_team

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 70/100

elastic/beats#50495 · 1 bình luận · Mở ngày 5/5/2026
decryptStream causes unbounded memory growth Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 68/100

aws/aws-encryption-sdk-javascript#1656 · Mở ngày 25/3/2026
Streams processing and YAML config Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 68/100

fluent/fluent-bit#11606 · Mở ngày 23/3/2026
[bug-hunter] Kafka output accepts headers for unsupported version 0.9 Đang mở

needs_team

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 74/100

elastic/beats#49538 · 2 bình luận · Mở ngày 18/3/2026
8.2.0 kafka-controller fails to start Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 62/100

confluentinc/kafka-images#467 · 1 bình luận · 4 reaction · Mở ngày 4/3/2026
refactor: remove unused actor_id label from metric Đang mở

no-issue-activity

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 68/100

risingwavelabs/risingwave#24732 · 1 bình luận · Mở ngày 6/2/2026
kafka delay metric not reporting when count drops to zero Đang mở

type:bug

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 68/100

apache/hudi#17974 · Mở ngày 21/1/2026
RuntimeWarning: non-string key in the __dict__ of class Outputs Đang mở

type: bug

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 68/100

Point72/csp#665 · Mở ngày 15/1/2026
For Kafka engine, every INSERT query will logging a WARING . Đang mở

comp-message-queues external unexpected behaviour

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 72/100

ClickHouse/ClickHouse#76852 · 2 bình luận · 4 reaction · Mở ngày 27/2/2025
Comment-out ssl.truststore.location from Kafka connector examples Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 65/100

aws-samples/amazon-managed-service-for-apache-flink-examples#70 · Mở ngày 15/10/2024
Kafka output only logs errors in debug level Đang mở

Team:Elastic-Agent Team:Elastic-Agent-Data-Plane

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 62/100

elastic/beats#37275 · 5 bình luận · Mở ngày 4/12/2023
Include Kafka Message Key in Events Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 68/100

ansible/event-driven-ansible#114 · Mở ngày 18/4/2023
event counting tutorial no longer needs dummy GROUP BY Đang mở

Độ khó 1/5 Dưới một giờ Mức phù hợp với người mới 68/100

confluentinc/kafka-tutorials#1330 · Mở ngày 27/7/2022

Issue cho người mới về Stream Processing

Danh sách này trông như thế nào

Nhận issue mới trong hộp thư của bạn