Skip to content

feat: Reconnect feature on stream error #1746

feat: Reconnect feature on stream error

feat: Reconnect feature on stream error #1746

Triggered via pull request March 19, 2026 11:54
Status Failure
Total duration 4m 21s
Artifacts

ci.yml

on: pull_request
Get changed packages
4s
Get changed packages
Matrix: aws-packages
Waiting for pending jobs
Matrix: general
automerge
0s
automerge
Fit to window
Zoom out
Zoom in

Annotations

8 errors and 2 notices
general (22.x, @message-queue-toolkit/kafka) / build
Process completed with exit code 1.
test/consumer/PermissionConsumer.reconnect.spec.ts > PermissionConsumer - reconnect > should handle errors on reconnection: packages/kafka/test/consumer/PermissionConsumer.reconnect.spec.ts#L74
AssertionError: expected "init" to be called 5 times, but got 6 times ❯ test/consumer/PermissionConsumer.reconnect.spec.ts:74:21
general (22.x, @message-queue-toolkit/kafka) / build
@message-queue-toolkit/kafka#test:coverage: command (/home/runner/work/message-queue-toolkit/message-queue-toolkit/packages/kafka) /opt/hostedtoolcache/node/22.22.1/x64/bin/npm run test:coverage exited (1)
general (24.x, @message-queue-toolkit/kafka) / build
The strategy configuration was canceled because "general._22_x__message-queue-tool" failed
general (24.x, @message-queue-toolkit/kafka) / build
The operation was canceled.
test/consumer/PermissionConsumer.reconnect.spec.ts > PermissionConsumer - reconnect > should handle errors on reconnection: packages/kafka/test/consumer/PermissionConsumer.reconnect.spec.ts#L74
AssertionError: expected "init" to be called 5 times, but got 6 times ❯ test/consumer/PermissionConsumer.reconnect.spec.ts:74:21
general (24.x, @message-queue-toolkit/kafka) / build
@message-queue-toolkit/kafka#test:coverage: command (/home/runner/work/message-queue-toolkit/message-queue-toolkit/packages/kafka) /opt/hostedtoolcache/node/24.14.0/x64/bin/npm run test:coverage exited (1)
CI
The strategy configuration was canceled because "general._22_x__message-queue-tool" failed
general (22.x, @message-queue-toolkit/kafka) / build
Running @message-queue-toolkit/kafka with QUEUE_BACKEND=fauxqs
general (24.x, @message-queue-toolkit/kafka) / build
Running @message-queue-toolkit/kafka with QUEUE_BACKEND=fauxqs