cookie-cutter icon indicating copy to clipboard operation
cookie-cutter copied to clipboard

Improve Error Messages in Kafka Module

Open sklose opened this issue 5 years ago • 0 comments

Improve error message from Kafka module by adding topic/partition/offset information to errors specific to messages

Example

{"log":{"time":"2019-11-20T14:36:25.908Z","level":"EROR","ctx":"XXX","fields":{"msg":["received invalid message from Kafka"],"type":[null],"err":["cannot find encoder for type name 'undefined' for current version '2.1.1005'"],"stack":["Error: cannot find encoder for type name 'undefined' for current version '2.1.1005'
    at Object.toEncoder (/usr/src/node_modules/@walmartlabs/cookie-cutter-proto/dist/pbjs.js:33:23)
    at ProtoMessageEncoder.decode (/usr/src/node_modules/@walmartlabs/cookie-cutter-proto/dist/ProtoMessageEncoder.js:19:37)
    at new EncodedMessage (/usr/src/node_modules/@walmartlabs/cookie-cutter-core/dist/defaults/EncodedMessage.js:19:38)
    at KafkaSource.start_1 (/usr/src/node_modules/@walmartlabs/cookie-cutter-kafka/dist/KafkaSource.js:123:44)
    at start_1.next (\u003canonymous\u003e)
    at resume (/usr/src/node_modules/@walmartlabs/cookie-cutter-kafka/dist/KafkaSource.js:30:44)
    at fulfill (/usr/src/node_modules/@walmartlabs/cookie-cutter-kafka/dist/KafkaSource.js:32:31)
    at runMicrotasks (\u003canonymous\u003e)
    at processTicksAndRejections (internal/process/task_queues.js:93:5)"]}},"stream":"stdout","time":"2019-11-20T14:36:25.908924633Z"}`````

sklose avatar Jan 20 '20 16:01 sklose