Issue tuyển chọn

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

Các issue đang mở về Stream Processing từ những dự án GitHub thuộc mọi ngôn ngữ. Danh sách mở ra ở những issue chúng tôi đánh giá là phù hợp với người mới, và các tên gọi khác của chủ đề cũng được khớp.

Stream Processing

Issue đang mở
8.3k
Mới trong tuần
67
Chưa ai nhận
7.6k
Độ khó trung bình
4.1/5

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

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

Cập nhật 9/11/2026.

Giới thiệu về Stream Processing

Xử lý luồng xử lý dữ liệu liên tục khi sự kiện đến, thay vì theo từng lô định kỳ. Công việc ở đây liên quan đến message broker, engine xử lý luồng và các connector giữa chúng.

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

Các issue có thể đã có người làm được xếp cuối danh sách. Sắp xếp tất cả theo ngày

  • [docs] Kafka feed page gives the work-topic partition bound alone
    Đang mở
    • Có gì không ổn?
    crate: spate-kafka documentation priority: medium

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

    spate-etl/spate#1891 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • [bug] DrainBarrier::wait and the spate-test waits panic on Duration::MAX
    Đang mở
    • Có gì không ổn?
    crate: spate-core crate: spate-test priority: low

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

    spate-etl/spate#1844 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • [bug] Kafka feed logs a resend for a write it gives up during backoff
    Đang mở
    • Có gì không ổn?
    crate: spate-kafka priority: low

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

    spate-etl/spate#1841 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • [task] pin that a Kafka lane poll returns once it has a record
    Đang mở
    • Có gì không ổn?
    crate: spate-kafka priority: low

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

    spate-etl/spate#1730 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • Runnable Examples for Aligned and Stream
    Đang mở
    • Có gì không ổn?
    documentation good first issue help wanted

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

    A-RYAN-1/event-order#30 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • Benchmarks for Dedup against a map plus heap baseline
    Đang mở
    • Có gì không ổn?
    good first issue help wanted performance

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

    A-RYAN-1/event-order#28 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • LocalConsumer retains paused partitions after unsubscribe and re-subscribe
    Đang mở
    • Có gì không ổn?
    bug good first issue Waiting for: Product Owner

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

    getsentry/arroyo#585 · 2 bình luận ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • [task] e2e_sink_outage can pass its backpressure check on a pause from before the outage
    Đang mở
    • Có gì không ổn?
    crate: spate priority: low

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

    spate-etl/spate#1267 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • CloudEvent source is invalid for IPv6 (and multi-) broker lists
    Đang mở
    • Có gì không ổn?
    bug

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

    knative-extensions/func-adapter-kafka#7 · 1 bình luận ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • [Bug]: Sub-optimal stream picked from list of variants in a single channel m3u8 file
    Đang mở
    • Có gì không ổn?
    Area: Backend Area: M3U Area: Streams M P3

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

    Dispatcharr/Dispatcharr#1786 · 1 bình luận ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • lifecycle/stream: fetchMessages doesn't check done before calling fetch again
    Đang mở
    • Có gì không ổn?

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

    ConduitIO/conduit#2976 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • disk buffer: reader can be notified before the data file write completes, delaying the sink's send
    Đang mở
    • Có gì không ổn?

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

    vectordotdev/vector#26523 · 8 bình luận · 2 reaction ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • is_live: true is ignored for a :stream input (normalized to a 3-tuple that input_realtime?/1 does not match)
    Có thể làm lại được Đang mở
    • Có gì không ổn?

    Độ 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 ·

  • [Bug] openai-compatible 流式解析把 tool_calls:[]（空数组）误判为工具调用阶段，思考过程被逐 token 碎片化（一词一行）
    Đang mở
    • Có gì không ổn?
    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 ·

  • NATS source declares can_acknowledge() = true while its docs declare acknowledgements: no, suppressing the end-to-end acknowledgement warning
    Đang mở
    • Có gì không ổn?
    source:nats

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

    vectordotdev/vector#26345 · 2 reaction ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • cherry-pick fix(meta): avoid snapshot race during resubscribe (#25728) to branch release-3.0
    Đang mở
    • Có gì không ổn?
    cherry-pick

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

    risingwavelabs/risingwave#26969 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • Spark: Async micro-batch preload does not stop when either limit is reached
    Có thể làm lại được Đang mở
    • Có gì không ổn?

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

    apache/iceberg#17951 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • Community Sample: NEX Agent Co. — first live A2A + x402 dual-protocol on Base
    Đang mở
    • Có gì không ổn?

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

    a2aproject/a2a-samples#696 ·

  • bug(mysql-cdc): TableMapEventMetadataDeserializer EOFException with Percona 8.0.33 and binlog_row_metadata=FUL
    Đang mở
    • Có gì không ổn?
    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 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • Create KafkaConsumerConfig in common-core
    Đang mở
    • Có gì không ổn?
    backend help wanted intermediate java kafka spring-boot

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

    YeamimHossainSajid/CodeMonk#346 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • Create CodeEntitiesExtractedEventProducer
    Đang mở
    • Có gì không ổn?
    backend code-analysis-service help wanted intermediate java spring-boot

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

    YeamimHossainSajid/CodeMonk#174 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • [CH] ReadFromGlutenStorageKafka stores column_names as a dangling const Names& reference
    Đang mở
    • Có gì không ổn?

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

    apache/gluten#12843 ·

    Maintainer thường phản hồi trong vòng 3 ngày

  • Rust transform SDK discards the input record offset that the ABI provides (Go SDK exposes Record.Offset)
    Đang mở
    • Có gì không ổn?

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

    redpanda-data/redpanda#31624 ·

  • onthebench.ai benchmarks Bifrost: a review of our setup for fairness
    Đang mở
    • Có gì không ổn?

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

    maximhq/bifrost#5508 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • ArrangementBackfill degrades to one-row-per-barrier under high upstream rate, causing iceberg-engine tables to miss backfill data
    Có thể làm lại được Đang mở
    • Có gì không ổn?

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

    risingwavelabs/risingwave#26421 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • ReliableMultiSubjectBase<T>.Observer.OnStarted throws NotImplementedException — should be a no-op
    Đang mở
    • Có gì không ổn?

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

    reaqtive/reaqtor#182 ·

  • stream: actor failure notification (recovery trigger) is delayed seconds by backtrace symbolization in exit logging
    Đang mở
    • Có gì không ổn?
    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 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • Channel with server-side failure stays valid indefinitely when using getLatestCommittedOffsetTokens()
    Đang mở
    • Có gì không ổn?

    Độ 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 ·

  • [CRITICAL][BUG] flusher_kafka_v2 can hang due to Sarama broker throttle timer race
    Đang mở
    • Có gì không ổn?

    Độ 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 ·

    Maintainer thường phản hồi trong vòng 4 ngày

  • [Databricks] Add typechecking support for READ_KAFKA
    Đang mở
    • Có gì không ổn?
    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 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • [bug-hunter] kafka_input_otel auth passwords are rendered unescaped and break YAML parsing
    Đang mở
    • Có gì không ổn?

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

    elastic/integrations#18873 ·

    Maintainer thường phản hồi trong vòng 2 ngày

  • [bug-hunter] Streaming input drops cursor-only updates when CEL emits zero events
    Đang mở
    • Có gì không ổn?
    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 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • decryptStream causes unbounded memory growth
    Đang mở
    • Có gì không ổn?

    Độ 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 ·

    Maintainer thường phản hồi trong vòng 7 ngày

  • Streams processing and YAML config
    Đang mở
    • Có gì không ổn?

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

    fluent/fluent-bit#11606 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • [bug-hunter] Kafka output accepts headers for unsupported version 0.9
    Đang mở
    • Có gì không ổn?
    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 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • 8.2.0 kafka-controller fails to start
    Đang mở
    • Có gì không ổn?

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

    confluentinc/kafka-images#467 · 2 bình luận · 4 reaction ·

    Maintainer thường phản hồi trong vòng 15 ngày

  • refactor: remove unused actor_id label from metric
    Đang mở
    • Có gì không ổn?
    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 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • kafka delay metric not reporting when count drops to zero
    Đang mở
    • Có gì không ổn?
    type:bug

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

    apache/hudi#17974 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • RuntimeWarning: non-string key in the __dict__ of class Outputs
    Có thể làm lại được Đang mở
    • Có gì không ổn?
    type: bug

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

    Point72/csp#665 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • For Kafka engine, every INSERT query will logging a WARING .
    Đang mở
    • Có gì không ổn?
    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 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • Comment-out ssl.truststore.location from Kafka connector examples
    Đang mở
    • Có gì không ổn?

    Độ 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 ·

  • Kafka output only logs errors in debug level
    Đang mở
    • Có gì không ổn?
    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 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • Include Kafka Message Key in Events
    Đang mở
    • Có gì không ổn?

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

    ansible/event-driven-ansible#114 ·

  • suggestion - provide the option to store CADU files when use live processing
    Đang mở
    • Có gì không ổn?
    Processing question

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

    SatDump/SatDump#144 · 5 bình luận ·

  • event counting tutorial no longer needs dummy GROUP BY
    Đang mở
    • Có gì không ổn?

    Độ 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 ·

  • Typo: there is a 'sting' where it should be a 'string'
    Đang mở
    • Có gì không ổn?

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

    siddhi-io/siddhi#1692 ·

  • streams: DelimiterStream leaves delimiter bytes in the output when the delimiter spans more than two chunks
    Có thể đã có người làm Đang mở
    • Có gì không ổn?

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

    denoland/std#7386 ·

    Maintainer thường phản hồi trong vòng 1 ngày

  • @shikijs/stream: `ShikiStreamTokenizer.clone()` shares its `tokensStable` array with the original
    Có thể đã có người làm Đang mở
    • Có gì không ổn?

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

    shikijs/shiki#1336 ·

    Maintainer thường phản hồi trong vòng 18 ngày

  • Streaming output rails re-judge the whole response when context_size is 0
    Có thể đã có người làm Đang mở
    • Có gì không ổn?

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

    NVIDIA-NeMo/Guardrails#2427 · 1 bình luận ·

    Maintainer thường phản hồi trong vòng 3 ngày

  • Commits carry one message each once a commit takes longer than allowed_latency
    Có thể đã có người làm Đang mở
    • Có gì không ổn?

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

    delta-io/kafka-delta-ingest#233 ·

Dự án có nhiều issue đang mở nhất ở đây

Trang liên quan

Câu hỏi

Ở đây có bao nhiêu issue Stream Processing đang mở?
8,282 issue đang mở: 67 issue được mở trong bảy ngày qua, và 7,630 issue chưa có ai làm. Chúng tôi đếm mỗi ngày một lần.
Tôi nên bắt đầu từ đâu?
Chọn một issue được đánh dấu là phù hợp với người mới, đọc hướng dẫn đóng góp của dự án và để lại bình luận trước khi bắt đầu. Hướng dẫn cho người đóng góp hướng dẫn từng bước, từ chọn issue đến pull request đầu tiên của bạn.
Bạn có thể chọn giúp tôi một issue không?
Có: đăng nhập bằng GitHub và Issue tiếp theo của bạn sẽ đưa ra một issue đang mở chưa ai nhận, khớp với ngôn ngữ, thời gian và độ khó bạn muốn.

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

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.