cookie-cutter
cookie-cutter copied to clipboard
Improve Error Messages in Kafka Module
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"}`````