Issues seleccionados

Stream Processing Good First Issues

Explora issues de código abierto agrupados bajo Stream Processing. Si la materia aparece en los metadatos con nombres más antiguos, también se tienen en cuenta.

Stream Processing

Cómo es esta lista

Dificultad anotada media: 4.1/5 en 7,329 issues.
3% de 7,329 estimaciones de tiempo son de un día o menos.

Para principiantes Todo

Abierto Todos

is_live: true is ignored for a :stream input (normalized to a 3-tuple that input_realtime?/1 does not match) Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 86/100

membraneframework/boombox#149 · 1 asignado · Abierto el 18/9/2026
[Serverless security] [kafka_input_otel] Failing test daily: policy test: test-kerberos-auth.yml in kafka_input_otel. Abierto

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

Dificultad 2/5 1-3 horas Aptitud para principiantes 70/100

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

priority: P2

Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100

zai-org/feedback#678 · 1 comentario · Abierto el 16/9/2026
`drop_on_error` default value inconsistency with `drop_on_abort` Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 82/100

vectordotdev/vector#26389 · Abierto el 15/9/2026
Kafka engine: KafkaSource takes IStorage::id_mutex once per row (for `_table`), so consumers of one table contend on it Abierto

comp-message-queues external performance

Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100

ClickHouse/ClickHouse#120032 · Abierto el 14/9/2026
Fjerne nøkkel fra Kafka topic på innkommende flyt (dialog.in) Abierto

helsemelding-inbound-processing-service

Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100

navikt/helsemelding-inbound-processing-service#10 · 3 comentarios · Abierto el 14/9/2026
VizPanelRenderer: useClearPreviousData truncates StreamingDataFrame field values in place (silent data loss for streaming panels) Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 76/100

grafana/scenes#1644 · Abierto el 13/9/2026
pubsub.kafka : mTLS panics without caCert instead of using system CA trust Abierto

kind/bug

Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100

dapr/components-contrib#4583 · Abierto el 13/9/2026
NATS source declares can_acknowledge() = true while its docs declare acknowledgements: no, suppressing the end-to-end acknowledgement warning Abierto

source: nats

Dificultad 2/5 1-3 horas Aptitud para principiantes 85/100

vectordotdev/vector#26345 · 1 reacción · Abierto el 10/9/2026
Flaky parallel e2e: batch_refresh_periodic retry window expires under high barrier latency Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 84/100

risingwavelabs/risingwave#27029 · Abierto el 10/9/2026
[BUG] Kafka sink throws NullPointerException on every shutdown when thread_wait_time is not set Abierto

bug untriaged

Dificultad 2/5 1-3 horas Aptitud para principiantes 88/100

opensearch-project/data-prepper#7130 · Abierto el 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 Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100

grafana/mimir#16546 · 2 comentarios · 2 reacciones · Abierto el 9/9/2026
[BUG] Scoped event subscriptions apply absolute depth instead of depth relative to namespace prefixes Abierto

bug

Dificultad 2/5 1-3 horas Aptitud para principiantes 86/100

