Feat: kafka coonsumer observability #1230
CarlosGameroAnnotations
5 errors
|
linting
Process completed with exit code 2.
|
|
linting
@message-queue-toolkit/kafka#lint: command (/home/runner/work/message-queue-toolkit/message-queue-toolkit/packages/kafka) /opt/hostedtoolcache/node/22.15.0/x64/bin/npm run lint exited (2)
|
|
linting
Type 'ExpectedMessage<{}>' does not satisfy the constraint '{ topic: string; value: {}; key: string; partition: number; timestamp: bigint; headers: { [iterator]: "Expected: function, Actual: function"; forEach: "Expected: function, Actual: function"; ... 9 more ...; size: number; }; offset: bigint; commit: (callback?: ((error?: Error | undefined) => void) | undefined) => voi...'.
|
|
linting
Type 'ExpectedMessage<{ type: "update"; }>' does not satisfy the constraint '{ topic: string; value: { type: "update"; }; key: string; partition: number; timestamp: bigint; headers: { [iterator]: "Expected: function, Actual: function"; forEach: "Expected: function, Actual: function"; ... 9 more ...; size: number; }; offset: bigint; commit: (callback?: ((error?: Error | undefined) => void) | ...'.
|
|
linting
Type 'ExpectedMessage<{ type: "create"; }>' does not satisfy the constraint '{ topic: string; value: { type: "create"; }; key: string; partition: number; timestamp: bigint; headers: { [iterator]: "Expected: function, Actual: function"; forEach: "Expected: function, Actual: function"; ... 9 more ...; size: number; }; offset: bigint; commit: (callback?: ((error?: Error | undefined) => void) | ...'.
|