Skip to content

fix: Restart on non-retryable kafka source ack errors #10146

fix: Restart on non-retryable kafka source ack errors

fix: Restart on non-retryable kafka source ack errors #10146

Triggered via pull request February 5, 2026 23:42
Status Failure
Total duration 31m 9s
Artifacts 2

ci.yaml

on: pull_request
Matrix: E2E Tests
Fit to window
Zoom out
Zoom in

Annotations

4 errors and 12 warnings
Unit Tests
Process completed with exit code 101.
Unit Tests
usage of wildcard import for enum variants
Unit Tests
this `if` statement can be collapsed
E2E Tests (jetstream, idle-source-e2e)
Process completed with exit code 2.
Unit Tests
unused import: `super::*`
Unit Tests
unused import: `tokio::sync::oneshot`
Unit Tests
unused import: `tempfile::TempDir`
Unit Tests
unused import: `numaflow::sideinput`
Unit Tests
unused import: `super::*`
Unit Tests
struct `PanicFlatmapStream` is never constructed
Unit Tests
struct `PanicBatchMap` is never constructed
Unit Tests
struct `PanicCat` is never constructed
Unit Tests
struct `SimpleTransformerPanic` is never constructed
Unit Tests
unused import: `crate::message::ReadAck`
Unit Tests
Restore cache failed: Dependencies file is not found in /home/runner/work/numaflow/numaflow. Supported file pattern: go.sum

Artifacts

Produced during runtime
Name Size Digest
entrypoint-linux-amd64 Expired
609 KB
sha256:9e19cea4492b8c0e3c3356cca2d2ab7d06bfdbb3d6e7fd23fb4e445a66416f12
numaflow-rs-linux-amd64 Expired
21.4 MB
sha256:21e577721a9bee1da18b994165c3686c7365d602464695f83258f6059c76dfa4