aegra/aegra#587 · 1 comentario · Abierto el 8/9/2026
cherry-pick fix(meta): avoid snapshot race during resubscribe (#25728) to branch release-3.0 Abierto

cherry-pick

Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100

risingwavelabs/risingwave#26969 · Abierto el 8/9/2026
`generate_demo_data` crashes with `BufferError: Local: Queue full` Abierto

bug

Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100

PostHog/posthog#96037 · Abierto el 7/9/2026
ChunkMerger.chunkToChatCompletion throws OpenAIInvalidDataException when a streamed chunk omits `id` or `model` (only `created` is guarded) Abierto

status: waiting-for-triage

Dificultad 2/5 1-3 horas Aptitud para principiantes 74/100

spring-projects/spring-ai#6928 · 1 comentario · Abierto el 7/9/2026
Spark: Async micro-batch preload does not stop when either limit is reached Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 90/100

apache/iceberg#17951 · Abierto el 4/9/2026
Mute ydb/tests/stress/kafka_serverless/tests/test_kafka_streams.py.TestYdbTopicWorkload.test in main Abierto

ai_reviewed area/topics

Dificultad 2/5 1-3 horas Aptitud para principiantes 65/100

ydb-platform/ydb#52226 · 3 comentarios · Abierto el 4/9/2026
Community Sample: NEX Agent Co. — first live A2A + x402 dual-protocol on Base Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 65/100

a2aproject/a2a-samples#696 · Abierto el 31/8/2026
StreamProcessor.selectMediaInfo() never settles without a representation controller Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 76/100

Dash-Industry-Forum/dash.js#5124 · Abierto el 30/8/2026
bug(mysql-cdc): TableMapEventMetadataDeserializer EOFException with Percona 8.0.33 and binlog_row_metadata=FUL Abierto

type/bug

Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100

risingwavelabs/risingwave#26837 · 1 comentario · Abierto el 28/8/2026
StreamChannel.tee(): only one branch sees a source error, the rest end cleanly Abierto

external

Dificultad 2/5 1-3 horas Aptitud para principiantes 88/100

langchain-ai/langgraph#8716 · 3 comentarios · Abierto el 25/8/2026
[CH] ReadFromGlutenStorageKafka stores column_names as a dangling const Names& reference Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100

apache/gluten#12843 · Abierto el 20/8/2026
Rust transform SDK discards the input record offset that the ABI provides (Go SDK exposes Record.Offset) Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100

redpanda-data/redpanda#31624 · Abierto el 18/8/2026
TraceDataEncoder fails after a truncated trace record Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 70/100

apache/rocketmq#10837 · 1 comentario · Abierto el 8/8/2026
[Bug] CDC streaming job with offset=latest/earliest fails on SSL-required MySQL because SSL properties are applied after JDBC connection Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 76/100

apache/doris#66558 · 1 comentario · Abierto el 6/8/2026
Bug: DROP CASCADE should drop initial or creating streaming jobs Abierto

type/bug

Dificultad 2/5 1-3 horas Aptitud para principiantes 84/100

risingwavelabs/risingwave#26550 · Abierto el 3/8/2026
ArrangementBackfill degrades to one-row-per-barrier under high upstream rate, causing iceberg-engine tables to miss backfill data Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100

risingwavelabs/risingwave#26421 · Abierto el 23/7/2026
Kafka middleware: document when to use Kafka client directly for advanced scenarios Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 70/100

knative-extensions/func-go#178 · Abierto el 3/7/2026
stream: actor failure notification (recovery trigger) is delayed seconds by backtrace symbolization in exit logging Abierto

A-streaming no-issue-activity type/bug

Dificultad 2/5 1-3 horas Aptitud para principiantes 86/100

risingwavelabs/risingwave#26158 · 1 comentario · Abierto el 3/7/2026
Minor issue with slack_post component in Redpanda Connect. Abierto

needs investigation

Dificultad 2/5 1-3 horas Aptitud para principiantes 65/100

redpanda-data/connect#4511 · 1 comentario · Abierto el 12/6/2026
Channel with server-side failure stays valid indefinitely when using getLatestCommittedOffsetTokens() Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 65/100

snowflakedb/snowflake-ingest-java#1154 · 1 comentario · Abierto el 5/6/2026
[CRITICAL][BUG] flusher_kafka_v2 can hang due to Sarama broker throttle timer race Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 76/100

alibaba/loongcollector#2581 · 2 comentarios · Abierto el 5/6/2026
[Databricks] Add typechecking support for READ_KAFKA Abierto

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

Dificultad 2/5 1-3 horas Aptitud para principiantes 74/100

dbt-labs/dbt#14907 · 1 comentario · Abierto el 26/5/2026
Add Kafka Consumer Group to Kafka Instrumentation Abierto

feature-request

Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100

open-telemetry/opentelemetry-python-contrib#4593 · Abierto el 18/5/2026
pulsar: support debezium protocol Abierto

contribution type/enhancement

Dificultad 2/5 1-3 horas Aptitud para principiantes 75/100

pingcap/ticdc#5056 · 1 comentario · Abierto el 15/5/2026
[bug-hunter] kafka_input_otel auth passwords are rendered unescaped and break YAML parsing Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 85/100

elastic/integrations#18873 · Abierto el 7/5/2026
[bug-hunter] Streaming input drops cursor-only updates when CEL emits zero events Abierto

needs_team

Dificultad 2/5 1-3 horas Aptitud para principiantes 70/100

elastic/beats#50495 · 1 comentario · Abierto el 5/5/2026
decryptStream causes unbounded memory growth Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100

aws/aws-encryption-sdk-javascript#1656 · Abierto el 25/3/2026
Streams processing and YAML config Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100

fluent/fluent-bit#11606 · Abierto el 23/3/2026
[bug-hunter] Kafka output accepts headers for unsupported version 0.9 Abierto

needs_team

Dificultad 2/5 1-3 horas Aptitud para principiantes 74/100

elastic/beats#49538 · 2 comentarios · Abierto el 18/3/2026
8.2.0 kafka-controller fails to start Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 62/100

confluentinc/kafka-images#467 · 1 comentario · 4 reacciones · Abierto el 4/3/2026
refactor: remove unused actor_id label from metric Abierto

no-issue-activity

Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100

risingwavelabs/risingwave#24732 · 1 comentario · Abierto el 6/2/2026
kafka delay metric not reporting when count drops to zero Abierto

type:bug

Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100

apache/hudi#17974 · Abierto el 21/1/2026
RuntimeWarning: non-string key in the __dict__ of class Outputs Abierto

type: bug

Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100

Point72/csp#665 · Abierto el 15/1/2026
For Kafka engine, every INSERT query will logging a WARING . Abierto

comp-message-queues external unexpected behaviour

Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100

ClickHouse/ClickHouse#76852 · 2 comentarios · 4 reacciones · Abierto el 27/2/2025
Comment-out ssl.truststore.location from Kafka connector examples Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 65/100

aws-samples/amazon-managed-service-for-apache-flink-examples#70 · Abierto el 15/10/2024
Kafka output only logs errors in debug level Abierto

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

Dificultad 2/5 1-3 horas Aptitud para principiantes 62/100

elastic/beats#37275 · 5 comentarios · Abierto el 4/12/2023
Include Kafka Message Key in Events Abierto

Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100

ansible/event-driven-ansible#114 · Abierto el 18/4/2023
event counting tutorial no longer needs dummy GROUP BY Abierto

Dificultad 1/5 Menos de una hora Aptitud para principiantes 68/100

confluentinc/kafka-tutorials#1330 · Abierto el 27/7/2022

Stream Processing Good First Issues

Cómo es esta lista

Recibe los nuevos issues en tu correo