Skip to content
CI

feat: Improve kafka backpreassure #1709

Sign in to view logs

feat: Improve kafka backpreassure

feat: Improve kafka backpreassure #1709

Triggered via pull request February 26, 2026 18:39
@CarlosGameroCarlosGamero
synchronize #410
feat/improve_kafka_backpreassure
Status Failure
Total duration 4m 49s
Artifacts –

ci.yml

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

Annotations

13 errors and 2 notices
general (22.x, @message-queue-toolkit/kafka) / build
Process completed with exit code 1.
general (24.x, @message-queue-toolkit/kafka) / build
Process completed with exit code 1.
test/consumer/PermissionConsumer.spec.ts > PermissionConsumer > sync message processing > should process messages synchronously across different topics: packages/kafka/test/consumer/PermissionConsumer.spec.ts#L677
Error: Test timed out in 5000ms. If this is a long-running test, pass a timeout value as the last argument or configure it globally with "testTimeout". ❯ test/consumer/PermissionConsumer.spec.ts:677:5
test/consumer/PermissionConsumer.spec.ts > PermissionConsumer > sync message processing > should process messages synchronously across different topics: packages/kafka/test/consumer/PermissionConsumer.spec.ts#L677
Error: Test timed out in 5000ms. If this is a long-running test, pass a timeout value as the last argument or configure it globally with "testTimeout". ❯ test/consumer/PermissionConsumer.spec.ts:677:5
test/consumer/PermissionConsumer.spec.ts > PermissionConsumer > sync message processing > should ensure previous message completes before next message starts processing: packages/kafka/test/consumer/PermissionConsumer.spec.ts#L615
Error: Test timed out in 5000ms. If this is a long-running test, pass a timeout value as the last argument or configure it globally with "testTimeout". ❯ test/consumer/PermissionConsumer.spec.ts:615:5
test/consumer/PermissionConsumer.spec.ts > PermissionConsumer > sync message processing > should ensure previous message completes before next message starts processing: packages/kafka/test/consumer/PermissionConsumer.spec.ts#L615
Error: Test timed out in 5000ms. If this is a long-running test, pass a timeout value as the last argument or configure it globally with "testTimeout". ❯ test/consumer/PermissionConsumer.spec.ts:615:5
test/consumer/PermissionConsumer.spec.ts > PermissionConsumer > sync message processing > should process messages in order even when published rapidly: packages/kafka/test/consumer/PermissionConsumer.spec.ts#L583
Error: Test timed out in 5000ms. If this is a long-running test, pass a timeout value as the last argument or configure it globally with "testTimeout". ❯ test/consumer/PermissionConsumer.spec.ts:583:5
test/consumer/PermissionConsumer.spec.ts > PermissionConsumer > sync message processing > should process messages in order even when published rapidly: packages/kafka/test/consumer/PermissionConsumer.spec.ts#L583
Error: Test timed out in 5000ms. If this is a long-running test, pass a timeout value as the last argument or configure it globally with "testTimeout". ❯ test/consumer/PermissionConsumer.spec.ts:583:5
test/consumer/PermissionConsumer.spec.ts > PermissionConsumer > sync message processing > should process messages one at a time using handleSyncStream: packages/kafka/test/consumer/PermissionConsumer.spec.ts#L515
Error: Test timed out in 5000ms. If this is a long-running test, pass a timeout value as the last argument or configure it globally with "testTimeout". ❯ test/consumer/PermissionConsumer.spec.ts:515:5
test/consumer/PermissionConsumer.spec.ts > PermissionConsumer > sync message processing > should process messages one at a time using handleSyncStream: packages/kafka/test/consumer/PermissionConsumer.spec.ts#L515
Error: Test timed out in 5000ms. If this is a long-running test, pass a timeout value as the last argument or configure it globally with "testTimeout". ❯ test/consumer/PermissionConsumer.spec.ts:515:5
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.13.1/x64/bin/npm run test:coverage exited (1)
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.0/x64/bin/npm run test:coverage exited (1)
CI
The strategy configuration was canceled because "general._24_x__message-queue-tool" failed
general (24.x, @message-queue-toolkit/kafka) / build
Running @message-queue-toolkit/kafka with QUEUE_BACKEND=fauxqs
general (22.x, @message-queue-toolkit/kafka) / build
Running @message-queue-toolkit/kafka with QUEUE_BACKEND=fauxqs