2025-09-02T15:37:18.041Z - error: uncaughtException: Cannot find module '../../../src/lib/logger' Require stack: - /home/circleci/project/test/unit/kafka/protocol/protocol.test.js - /home/circleci/project/node_modules/tapes/bin/tapes Error: Cannot find module '../../../src/lib/logger' Require stack: - /home/circleci/project/test/unit/kafka/protocol/protocol.test.js - /home/circleci/project/node_modules/tapes/bin/tapes at Function._resolveFilename (node:internal/modules/cjs/loader:1401:15) at defaultResolveImpl (node:internal/modules/cjs/loader:1057:19) at resolveForCJSWithHooks (node:internal/modules/cjs/loader:1062:22) at Function._load (node:internal/modules/cjs/loader:1211:37) at TracingChannel.traceSync (node:diagnostics_channel:322:14) at wrapModuleLoad (node:internal/modules/cjs/loader:235:24) at Module.require (node:internal/modules/cjs/loader:1487:12) at require (node:internal/modules/helpers:135:16) at Object. (/home/circleci/project/test/unit/kafka/protocol/protocol.test.js:3:16) at Module._compile (node:internal/modules/cjs/loader:1730:14) at Module.replacementCompile (/home/circleci/project/node_modules/append-transform/index.js:60:13) at node:internal/modules/cjs/loader:1895:10 at Object. (/home/circleci/project/node_modules/append-transform/index.js:64:4) at Module.load (node:internal/modules/cjs/loader:1465:32) at Function._load (node:internal/modules/cjs/loader:1282:12) at TracingChannel.traceSync (node:diagnostics_channel:322:14) at wrapModuleLoad (node:internal/modules/cjs/loader:235:24) at Module.require (node:internal/modules/cjs/loader:1487:12) at require (node:internal/modules/helpers:135:16) at /home/circleci/project/node_modules/tapes/bin/tapes:9:7 at Array.forEach () at /home/circleci/project/node_modules/tapes/bin/tapes:8:11 at f (/home/circleci/project/node_modules/once/once.js:25:25) at Glob. (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:146:7) at Glob.emit (node:events:518:28) at Glob._finish (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:185:8) at done (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:172:12) at Glob._processGlobStar2 (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:614:12) at /home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:603:10 at RES (/home/circleci/project/node_modules/inflight/inflight.js:31:16) at f (/home/circleci/project/node_modules/once/once.js:25:25) at lstatcb_ (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:504:7) at RES (/home/circleci/project/node_modules/inflight/inflight.js:31:16) at f (/home/circleci/project/node_modules/once/once.js:25:25) at FSReqCallback.oncomplete (node:fs:199:5) - {"date":"Tue Sep 02 2025 15:37:18 GMT+0000 (Coordinated Universal Time)","error":{"code":"MODULE_NOT_FOUND","requireStack":["/home/circleci/project/test/unit/kafka/protocol/protocol.test.js","/home/circleci/project/node_modules/tapes/bin/tapes"]},"exception":true,"os":{"loadavg":[8.92,10.77,14.5],"uptime":26.52},"process":{"argv":["/usr/local/bin/node","/home/circleci/project/node_modules/.bin/tapes","--","test/unit/**/**.test.js"],"cwd":"/home/circleci/project","execPath":"/usr/local/bin/node","gid":0,"memoryUsage":{"arrayBuffers":35407,"external":2540763,"heapTotal":80711680,"heapUsed":53016512,"rss":145620992},"pid":1851,"uid":0,"version":"v22.15.0"},"stack":"Error: Cannot find module '../../../src/lib/logger'\nRequire stack:\n- /home/circleci/project/test/unit/kafka/protocol/protocol.test.js\n- /home/circleci/project/node_modules/tapes/bin/tapes\n at Function._resolveFilename (node:internal/modules/cjs/loader:1401:15)\n at defaultResolveImpl (node:internal/modules/cjs/loader:1057:19)\n at resolveForCJSWithHooks (node:internal/modules/cjs/loader:1062:22)\n at Function._load (node:internal/modules/cjs/loader:1211:37)\n at TracingChannel.traceSync (node:diagnostics_channel:322:14)\n at wrapModuleLoad (node:internal/modules/cjs/loader:235:24)\n at Module.require (node:internal/modules/cjs/loader:1487:12)\n at require (node:internal/modules/helpers:135:16)\n at Object. (/home/circleci/project/test/unit/kafka/protocol/protocol.test.js:3:16)\n at Module._compile (node:internal/modules/cjs/loader:1730:14)\n at Module.replacementCompile (/home/circleci/project/node_modules/append-transform/index.js:60:13)\n at node:internal/modules/cjs/loader:1895:10\n at Object. (/home/circleci/project/node_modules/append-transform/index.js:64:4)\n at Module.load (node:internal/modules/cjs/loader:1465:32)\n at Function._load (node:internal/modules/cjs/loader:1282:12)\n at TracingChannel.traceSync (node:diagnostics_channel:322:14)\n at wrapModuleLoad (node:internal/modules/cjs/loader:235:24)\n at Module.require (node:internal/modules/cjs/loader:1487:12)\n at require (node:internal/modules/helpers:135:16)\n at /home/circleci/project/node_modules/tapes/bin/tapes:9:7\n at Array.forEach ()\n at /home/circleci/project/node_modules/tapes/bin/tapes:8:11\n at f (/home/circleci/project/node_modules/once/once.js:25:25)\n at Glob. (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:146:7)\n at Glob.emit (node:events:518:28)\n at Glob._finish (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:185:8)\n at done (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:172:12)\n at Glob._processGlobStar2 (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:614:12)\n at /home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:603:10\n at RES (/home/circleci/project/node_modules/inflight/inflight.js:31:16)\n at f (/home/circleci/project/node_modules/once/once.js:25:25)\n at lstatcb_ (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:504:7)\n at RES (/home/circleci/project/node_modules/inflight/inflight.js:31:16)\n at f (/home/circleci/project/node_modules/once/once.js:25:25)\n at FSReqCallback.oncomplete (node:fs:199:5)","trace":[{"column":15,"file":"node:internal/modules/cjs/loader","function":"Function._resolveFilename","line":1401,"method":"_resolveFilename","native":false},{"column":19,"file":"node:internal/modules/cjs/loader","function":"defaultResolveImpl","line":1057,"method":null,"native":false},{"column":22,"file":"node:internal/modules/cjs/loader","function":"resolveForCJSWithHooks","line":1062,"method":null,"native":false},{"column":37,"file":"node:internal/modules/cjs/loader","function":"Function._load","line":1211,"method":"_load","native":false},{"column":14,"file":"node:diagnostics_channel","function":"TracingChannel.traceSync","line":322,"method":"traceSync","native":false},{"column":24,"file":"node:internal/modules/cjs/loader","function":"wrapModuleLoad","line":235,"method":null,"native":false},{"column":12,"file":"node:internal/modules/cjs/loader","function":"Module.require","line":1487,"method":"require","native":false},{"column":16,"file":"node:internal/modules/helpers","function":"require","line":135,"method":null,"native":false},{"column":16,"file":"/home/circleci/project/test/unit/kafka/protocol/protocol.test.js","function":null,"line":3,"method":null,"native":false},{"column":14,"file":"node:internal/modules/cjs/loader","function":"Module._compile","line":1730,"method":"_compile","native":false},{"column":13,"file":"/home/circleci/project/node_modules/append-transform/index.js","function":"Module.replacementCompile","line":60,"method":"replacementCompile","native":false},{"column":10,"file":"node:internal/modules/cjs/loader","function":null,"line":1895,"method":null,"native":false},{"column":4,"file":"/home/circleci/project/node_modules/append-transform/index.js","function":null,"line":64,"method":null,"native":false},{"column":32,"file":"node:internal/modules/cjs/loader","function":"Module.load","line":1465,"method":"load","native":false},{"column":12,"file":"node:internal/modules/cjs/loader","function":"Function._load","line":1282,"method":"_load","native":false},{"column":14,"file":"node:diagnostics_channel","function":"TracingChannel.traceSync","line":322,"method":"traceSync","native":false},{"column":24,"file":"node:internal/modules/cjs/loader","function":"wrapModuleLoad","line":235,"method":null,"native":false},{"column":12,"file":"node:internal/modules/cjs/loader","function":"Module.require","line":1487,"method":"require","native":false},{"column":16,"file":"node:internal/modules/helpers","function":"require","line":135,"method":null,"native":false},{"column":7,"file":"/home/circleci/project/node_modules/tapes/bin/tapes","function":null,"line":9,"method":null,"native":false},{"column":null,"file":null,"function":"Array.forEach","line":null,"method":"forEach","native":false},{"column":11,"file":"/home/circleci/project/node_modules/tapes/bin/tapes","function":null,"line":8,"method":null,"native":false},{"column":25,"file":"/home/circleci/project/node_modules/once/once.js","function":"f","line":25,"method":null,"native":false},{"column":7,"file":"/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js","function":null,"line":146,"method":null,"native":false},{"column":28,"file":"node:events","function":"Glob.emit","line":518,"method":"emit","native":false},{"column":8,"file":"/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js","function":"Glob._finish","line":185,"method":"_finish","native":false},{"column":12,"file":"/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js","function":"done","line":172,"method":null,"native":false},{"column":12,"file":"/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js","function":"Glob._processGlobStar2","line":614,"method":"_processGlobStar2","native":false},{"column":10,"file":"/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js","function":null,"line":603,"method":null,"native":false},{"column":16,"file":"/home/circleci/project/node_modules/inflight/inflight.js","function":"RES","line":31,"method":null,"native":false},{"column":25,"file":"/home/circleci/project/node_modules/once/once.js","function":"f","line":25,"method":null,"native":false},{"column":7,"file":"/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js","function":"lstatcb_","line":504,"method":null,"native":false},{"column":16,"file":"/home/circleci/project/node_modules/inflight/inflight.js","function":"RES","line":31,"method":null,"native":false},{"column":25,"file":"/home/circleci/project/node_modules/once/once.js","function":"f","line":25,"method":null,"native":false},{"column":5,"file":"node:fs","function":"FSReqCallback.oncomplete","line":199,"method":"oncomplete","native":false}]} undefined 2025-09-02T15:37:18.044Z - error: uncaughtException: Cannot find module '../../../src/lib/logger' Require stack: - /home/circleci/project/test/unit/kafka/protocol/protocol.test.js - /home/circleci/project/node_modules/tapes/bin/tapes Error: Cannot find module '../../../src/lib/logger' Require stack: - /home/circleci/project/test/unit/kafka/protocol/protocol.test.js - /home/circleci/project/node_modules/tapes/bin/tapes at Function._resolveFilename (node:internal/modules/cjs/loader:1401:15) at defaultResolveImpl (node:internal/modules/cjs/loader:1057:19) at resolveForCJSWithHooks (node:internal/modules/cjs/loader:1062:22) at Function._load (node:internal/modules/cjs/loader:1211:37) at TracingChannel.traceSync (node:diagnostics_channel:322:14) at wrapModuleLoad (node:internal/modules/cjs/loader:235:24) at Module.require (node:internal/modules/cjs/loader:1487:12) at require (node:internal/modules/helpers:135:16) at Object. (/home/circleci/project/test/unit/kafka/protocol/protocol.test.js:3:16) at Module._compile (node:internal/modules/cjs/loader:1730:14) at Module.replacementCompile (/home/circleci/project/node_modules/append-transform/index.js:60:13) at node:internal/modules/cjs/loader:1895:10 at Object. (/home/circleci/project/node_modules/append-transform/index.js:64:4) at Module.load (node:internal/modules/cjs/loader:1465:32) at Function._load (node:internal/modules/cjs/loader:1282:12) at TracingChannel.traceSync (node:diagnostics_channel:322:14) at wrapModuleLoad (node:internal/modules/cjs/loader:235:24) at Module.require (node:internal/modules/cjs/loader:1487:12) at require (node:internal/modules/helpers:135:16) at /home/circleci/project/node_modules/tapes/bin/tapes:9:7 at Array.forEach () at /home/circleci/project/node_modules/tapes/bin/tapes:8:11 at f (/home/circleci/project/node_modules/once/once.js:25:25) at Glob. (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:146:7) at Glob.emit (node:events:518:28) at Glob._finish (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:185:8) at done (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:172:12) at Glob._processGlobStar2 (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:614:12) at /home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:603:10 at RES (/home/circleci/project/node_modules/inflight/inflight.js:31:16) at f (/home/circleci/project/node_modules/once/once.js:25:25) at lstatcb_ (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:504:7) at RES (/home/circleci/project/node_modules/inflight/inflight.js:31:16) at f (/home/circleci/project/node_modules/once/once.js:25:25) at FSReqCallback.oncomplete (node:fs:199:5) - {"date":"Tue Sep 02 2025 15:37:18 GMT+0000 (Coordinated Universal Time)","error":{"code":"MODULE_NOT_FOUND","requireStack":["/home/circleci/project/test/unit/kafka/protocol/protocol.test.js","/home/circleci/project/node_modules/tapes/bin/tapes"]},"exception":true,"os":{"loadavg":[8.92,10.77,14.5],"uptime":26.53},"process":{"argv":["/usr/local/bin/node","/home/circleci/project/node_modules/.bin/tapes","--","test/unit/**/**.test.js"],"cwd":"/home/circleci/project","execPath":"/usr/local/bin/node","gid":0,"memoryUsage":{"arrayBuffers":35431,"external":2416314,"heapTotal":80973824,"heapUsed":53225008,"rss":145620992},"pid":1851,"uid":0,"version":"v22.15.0"},"stack":"Error: Cannot find module '../../../src/lib/logger'\nRequire stack:\n- /home/circleci/project/test/unit/kafka/protocol/protocol.test.js\n- /home/circleci/project/node_modules/tapes/bin/tapes\n at Function._resolveFilename (node:internal/modules/cjs/loader:1401:15)\n at defaultResolveImpl (node:internal/modules/cjs/loader:1057:19)\n at resolveForCJSWithHooks (node:internal/modules/cjs/loader:1062:22)\n at Function._load (node:internal/modules/cjs/loader:1211:37)\n at TracingChannel.traceSync (node:diagnostics_channel:322:14)\n at wrapModuleLoad (node:internal/modules/cjs/loader:235:24)\n at Module.require (node:internal/modules/cjs/loader:1487:12)\n at require (node:internal/modules/helpers:135:16)\n at Object. (/home/circleci/project/test/unit/kafka/protocol/protocol.test.js:3:16)\n at Module._compile (node:internal/modules/cjs/loader:1730:14)\n at Module.replacementCompile (/home/circleci/project/node_modules/append-transform/index.js:60:13)\n at node:internal/modules/cjs/loader:1895:10\n at Object. (/home/circleci/project/node_modules/append-transform/index.js:64:4)\n at Module.load (node:internal/modules/cjs/loader:1465:32)\n at Function._load (node:internal/modules/cjs/loader:1282:12)\n at TracingChannel.traceSync (node:diagnostics_channel:322:14)\n at wrapModuleLoad (node:internal/modules/cjs/loader:235:24)\n at Module.require (node:internal/modules/cjs/loader:1487:12)\n at require (node:internal/modules/helpers:135:16)\n at /home/circleci/project/node_modules/tapes/bin/tapes:9:7\n at Array.forEach ()\n at /home/circleci/project/node_modules/tapes/bin/tapes:8:11\n at f (/home/circleci/project/node_modules/once/once.js:25:25)\n at Glob. (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:146:7)\n at Glob.emit (node:events:518:28)\n at Glob._finish (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:185:8)\n at done (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:172:12)\n at Glob._processGlobStar2 (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:614:12)\n at /home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:603:10\n at RES (/home/circleci/project/node_modules/inflight/inflight.js:31:16)\n at f (/home/circleci/project/node_modules/once/once.js:25:25)\n at lstatcb_ (/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js:504:7)\n at RES (/home/circleci/project/node_modules/inflight/inflight.js:31:16)\n at f (/home/circleci/project/node_modules/once/once.js:25:25)\n at FSReqCallback.oncomplete (node:fs:199:5)","trace":[{"column":15,"file":"node:internal/modules/cjs/loader","function":"Function._resolveFilename","line":1401,"method":"_resolveFilename","native":false},{"column":19,"file":"node:internal/modules/cjs/loader","function":"defaultResolveImpl","line":1057,"method":null,"native":false},{"column":22,"file":"node:internal/modules/cjs/loader","function":"resolveForCJSWithHooks","line":1062,"method":null,"native":false},{"column":37,"file":"node:internal/modules/cjs/loader","function":"Function._load","line":1211,"method":"_load","native":false},{"column":14,"file":"node:diagnostics_channel","function":"TracingChannel.traceSync","line":322,"method":"traceSync","native":false},{"column":24,"file":"node:internal/modules/cjs/loader","function":"wrapModuleLoad","line":235,"method":null,"native":false},{"column":12,"file":"node:internal/modules/cjs/loader","function":"Module.require","line":1487,"method":"require","native":false},{"column":16,"file":"node:internal/modules/helpers","function":"require","line":135,"method":null,"native":false},{"column":16,"file":"/home/circleci/project/test/unit/kafka/protocol/protocol.test.js","function":null,"line":3,"method":null,"native":false},{"column":14,"file":"node:internal/modules/cjs/loader","function":"Module._compile","line":1730,"method":"_compile","native":false},{"column":13,"file":"/home/circleci/project/node_modules/append-transform/index.js","function":"Module.replacementCompile","line":60,"method":"replacementCompile","native":false},{"column":10,"file":"node:internal/modules/cjs/loader","function":null,"line":1895,"method":null,"native":false},{"column":4,"file":"/home/circleci/project/node_modules/append-transform/index.js","function":null,"line":64,"method":null,"native":false},{"column":32,"file":"node:internal/modules/cjs/loader","function":"Module.load","line":1465,"method":"load","native":false},{"column":12,"file":"node:internal/modules/cjs/loader","function":"Function._load","line":1282,"method":"_load","native":false},{"column":14,"file":"node:diagnostics_channel","function":"TracingChannel.traceSync","line":322,"method":"traceSync","native":false},{"column":24,"file":"node:internal/modules/cjs/loader","function":"wrapModuleLoad","line":235,"method":null,"native":false},{"column":12,"file":"node:internal/modules/cjs/loader","function":"Module.require","line":1487,"method":"require","native":false},{"column":16,"file":"node:internal/modules/helpers","function":"require","line":135,"method":null,"native":false},{"column":7,"file":"/home/circleci/project/node_modules/tapes/bin/tapes","function":null,"line":9,"method":null,"native":false},{"column":null,"file":null,"function":"Array.forEach","line":null,"method":"forEach","native":false},{"column":11,"file":"/home/circleci/project/node_modules/tapes/bin/tapes","function":null,"line":8,"method":null,"native":false},{"column":25,"file":"/home/circleci/project/node_modules/once/once.js","function":"f","line":25,"method":null,"native":false},{"column":7,"file":"/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js","function":null,"line":146,"method":null,"native":false},{"column":28,"file":"node:events","function":"Glob.emit","line":518,"method":"emit","native":false},{"column":8,"file":"/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js","function":"Glob._finish","line":185,"method":"_finish","native":false},{"column":12,"file":"/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js","function":"done","line":172,"method":null,"native":false},{"column":12,"file":"/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js","function":"Glob._processGlobStar2","line":614,"method":"_processGlobStar2","native":false},{"column":10,"file":"/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js","function":null,"line":603,"method":null,"native":false},{"column":16,"file":"/home/circleci/project/node_modules/inflight/inflight.js","function":"RES","line":31,"method":null,"native":false},{"column":25,"file":"/home/circleci/project/node_modules/once/once.js","function":"f","line":25,"method":null,"native":false},{"column":7,"file":"/home/circleci/project/node_modules/tapes/node_modules/glob/glob.js","function":"lstatcb_","line":504,"method":null,"native":false},{"column":16,"file":"/home/circleci/project/node_modules/inflight/inflight.js","function":"RES","line":31,"method":null,"native":false},{"column":25,"file":"/home/circleci/project/node_modules/once/once.js","function":"f","line":25,"method":null,"native":false},{"column":5,"file":"node:fs","function":"FSReqCallback.oncomplete","line":199,"method":"oncomplete","native":false}]} undefined TAP version 13 # Index # Exports Kafka ok 1 should be equal # Exports kafka util ok 2 should be equal # Consumer test # Consumer test for KafkaConsumer events # otel Tests --> # Producer test # Producer test for KafkaProducer events # Consumer test Test Consumer::constructor ok 3 Consumer instance created ok 4 Consumer constructor called once # Consumer test Test Consumer::constructor - no config ok 5 Consumer instance created # Consumer test Test Consumer::constructor - defaults ok 6 Consumer instance created ok 7 Consumer constructor called once # Consumer test Test Consumer::constructor - no params ok 8 true # Consumer test Test Consumer::connect ok 9 on Ready event received ok 10 connection result received # Consumer test Test Consumer::connect - with error on callBack 2025-09-02T15:37:18.067Z - error: Consumer::onError()[topics='test'] - error test test) - {"context":"CSS"} 2025-09-02T15:37:18.067Z - error: error test test - {"context":"CSS"} ok 11 on Error event received ok 12 should be truthy # Consumer test Test Consumer::disconnect ok 13 should be equal 2025-09-02T15:37:18.069Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438069} - {"context":"CSS"} 2025-09-02T15:37:18.069Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438069} - {"context":"CSS"} # Consumer test Test Consumer::disconnect - no callback 2025-09-02T15:37:18.070Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438070} - {"context":"CSS"} 2025-09-02T15:37:18.071Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438070} - {"context":"CSS"} # Consumer test Test Consumer::subscribe # Consumer test Test Consumer::subscribe - no params # Consumer test Test Consumer::getWatermarkOffsets ok 14 connection result received ok 15 waterMarkOffset result exists ok 16 waterMarkOffset results match # Consumer test Test Consumer::getMetadata ok 17 connection result received ok 18 metadata object exists ok 19 metadata objects match # Consumer test Test Consumer::getMetadata - no callback function ok 20 connection result received # Consumer test Test Consumer::getMetadataSync ok 21 connection result received ok 22 metadata object exists ok 23 metadata objects match # Consumer test Test Consumer::isConnected ok 24 connection result received ok 25 isConnected result exists # Consumer test Test Consumer::connectedTime ok 26 connection result received ok 27 connectedTime result exists # Consumer test Test Consumer::commit ok 28 connection result received ok 29 commit passed # Consumer test Test Consumer::commit - no params ok 30 connection result received ok 31 commit passed # Consumer test Test Consumer::commitSync ok 32 connection result received ok 33 commit passed # Consumer test Test Consumer::commitSync - no params ok 34 connection result received ok 35 commit passed # Consumer test Test Consumer::commitMessage ok 36 connection result received ok 37 commit passed # Consumer test Test Consumer::commitMessageSync ok 38 connection result received ok 39 commit passed # Consumer test Test Consumer::consumeOnce - Not Implemented - default params ok 40 connection result received 2025-09-02T15:37:18.106Z - error: Error: Not implemented - {"context":"CSS"} ok 41 should be equal # Consumer test Test Consumer::consumeOnce - Not Implemented - batchSize=10 ok 42 connection result received 2025-09-02T15:37:18.108Z - error: Error: Not implemented - {"context":"CSS"} ok 43 should be equal # Consumer test Test Consumer::consume - defaults ok 44 connection result received 2025-09-02T15:37:18.110Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438109} - {"context":"CSS"} 2025-09-02T15:37:18.110Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438109} - {"context":"CSS"} ok 45 on Message event received 2025-09-02T15:37:18.111Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438109} - {"context":"CSS"} 2025-09-02T15:37:18.111Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438109} - {"context":"CSS"} ok 46 on Message event received 2025-09-02T15:37:18.111Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438109} - {"context":"CSS"} 2025-09-02T15:37:18.111Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438109} - {"context":"CSS"} ok 47 on Message event received 2025-09-02T15:37:18.111Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438109} - {"context":"CSS"} 2025-09-02T15:37:18.111Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438109} - {"context":"CSS"} ok 48 on Message event received 2025-09-02T15:37:18.111Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438109} - {"context":"CSS"} 2025-09-02T15:37:18.111Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438109} - {"context":"CSS"} ok 49 on Message event received 2025-09-02T15:37:18.111Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438109} - {"context":"CSS"} 2025-09-02T15:37:18.111Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438109} - {"context":"CSS"} ok 50 on Message event received 2025-09-02T15:37:18.111Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438109} - {"context":"CSS"} 2025-09-02T15:37:18.111Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438109} - {"context":"CSS"} ok 51 on Message event received 2025-09-02T15:37:18.112Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438109} - {"context":"CSS"} 2025-09-02T15:37:18.112Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438109} - {"context":"CSS"} ok 52 on Message event received 2025-09-02T15:37:18.112Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438109} - {"context":"CSS"} 2025-09-02T15:37:18.112Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438109} - {"context":"CSS"} ok 53 on Message event received # Consumer test Test Consumer::consume flow sync=false, messageAsJson=true ok 54 on Ready event received ok 55 connection result received ok 56 on Message event received 2025-09-02T15:37:18.115Z - info: Message Received by callback function - {"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":"key","size":17,"timestamp":1756827438114} - {"context":"CSS"} ok 57 should be equal ok 58 message processed # Consumer test Test Consumer::consume flow sync=false, messageAsJson=false ok 59 on Ready event received ok 60 connection result received ok 61 on Message event received 2025-09-02T15:37:18.117Z - info: Message Received by callback function - {"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":"key","size":17,"timestamp":1756827438117} - {"context":"CSS"} ok 62 should be equal ok 63 message processed # Consumer test Test Consumer::consume flow sync=true, messageAsJson=true ok 64 on Ready event received ok 65 connection result received ok 66 on Message event received 2025-09-02T15:37:18.120Z - info: Message Received by callback function - {"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":"key","size":17,"timestamp":1756827438119} - {"context":"CSS"} ok 67 message processed ok 68 should be equal # Consumer test Test Consumer::consume flow sync=true, messageAsJson=false ok 69 on Ready event received ok 70 connection result received ok 71 on Message event received 2025-09-02T15:37:18.122Z - info: Message Received by callback function - {"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":"key","size":17,"timestamp":1756827438121} - {"context":"CSS"} ok 72 message processed ok 73 should be equal # Consumer test Test Consumer::consume flow sync=true, messageAsJson=false with callback exception ok 74 on Ready event received ok 75 connection result received ok 76 on Message event received ok 77 on Message event received ok 78 on Message event received ok 79 on Message event received 2025-09-02T15:37:18.125Z - info: consume::callback[recursiveCount=1] null, {"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":"key","size":17,"timestamp":1756827438124} - {"context":"CSS"} ok 80 Message processed by the flow consumer 2025-09-02T15:37:18.125Z - info: consume::callback[recursiveCount=2] null, {"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":"key","size":17,"timestamp":1756827438124} - {"context":"CSS"} ok 81 Message processed by the flow to throw exception consumer 2025-09-02T15:37:18.126Z - info: consume::callback[recursiveCount=3] null, {"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":"key","size":17,"timestamp":1756827438124} - {"context":"CSS"} ok 82 Message processed by the flow to throw exception consumer 2025-09-02T15:37:18.126Z - info: consume::callback[recursiveCount=4] null, {"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":"key","size":17,"timestamp":1756827438125} - {"context":"CSS"} ok 83 Message processed by the flow consumer 2025-09-02T15:37:18.126Z - error: Consumer::consume()::syncQueue.queue[0] - workDoneCb - error: Error: this is an error thrown - {"context":"CSS"} 2025-09-02T15:37:18.127Z - error: Consumer::onError()[topics='test'] - Error: this is an error thrown at /home/circleci/project/test/unit/kafka/consumer.test.js:766:17 at new Promise () at /home/circleci/project/test/unit/kafka/consumer.test.js:762:16 at workProcessing (/home/circleci/project/src/kafka/consumer.js:213:645) at executeAndSetSpanStatus (/home/circleci/project/src/kafka/otel.js:3:864) at /home/circleci/project/src/kafka/otel.js:3:614 at NoopContextManager.with (/home/circleci/project/node_modules/@opentelemetry/api/build/src/context/NoopContextManager.js:25:19) at ContextAPI.with (/home/circleci/project/node_modules/@opentelemetry/api/build/src/api/context.js:60:46) at executeInsideSpanContext (/home/circleci/project/src/kafka/otel.js:3:601) at /home/circleci/project/src/kafka/consumer.js:214:872 at /home/circleci/project/node_modules/async/dist/async.js:4017:13 at Object.process (/home/circleci/project/node_modules/async/dist/async.js:1680:21) at /home/circleci/project/node_modules/async/dist/async.js:1532:23 at /home/circleci/project/node_modules/async/dist/async.js:74:45 at node:internal/process/task_queues:151:7 at AsyncResource.runInAsyncScope (node:async_hooks:214:14) at AsyncResource.runMicrotask (node:internal/process/task_queues:148:8) at process.processTicksAndRejections (node:internal/process/task_queues:105:5)) - {"context":"CSS"} ok 84 should be equal ok 85 Error handled by throw 2025-09-02T15:37:18.127Z - error: Error: this is an error thrown - {"context":"CSS"} 2025-09-02T15:37:18.127Z - error: Consumer::consume()::syncQueue.queue[0] - workDoneCb - error: this is an error rejected - {"context":"CSS"} 2025-09-02T15:37:18.127Z - error: Consumer::onError()[topics='test'] - this is an error rejected) - {"context":"CSS"} ok 86 should be equal ok 87 Error handled by rejection ok 88 All errors handled 2025-09-02T15:37:18.128Z - error: this is an error rejected - {"context":"CSS"} # Consumer test Test Consumer::consume flow sync=false, messageAsJson=false with callback exception ok 89 on Ready event received ok 90 connection result received ok 91 on Message event received 2025-09-02T15:37:18.129Z - info: consume::callback[recursiveCount=1] null, {"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":"key","size":17,"timestamp":1756827438129} - {"context":"CSS"} ok 92 Message processed by the flow consumer ok 93 on Message event received 2025-09-02T15:37:18.130Z - info: consume::callback[recursiveCount=2] null, {"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":"key","size":17,"timestamp":1756827438130} - {"context":"CSS"} ok 94 Message processed by the flow to throw exception consumer ok 95 on Message event received 2025-09-02T15:37:18.130Z - info: consume::callback[recursiveCount=3] null, {"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":"key","size":17,"timestamp":1756827438130} - {"context":"CSS"} ok 96 Message processed by the flow to throw exception consumer ok 97 on Message event received 2025-09-02T15:37:18.130Z - info: consume::callback[recursiveCount=4] null, {"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":"key","size":17,"timestamp":1756827438130} - {"context":"CSS"} ok 98 Message processed by the flow consumer 2025-09-02T15:37:18.131Z - error: Consumer::_consumerFlow() - non-sync wokDoneCb response - Error: this is an error thrown - {"context":"CSS"} 2025-09-02T15:37:18.131Z - error: Consumer::onError()[topics='test'] - Error: this is an error thrown at /home/circleci/project/test/unit/kafka/consumer.test.js:869:17 at new Promise () at /home/circleci/project/test/unit/kafka/consumer.test.js:865:16 at /home/circleci/project/src/kafka/consumer.js:273:17 at KafkaConsumer.consume (/home/circleci/project/test/unit/kafka/KafkaStub.js:224:5) at Consumer._consumeFlow (/home/circleci/project/src/kafka/consumer.js:272:152) at Consumer.consume (/home/circleci/project/src/kafka/consumer.js:218:202) at /home/circleci/project/test/unit/kafka/consumer.test.js:864:9 at processTicksAndRejections (node:internal/process/task_queues:105:5) at runNextTicks (node:internal/process/task_queues:69:3) at process.processImmediate (node:internal/timers:453:9)) - {"context":"CSS"} ok 99 should be equal ok 100 Error handled by throw 2025-09-02T15:37:18.131Z - error: Consumer::_consumerFlow() - non-sync wokDoneCb response - this is an error rejected - {"context":"CSS"} 2025-09-02T15:37:18.132Z - error: Consumer::onError()[topics='test'] - this is an error rejected) - {"context":"CSS"} ok 101 should be equal ok 102 Error handled by rejection ok 103 All errors handled # Consumer test Test Consumer::consume poller sync=false, messageAsJson=true ok 104 on Ready event received ok 105 connection result received ok 106 on Message event received ok 107 on Message event received ok 108 on Message event received ok 109 on Message event received ok 110 on Message event received ok 111 on Message event received ok 112 on Message event received ok 113 on Message event received ok 114 on Message event received 2025-09-02T15:37:18.145Z - info: Message Received by callback function - [{"value":{"hello":"world"},"topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438143},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438143},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438143},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438143},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438143},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438143},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438143},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438143},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438143}] - {"context":"CSS"} ok 115 message processed ok 116 batch of messages received ok 117 should be equal ok 118 should be equal ok 119 should be equal ok 120 should be equal ok 121 should be equal ok 122 should be equal ok 123 should be equal ok 124 should be equal ok 125 should be equal ok 126 on Batch event received ok 127 batch of messages received ok 128 on Message event received ok 129 on Message event received ok 130 on Message event received ok 131 on Message event received ok 132 on Message event received ok 133 on Message event received ok 134 on Message event received ok 135 on Message event received ok 136 on Message event received 2025-09-02T15:37:18.154Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438133} - {"context":"CSS"} 2025-09-02T15:37:18.155Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438133} - {"context":"CSS"} ok 137 Message processed once by the poller consumer ok 138 on Batch event received ok 139 batch of messages received # Consumer test Test Consumer::consume poller sync=false, messageAsJson=false ok 140 on Ready event received ok 141 connection result received ok 142 on Message event received ok 143 on Message event received ok 144 on Message event received ok 145 on Message event received ok 146 on Message event received ok 147 on Message event received ok 148 on Message event received ok 149 on Message event received ok 150 on Message event received 2025-09-02T15:37:18.167Z - info: Message Received by callback function - [{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438166},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438166},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438166},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438166},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438166},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438166},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438166},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438166},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438166}] - {"context":"CSS"} ok 151 message processed ok 152 batch of messages received ok 153 should be equal ok 154 should be equal ok 155 should be equal ok 156 should be equal ok 157 should be equal ok 158 should be equal ok 159 should be equal ok 160 should be equal ok 161 should be equal ok 162 on Batch event received ok 163 batch of messages received ok 164 on Message event received ok 165 on Message event received ok 166 on Message event received ok 167 on Message event received ok 168 on Message event received ok 169 on Message event received ok 170 on Message event received ok 171 on Message event received ok 172 on Message event received 2025-09-02T15:37:18.177Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438156} - {"context":"CSS"} 2025-09-02T15:37:18.177Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438156} - {"context":"CSS"} ok 173 Message processed once by the poller consumer ok 174 on Batch event received ok 175 batch of messages received # Consumer test Test Consumer::consume poller sync=true, messageAsJson=true ok 176 on Ready event received ok 177 connection result received ok 178 on Message event received ok 179 on Message event received ok 180 on Message event received ok 181 on Message event received ok 182 on Message event received ok 183 on Message event received ok 184 on Message event received ok 185 on Message event received ok 186 on Message event received 2025-09-02T15:37:18.190Z - info: Message Received by callback function - [{"value":{"hello":"world"},"topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438189},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438189},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438189},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438189},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438189},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438189},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438189},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438189},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438189}] - {"context":"CSS"} ok 187 message processed ok 188 batch of messages received ok 189 should be equal ok 190 should be equal ok 191 should be equal ok 192 should be equal ok 193 should be equal ok 194 should be equal ok 195 should be equal ok 196 should be equal ok 197 should be equal ok 198 on Message event received ok 199 on Message event received ok 200 on Message event received ok 201 on Message event received ok 202 on Message event received ok 203 on Message event received ok 204 on Message event received ok 205 on Message event received ok 206 on Message event received 2025-09-02T15:37:18.220Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438179} - {"context":"CSS"} 2025-09-02T15:37:18.220Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438179} - {"context":"CSS"} ok 207 Message processed once by the poller consumer # Consumer test Test Consumer::consume poller sync=true, messageAsJson=false ok 208 on Ready event received ok 209 connection result received ok 210 on Message event received ok 211 on Message event received ok 212 on Message event received ok 213 on Message event received ok 214 on Message event received ok 215 on Message event received ok 216 on Message event received ok 217 on Message event received ok 218 on Message event received 2025-09-02T15:37:18.233Z - info: Message Received by callback function - [{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438232},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438232},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438232},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438232},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438232},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438232},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438232},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438232},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438232}] - {"context":"CSS"} ok 219 message processed ok 220 batch of messages received ok 221 should be equal ok 222 should be equal ok 223 should be equal ok 224 should be equal ok 225 should be equal ok 226 should be equal ok 227 should be equal ok 228 should be equal ok 229 should be equal ok 230 on Message event received ok 231 on Message event received ok 232 on Message event received ok 233 on Message event received ok 234 on Message event received ok 235 on Message event received ok 236 on Message event received ok 237 on Message event received ok 238 on Message event received 2025-09-02T15:37:18.243Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438222} - {"context":"CSS"} 2025-09-02T15:37:18.243Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438222} - {"context":"CSS"} ok 239 Message processed once by the poller consumer # Consumer test Test Consumer::consume recursive sync=false, messageAsJson=true ok 240 on Ready event received ok 241 connection result received ok 242 on Message event received ok 243 on Message event received ok 244 on Message event received ok 245 on Message event received ok 246 on Message event received ok 247 on Message event received ok 248 on Message event received ok 249 on Message event received ok 250 on Message event received 2025-09-02T15:37:18.246Z - info: Message Received by callback function - [{"value":{"hello":"world"},"topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438245},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438245},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438245},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438245},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438245},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438245},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438245},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438245},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438245}] - {"context":"CSS"} ok 251 message processed ok 252 batch of messages received ok 253 should be equal ok 254 should be equal ok 255 should be equal ok 256 should be equal ok 257 should be equal ok 258 should be equal ok 259 should be equal ok 260 should be equal ok 261 should be equal ok 262 on Batch event received ok 263 batch of messages received ok 264 on Message event received ok 265 on Message event received ok 266 on Message event received ok 267 on Message event received ok 268 on Message event received ok 269 on Message event received ok 270 on Message event received ok 271 on Message event received ok 272 on Message event received 2025-09-02T15:37:18.248Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438245} - {"context":"CSS"} 2025-09-02T15:37:18.248Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438245} - {"context":"CSS"} ok 273 Message processed once by the recursive consumer ok 274 on Batch event received ok 275 batch of messages received # Consumer test Test Consumer::consume recursive sync=false, messageAsJson=false ok 276 on Ready event received ok 277 connection result received ok 278 on Message event received ok 279 on Message event received ok 280 on Message event received ok 281 on Message event received ok 282 on Message event received ok 283 on Message event received ok 284 on Message event received ok 285 on Message event received ok 286 on Message event received 2025-09-02T15:37:18.250Z - info: Message Received by callback function - [{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438249},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438249},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438249},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438249},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438249},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438249},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438249},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438249},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438249}] - {"context":"CSS"} ok 287 message processed ok 288 batch of messages received ok 289 should be equal ok 290 should be equal ok 291 should be equal ok 292 should be equal ok 293 should be equal ok 294 should be equal ok 295 should be equal ok 296 should be equal ok 297 should be equal ok 298 on Batch event received ok 299 batch of messages received ok 300 on Message event received ok 301 on Message event received ok 302 on Message event received ok 303 on Message event received ok 304 on Message event received ok 305 on Message event received ok 306 on Message event received ok 307 on Message event received ok 308 on Message event received 2025-09-02T15:37:18.252Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438249} - {"context":"CSS"} 2025-09-02T15:37:18.252Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438249} - {"context":"CSS"} ok 309 Message processed once by the recursive consumer ok 310 on Batch event received ok 311 batch of messages received # Consumer test Test Consumer::consume recursive sync=true, messageAsJson=true ok 312 on Ready event received ok 313 connection result received ok 314 on Message event received ok 315 on Message event received ok 316 on Message event received ok 317 on Message event received ok 318 on Message event received ok 319 on Message event received ok 320 on Message event received ok 321 on Message event received ok 322 on Message event received ok 323 on Batch event received ok 324 batch of messages received 2025-09-02T15:37:18.255Z - info: Message Received by callback function - [{"value":{"hello":"world"},"topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438254},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438254},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438254},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438254},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438254},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438254},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438254},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438254},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438254}] - {"context":"CSS"} ok 325 message processed ok 326 batch of messages received ok 327 should be equal ok 328 should be equal ok 329 should be equal ok 330 should be equal ok 331 should be equal ok 332 should be equal ok 333 should be equal ok 334 should be equal ok 335 should be equal ok 336 on Message event received ok 337 on Message event received ok 338 on Message event received ok 339 on Message event received ok 340 on Message event received ok 341 on Message event received ok 342 on Message event received ok 343 on Message event received ok 344 on Message event received ok 345 on Batch event received ok 346 batch of messages received 2025-09-02T15:37:18.293Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438253} - {"context":"CSS"} 2025-09-02T15:37:18.293Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438253} - {"context":"CSS"} ok 347 Message processed once by the recursive consumer # Consumer test Test Consumer::consume recursive sync=true, messageAsJson=true, syncSingleMessage=true ok 348 on Ready event received ok 349 connection result received ok 350 on Message event received ok 351 on Message event received ok 352 on Message event received ok 353 on Message event received ok 354 on Message event received ok 355 on Message event received ok 356 on Message event received ok 357 on Message event received ok 358 on Message event received ok 359 on Batch event received ok 360 batch of messages received 2025-09-02T15:37:18.296Z - info: Message Received by callback function - {"value":{"hello":"world"},"topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438295} - {"context":"CSS"} ok 361 message processed ok 362 single message received 2025-09-02T15:37:18.296Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438294} - {"context":"CSS"} 2025-09-02T15:37:18.296Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438294} - {"context":"CSS"} ok 363 Message processed once by the recursive consumer # Consumer test Test Consumer::consume recursive sync=true, messageAsJson=false ok 364 on Ready event received ok 365 connection result received ok 366 on Message event received ok 367 on Message event received ok 368 on Message event received ok 369 on Message event received ok 370 on Message event received ok 371 on Message event received ok 372 on Message event received ok 373 on Message event received ok 374 on Message event received ok 375 on Batch event received ok 376 batch of messages received 2025-09-02T15:37:18.299Z - info: Message Received by callback function - [{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438298},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438298},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438298},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438298},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438298},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438298},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438298},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438298},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438298}] - {"context":"CSS"} ok 377 message processed ok 378 batch of messages received ok 379 should be equal ok 380 should be equal ok 381 should be equal ok 382 should be equal ok 383 should be equal ok 384 should be equal ok 385 should be equal ok 386 should be equal ok 387 should be equal ok 388 on Message event received ok 389 on Message event received ok 390 on Message event received ok 391 on Message event received ok 392 on Message event received ok 393 on Message event received ok 394 on Message event received ok 395 on Message event received ok 396 on Message event received ok 397 on Batch event received ok 398 batch of messages received 2025-09-02T15:37:18.301Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438298} - {"context":"CSS"} 2025-09-02T15:37:18.301Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438298} - {"context":"CSS"} ok 399 Message processed once by the recursive consumer # Consumer test Test Consumer::consume recursive sync=true, messageAsJson=false with callback exception ok 400 on Ready event received ok 401 connection result received ok 402 on Message event received ok 403 on Message event received ok 404 on Message event received ok 405 on Message event received ok 406 on Message event received ok 407 on Message event received ok 408 on Message event received ok 409 on Message event received ok 410 on Message event received ok 411 on Batch event received ok 412 batch of messages received 2025-09-02T15:37:18.306Z - info: consume::callback[recursiveCount=1] null, [{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438305},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438305},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438305},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438305},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438305},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438305},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438305},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438305},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438305}] - {"context":"CSS"} ok 413 on Message event received ok 414 on Message event received ok 415 on Message event received ok 416 on Message event received ok 417 on Message event received ok 418 on Message event received ok 419 on Message event received ok 420 on Message event received ok 421 on Message event received ok 422 on Batch event received ok 423 batch of messages received 2025-09-02T15:37:18.307Z - info: consume::callback[recursiveCount=2] null, [{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438306},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438306},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438306},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438306},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438306},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438306},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438306},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438306},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438306}] - {"context":"CSS"} 2025-09-02T15:37:18.381Z - error: Consumer::consume()::syncQueue.queue[0] - workDoneCb - error: Error: this is an error thrown - {"context":"CSS"} 2025-09-02T15:37:18.381Z - error: Consumer::onError()[topics='test'] - Error: this is an error thrown at /home/circleci/project/test/unit/kafka/consumer.test.js:1721:19 at new Promise () at /home/circleci/project/test/unit/kafka/consumer.test.js:1709:16 at workProcessing (/home/circleci/project/src/kafka/consumer.js:213:645) at /home/circleci/project/src/kafka/consumer.js:214:683 at /home/circleci/project/node_modules/async/dist/async.js:4017:13 at Object.process (/home/circleci/project/node_modules/async/dist/async.js:1680:21) at /home/circleci/project/node_modules/async/dist/async.js:1572:19 at /home/circleci/project/node_modules/async/dist/async.js:328:20 at /home/circleci/project/src/kafka/consumer.js:213:742 at process.processTicksAndRejections (node:internal/process/task_queues:105:5)) - {"context":"CSS"} ok 424 should be equal ok 425 Error handled by throw 2025-09-02T15:37:18.381Z - error: Consumer::_consumerRecursive()::syncQueue.Batch.push - error: Error: this is an error thrown - {"context":"CSS"} 2025-09-02T15:37:18.381Z - error: Consumer::consume() - onRecursive - error Error: this is an error thrown - {"context":"CSS"} ok 426 on Message event received ok 427 on Message event received ok 428 on Message event received ok 429 on Message event received ok 430 on Message event received ok 431 on Message event received ok 432 on Message event received ok 433 on Message event received ok 434 on Message event received ok 435 on Batch event received ok 436 batch of messages received 2025-09-02T15:37:18.382Z - info: consume::callback[recursiveCount=3] null, [{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438381},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438381},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438381},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438381},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438381},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438381},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438381},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438381},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438381}] - {"context":"CSS"} 2025-09-02T15:37:18.382Z - error: Consumer::consume()::syncQueue.queue[0] - workDoneCb - error: this is an error rejected - {"context":"CSS"} 2025-09-02T15:37:18.383Z - error: Consumer::onError()[topics='test'] - this is an error rejected) - {"context":"CSS"} ok 437 should be equal ok 438 Error handled by rejection 2025-09-02T15:37:18.383Z - error: Consumer::_consumerRecursive()::syncQueue.Batch.push - error: this is an error rejected - {"context":"CSS"} 2025-09-02T15:37:18.383Z - error: Consumer::consume() - onRecursive - error this is an error rejected - {"context":"CSS"} ok 439 on Message event received ok 440 on Message event received ok 441 on Message event received ok 442 on Message event received ok 443 on Message event received ok 444 on Message event received ok 445 on Message event received ok 446 on Message event received ok 447 on Message event received ok 448 on Batch event received ok 449 batch of messages received 2025-09-02T15:37:18.385Z - info: consume::callback[recursiveCount=4] null, [{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438383},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438383},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438383},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438383},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438383},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438383},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438383},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438383},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438383}] - {"context":"CSS"} 2025-09-02T15:37:18.385Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438305} - {"context":"CSS"} 2025-09-02T15:37:18.385Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438305} - {"context":"CSS"} ok 450 Message processed by the recursive consumer ok 451 All errors handled # Consumer test Test Consumer::consume recursive sync=false, messageAsJson=false with callback exception ok 452 on Ready event received ok 453 connection result received ok 454 on Message event received ok 455 on Message event received ok 456 on Message event received ok 457 on Message event received ok 458 on Message event received ok 459 on Message event received ok 460 on Message event received ok 461 on Message event received ok 462 on Message event received 2025-09-02T15:37:18.389Z - info: consume::callback[recursiveCount=1] null, [{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438388},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438388},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438388},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438388},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438388},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438388},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438388},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438388},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438388}] - {"context":"CSS"} ok 463 Message processed by the recursive consumer ok 464 on Batch event received ok 465 batch of messages received ok 466 on Message event received ok 467 on Message event received ok 468 on Message event received ok 469 on Message event received ok 470 on Message event received ok 471 on Message event received ok 472 on Message event received ok 473 on Message event received ok 474 on Message event received 2025-09-02T15:37:18.390Z - info: consume::callback[recursiveCount=2] null, [{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438389},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438389},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438389},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438389},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438389},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438389},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438389},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438389},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438389}] - {"context":"CSS"} ok 475 on Batch event received ok 476 batch of messages received 2025-09-02T15:37:18.517Z - error: Consumer::_consumerRecursive() - non-sync wokDoneCb response - Error: this is an error thrown - {"context":"CSS"} ok 477 on Message event received ok 478 on Message event received ok 479 on Message event received ok 480 on Message event received ok 481 on Message event received ok 482 on Message event received ok 483 on Message event received ok 484 on Message event received ok 485 on Message event received 2025-09-02T15:37:18.517Z - info: consume::callback[recursiveCount=3] null, [{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438517},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438517},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438517},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438517},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438517},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438517},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438517},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438517},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438517}] - {"context":"CSS"} ok 486 on Batch event received ok 487 batch of messages received 2025-09-02T15:37:18.518Z - error: Consumer::onError()[topics='test'] - Error: this is an error thrown at /home/circleci/project/test/unit/kafka/consumer.test.js:1812:19 at new Promise () at /home/circleci/project/test/unit/kafka/consumer.test.js:1799:16 at /home/circleci/project/src/kafka/consumer.js:261:17 at KafkaConsumer.consume (/home/circleci/project/test/unit/kafka/KafkaStub.js:218:7) at Consumer._consumeRecursive (/home/circleci/project/src/kafka/consumer.js:256:218) at Consumer. (/home/circleci/project/src/kafka/consumer.js:217:841) at Consumer.emit (node:events:518:28) at /home/circleci/project/src/kafka/consumer.js:261:235 at process.processTicksAndRejections (node:internal/process/task_queues:105:5)) - {"context":"CSS"} ok 488 should be equal ok 489 Error handled by throw 2025-09-02T15:37:18.518Z - error: Consumer::_consumerRecursive() - non-sync wokDoneCb response - this is an error rejected - {"context":"CSS"} ok 490 on Message event received ok 491 on Message event received ok 492 on Message event received ok 493 on Message event received ok 494 on Message event received ok 495 on Message event received ok 496 on Message event received ok 497 on Message event received ok 498 on Message event received 2025-09-02T15:37:18.519Z - info: consume::callback[recursiveCount=4] null, [{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438518},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438518},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438518},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438518},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438518},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438518},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438518},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438518},{"value":"{\"hello\":\"world\"}","topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438518}] - {"context":"CSS"} ok 499 Message processed by the recursive consumer 2025-09-02T15:37:18.519Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438387} - {"context":"CSS"} 2025-09-02T15:37:18.519Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438387} - {"context":"CSS"} ok 500 on Batch event received ok 501 batch of messages received 2025-09-02T15:37:18.519Z - error: Consumer::onError()[topics='test'] - this is an error rejected) - {"context":"CSS"} ok 502 should be equal ok 503 Error handled by rejection ok 504 All errors handled # Consumer test Test Consumer::consume poller sync=false, messageAsJson=true, batchSize=0 ok 505 connection result received 2025-09-02T15:37:18.521Z - error: Error: batchSize option is not valid - Select an integer greater then 0 - {"context":"CSS"} 2025-09-02T15:37:18.521Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438521} - {"context":"CSS"} 2025-09-02T15:37:18.521Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438521} - {"context":"CSS"} ok 506 should be equal # Consumer test Test Consumer::consume poller sync=false, messageAsJson=true, batchSize=0 with Callback exception ok 507 connection result received 2025-09-02T15:37:18.533Z - info: consume::callback[recursiveCount=1] null, [{"value":{"hello":"world"},"topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438532},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438532},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438532},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438532},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438532},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438532},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438532},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438532},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438532}] - {"context":"CSS"} ok 508 Message processed by the recursive consumer 2025-09-02T15:37:18.542Z - info: consume::callback[recursiveCount=2] null, [{"value":{"hello":"world"},"topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438542},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438542},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438542},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438542},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438542},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438542},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438542},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438542},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438542}] - {"context":"CSS"} 2025-09-02T15:37:18.543Z - error: Consumer::_consumePoller() - non-sync wokDoneCb response - Error: this is an error thrown - {"context":"CSS"} 2025-09-02T15:37:18.543Z - error: Consumer::onError()[topics='test'] - Error: this is an error thrown at /home/circleci/project/test/unit/kafka/consumer.test.js:1922:19 at new Promise () at /home/circleci/project/test/unit/kafka/consumer.test.js:1909:16 at /home/circleci/project/src/kafka/consumer.js:235:17 at KafkaConsumer.consume (/home/circleci/project/test/unit/kafka/KafkaStub.js:218:7) at Timeout._onTimeout (/home/circleci/project/src/kafka/consumer.js:233:16) at listOnTimeout (node:internal/timers:588:17) at process.processTimers (node:internal/timers:523:7)) - {"context":"CSS"} ok 509 should be equal ok 510 Error handled by throw 2025-09-02T15:37:18.553Z - info: consume::callback[recursiveCount=3] null, [{"value":{"hello":"world"},"topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438552},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438552},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438552},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438552},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438552},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438552},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438552},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438552},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438552}] - {"context":"CSS"} 2025-09-02T15:37:18.596Z - error: Consumer::_consumePoller() - non-sync wokDoneCb response - this is an error rejected - {"context":"CSS"} 2025-09-02T15:37:18.596Z - error: Consumer::onError()[topics='test'] - this is an error rejected) - {"context":"CSS"} ok 511 should be equal ok 512 Error handled by rejection 2025-09-02T15:37:18.597Z - info: consume::callback[recursiveCount=4] null, [{"value":{"hello":"world"},"topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438596},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438596},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438596},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438596},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438596},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438596},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438596},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438596},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438596}] - {"context":"CSS"} ok 513 Message processed by the recursive consumer 2025-09-02T15:37:18.597Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438522} - {"context":"CSS"} 2025-09-02T15:37:18.597Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438522} - {"context":"CSS"} ok 514 All errors handled # Consumer test Test Consumer::consume poller sync=true, messageAsJson=true, batchSize=0 with Callback exception ok 515 connection result received 2025-09-02T15:37:18.609Z - info: consume::callback[recursiveCount=1] null, [{"value":{"hello":"world"},"topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438608},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438608},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438608},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438608},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438608},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438608},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438608},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438608},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438608}] - {"context":"CSS"} ok 516 Message processed by the recursive consumer 2025-09-02T15:37:18.619Z - info: consume::callback[recursiveCount=2] null, [{"value":{"hello":"world"},"topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438618},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438618},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438618},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438618},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438618},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438618},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438618},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438618},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438618}] - {"context":"CSS"} 2025-09-02T15:37:18.619Z - error: Consumer::consume()::syncQueue.queue[0] - workDoneCb - error: Error: this is an error thrown - {"context":"CSS"} 2025-09-02T15:37:18.619Z - error: Consumer::onError()[topics='test'] - Error: this is an error thrown at /home/circleci/project/test/unit/kafka/consumer.test.js:1997:19 at new Promise () at /home/circleci/project/test/unit/kafka/consumer.test.js:1984:16 at workProcessing (/home/circleci/project/src/kafka/consumer.js:213:645) at /home/circleci/project/src/kafka/consumer.js:214:683 at /home/circleci/project/node_modules/async/dist/async.js:4017:13 at Object.process (/home/circleci/project/node_modules/async/dist/async.js:1680:21) at /home/circleci/project/node_modules/async/dist/async.js:1532:23 at /home/circleci/project/node_modules/async/dist/async.js:74:45 at node:internal/process/task_queues:151:7 at AsyncResource.runInAsyncScope (node:async_hooks:214:14) at AsyncResource.runMicrotask (node:internal/process/task_queues:148:8) at process.processTicksAndRejections (node:internal/process/task_queues:105:5)) - {"context":"CSS"} ok 517 should be equal ok 518 Error handled by throw 2025-09-02T15:37:18.619Z - error: Consumer::_consumePoller()::syncQueue.push - error: null - {"context":"CSS"} 2025-09-02T15:37:18.629Z - info: consume::callback[recursiveCount=3] null, [{"value":{"hello":"world"},"topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438628},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438628},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438628},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438628},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438628},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438628},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438628},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438628},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438628}] - {"context":"CSS"} 2025-09-02T15:37:18.629Z - error: Consumer::consume()::syncQueue.queue[0] - workDoneCb - error: this is an error rejected - {"context":"CSS"} 2025-09-02T15:37:18.629Z - error: Consumer::onError()[topics='test'] - this is an error rejected) - {"context":"CSS"} ok 519 should be equal ok 520 Error handled by rejection 2025-09-02T15:37:18.629Z - error: Consumer::_consumePoller()::syncQueue.push - error: null - {"context":"CSS"} 2025-09-02T15:37:18.639Z - info: consume::callback[recursiveCount=4] null, [{"value":{"hello":"world"},"topic":"test","partition":0,"offset":0,"key":0,"size":17,"timestamp":1756827438638},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":1,"size":17,"timestamp":1756827438638},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":2,"key":2,"size":17,"timestamp":1756827438638},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":3,"key":3,"size":17,"timestamp":1756827438638},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":4,"key":4,"size":17,"timestamp":1756827438638},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":5,"key":5,"size":17,"timestamp":1756827438638},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":6,"key":6,"size":17,"timestamp":1756827438638},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":7,"key":7,"size":17,"timestamp":1756827438638},{"value":{"hello":"world"},"topic":"test","partition":0,"offset":9,"key":9,"size":17,"timestamp":1756827438638}] - {"context":"CSS"} ok 521 Message processed by the recursive consumer 2025-09-02T15:37:18.639Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438598} - {"context":"CSS"} 2025-09-02T15:37:18.639Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438598} - {"context":"CSS"} ok 522 All errors handled # Consumer test Test Consumer::consume recursive sync=false, messageAsJson=true, batchSize=0 ok 523 connection result received 2025-09-02T15:37:18.640Z - error: Error: batchSize option is not valid - Select an integer greater then 0 - {"context":"CSS"} 2025-09-02T15:37:18.640Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438640} - {"context":"CSS"} 2025-09-02T15:37:18.683Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438640} - {"context":"CSS"} ok 524 should be equal # Consumer test Test Consumer::consume flow sync=false, messageAsJson=true - invalid CONSUMER MODE SELECTED ok 525 on Ready event received ok 526 connection result received ok 527 on Message event received 2025-09-02T15:37:18.685Z - info: Message Received by callback function - {"value":{"hello":"world"},"topic":"test","partition":0,"offset":1,"key":"key","size":17,"timestamp":1756827438685} - {"context":"CSS"} ok 528 should be equal ok 529 message processed # Consumer test for KafkaConsumer events Test Consumer::connect - test KafkaConsumer events: event.log, event.error, error ok 530 on Ready event received 2025-09-02T15:37:18.687Z - warn: Consumer::onWarning - "warning" - {"context":"CSS"} 2025-09-02T15:37:18.687Z - error: Consumer::onEventError - "event.error" - {"context":"CSS"} 2025-09-02T15:37:18.687Z - error: Consumer::onError()[topics='test'] - event.error) - {"context":"CSS"} 2025-09-02T15:37:18.688Z - error: event.error - {"context":"CSS"} ok 531 on Error event received 2025-09-02T15:37:18.688Z - error: Consumer::onError - "error" - {"context":"CSS"} 2025-09-02T15:37:18.688Z - error: Consumer::onError()[topics='test'] - error) - {"context":"CSS"} 2025-09-02T15:37:18.688Z - error: error - {"context":"CSS"} ok 532 on Error event received 2025-09-02T15:37:18.688Z - warn: Consumer::onEventThrottle - "event.throttle" - {"context":"CSS"} ok 533 event.throttle ok 534 partition.eof ok 535 connection result received 2025-09-02T15:37:18.689Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438687} - {"context":"CSS"} 2025-09-02T15:37:18.689Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438687} - {"context":"CSS"} ok 536 disconnected # Consumer test for KafkaConsumer events Test Consumer::connect - test KafkaConsumer events: event.log, event.error, error, stats enabled ok 537 on Ready event received 2025-09-02T15:37:18.691Z - warn: Consumer::onWarning - "warning" - {"context":"CSS"} 2025-09-02T15:37:18.691Z - error: Consumer::onEventError - "event.error" - {"context":"CSS"} 2025-09-02T15:37:18.691Z - error: Consumer::onError()[topics='test'] - event.error) - {"context":"CSS"} 2025-09-02T15:37:18.691Z - error: event.error - {"context":"CSS"} ok 538 on Error event received 2025-09-02T15:37:18.691Z - error: Consumer::onError - "error" - {"context":"CSS"} 2025-09-02T15:37:18.691Z - error: Consumer::onError()[topics='test'] - error) - {"context":"CSS"} 2025-09-02T15:37:18.691Z - error: error - {"context":"CSS"} ok 539 on Error event received 2025-09-02T15:37:18.691Z - warn: Consumer::onEventThrottle - "event.throttle" - {"context":"CSS"} ok 540 event.throttle 2025-09-02T15:37:18.692Z - error: Consumer::onEventStats - error parsing stats: SyntaxError: Unexpected token 'e', "event.stats" is not valid JSON - {"context":"CSS"} ok 541 event.stats ok 542 partition.eof ok 543 connection result received 2025-09-02T15:37:18.693Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438691} - {"context":"CSS"} 2025-09-02T15:37:18.693Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438691} - {"context":"CSS"} ok 544 disconnected # otel Tests --> should return empty object if kafkaHeaders is not array with elements ok 545 should be equivalent # otel Tests --> should extract OTel headers from array with one-with-all headers element ok 546 traceparent header is extracted ok 547 tracestate header is extracted ok 548 baggage header is extracted ok 549 content-type header is NOT extracted # otel Tests --> should extract OTel headers from array with several headers elements ok 550 traceparent header is extracted ok 551 tracestate header is extracted ok 552 baggage header is extracted ok 553 content-type header is NOT extracted # otel Tests --> executeAndSetSpanStatus Tests --> # Producer test Test Producer::constructor ok 554 Producer instance created ok 555 Producer constructor called once # Producer test Test Producer::constructor - defaults ok 556 Producer instance created ok 557 Producer constructor called once # Producer test Test Producer::constructor null ok 558 Producer instance created # Producer test Test Producer::constructor null ok 559 Producer instance created # Producer test Test Producer::connect - with error on callBack 2025-09-02T15:37:18.704Z - error: Producer::onError()[topics='undefined'] - error test test) - {"context":"CSS"} 2025-09-02T15:37:18.704Z - error: error test test - {"context":"CSS"} ok 560 on Error event received ok 561 should be truthy # Producer test Test Producer::connect 2025-09-02T15:37:18.706Z - info: onReady: {"librdkafkaVersion":"2.8.0","features":["gzip","snappy","ssl","sasl","regex","lz4","sasl_gssapi","sasl_plain","sasl_scram","plugins","zstd","sasl_oauthbearer"]} - {"context":"CSS"} ok 562 on Ready event received ok 563 connection result received 2025-09-02T15:37:18.706Z - warn: Producer::onDisconnected - {"connectionOpened":1756827438706} - {"context":"CSS"} 2025-09-02T15:37:18.706Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827438706} - {"context":"CSS"} # Producer test Test Producer::disconnect ok 564 should be equal 2025-09-02T15:37:18.708Z - warn: Producer::onDisconnected - {"connectionOpened":1756827438707} - {"context":"CSS"} 2025-09-02T15:37:18.708Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827438707} - {"context":"CSS"} # Producer test Test Producer::disconnect ok 565 should be truthy # Producer test Test Producer::sendMessage 2025-09-02T15:37:18.710Z - info: onReady: {"librdkafkaVersion":"2.8.0","features":["gzip","snappy","ssl","sasl","regex","lz4","sasl_gssapi","sasl_plain","sasl_scram","plugins","zstd","sasl_oauthbearer"]} - {"context":"CSS"} ok 566 on Ready event received ok 567 connection result received ok 568 should be equal 2025-09-02T15:37:18.711Z - warn: Producer::onDisconnected - {"connectionOpened":1756827438710} - {"context":"CSS"} 2025-09-02T15:37:18.711Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827438710} - {"context":"CSS"} # Producer test Test Producer::sendMessage with maxLag 2025-09-02T15:37:18.713Z - info: onReady: {"librdkafkaVersion":"2.8.0","features":["gzip","snappy","ssl","sasl","regex","lz4","sasl_gssapi","sasl_plain","sasl_scram","plugins","zstd","sasl_oauthbearer"]} - {"context":"CSS"} ok 569 on Ready event received ok 570 connection result received 2025-09-02T15:37:20.715Z - error: {"message":"Topic test lag 5 > 4","apiErrorCode":{"code":"2003","message":"Service currently unavailable","httpStatusCode":503,"name":"SERVICE_CURRENTLY_UNAVAILABLE","type":{"regex":"^20[0-9]{2}$","description":"Generic Server Error","httpStatusCode":500,"name":"GENERIC_SERVER_ERROR"}}} - {"context":"CSS"} ok 571 Max lag exceeded http status code 503 ok 572 should be equal 2025-09-02T15:37:20.715Z - warn: Producer::onDisconnected - {"connectionOpened":1756827438713} - {"context":"CSS"} 2025-09-02T15:37:20.715Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827438713} - {"context":"CSS"} # Producer test Test Producer::sendMessage with error 2025-09-02T15:37:20.717Z - info: onReady: {"librdkafkaVersion":"2.8.0","features":["gzip","snappy","ssl","sasl","regex","lz4","sasl_gssapi","sasl_plain","sasl_scram","plugins","zstd","sasl_oauthbearer"]} - {"context":"CSS"} ok 573 on Ready event received 2025-09-02T15:37:21.718Z - error: Producer::_getLag() - error: Error: error - {"context":"CSS"} ok 574 connection result received ok 575 should be equal 2025-09-02T15:37:22.720Z - warn: Producer::onDisconnected - {"connectionOpened":1756827440717} - {"context":"CSS"} 2025-09-02T15:37:22.720Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827440717} - {"context":"CSS"} # Producer test Test sync Producer::sendMessage 2025-09-02T15:37:22.721Z - info: onReady: {"librdkafkaVersion":"2.8.0","features":["gzip","snappy","ssl","sasl","regex","lz4","sasl_gssapi","sasl_plain","sasl_scram","plugins","zstd","sasl_oauthbearer"]} - {"context":"CSS"} ok 576 on Ready event received ok 577 connection result received ok 578 should be equal ok 579 should be equal 2025-09-02T15:37:22.722Z - warn: Producer::onDisconnected - {"connectionOpened":1756827442721} - {"context":"CSS"} 2025-09-02T15:37:22.722Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827442721} - {"context":"CSS"} # Producer test Test Producer::sendMessage producer null 2025-09-02T15:37:22.723Z - error: Error: You must call and await .connect() before trying to produce messages. - {"context":"CSS"} ok 580 You must call and await .connect() before trying to produce messages. # Producer test Test Producer::sendMessage producer null 2025-09-02T15:37:22.724Z - error: Error: You must call and await .connect() before trying to produce messages. - {"context":"CSS"} ok 581 You must call and await .connect() before trying to produce messages. # Producer test Test Producer::getMetadata ok 582 connection result received ok 583 metadata object exists ok 584 metadata objects match # Producer test Test Producer::getMetadata - no callback function ok 585 connection result received # Producer test Test Producer::getMetadataSync ok 586 connection result received ok 587 metadata object exists ok 588 metadata objects match # Producer test Test Consumer::isConnected ok 589 connection result received ok 590 isConnected result exists # Producer test Test Consumer::connectedTime ok 591 connection result received ok 592 connectedTime result exists # Producer test for KafkaProducer events Test Producer::connect - test KafkaProducer events: event.log, event.error, error, deliver-report 2025-09-02T15:37:22.733Z - info: onReady: {"librdkafkaVersion":"2.8.0","features":["gzip","snappy","ssl","sasl","regex","lz4","sasl_gssapi","sasl_plain","sasl_scram","plugins","zstd","sasl_oauthbearer"]} - {"context":"CSS"} ok 593 on Ready event received 2025-09-02T15:37:22.733Z - error: Producer::onEventError - "event.error" - {"context":"CSS"} 2025-09-02T15:37:22.733Z - error: Producer::onError()[topics='undefined'] - event.error) - {"context":"CSS"} 2025-09-02T15:37:22.733Z - info: onError: event.error - {"context":"CSS"} ok 594 on Error event received 2025-09-02T15:37:22.733Z - error: Producer::onError - "error" - {"context":"CSS"} 2025-09-02T15:37:22.733Z - error: Producer::onError()[topics='undefined'] - error) - {"context":"CSS"} 2025-09-02T15:37:22.733Z - info: onError: error - {"context":"CSS"} ok 595 on Error event received 2025-09-02T15:37:22.733Z - warn: Producer::onEventThrottle - "event.throttle" - {"context":"CSS"} ok 596 event.throttle ok 597 delivery-report ok 598 connection result received 2025-09-02T15:37:22.734Z - warn: Producer::onDisconnected - {"connectionOpened":1756827442733} - {"context":"CSS"} 2025-09-02T15:37:22.734Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827442733} - {"context":"CSS"} ok 599 disconnected # Producer test for KafkaProducer events Test Producer::connect - test KafkaProducer events: event.log, event.error, error, deliver-report, stats enabled 2025-09-02T15:37:22.735Z - info: onReady: {"librdkafkaVersion":"2.8.0","features":["gzip","snappy","ssl","sasl","regex","lz4","sasl_gssapi","sasl_plain","sasl_scram","plugins","zstd","sasl_oauthbearer"]} - {"context":"CSS"} ok 600 on Ready event received 2025-09-02T15:37:22.735Z - error: Producer::onEventError - "event.error" - {"context":"CSS"} 2025-09-02T15:37:22.735Z - error: Producer::onError()[topics='undefined'] - event.error) - {"context":"CSS"} 2025-09-02T15:37:22.735Z - info: onError: event.error - {"context":"CSS"} ok 601 on Error event received 2025-09-02T15:37:22.735Z - error: Producer::onError - "error" - {"context":"CSS"} 2025-09-02T15:37:22.735Z - error: Producer::onError()[topics='undefined'] - error) - {"context":"CSS"} 2025-09-02T15:37:22.735Z - info: onError: error - {"context":"CSS"} ok 602 on Error event received 2025-09-02T15:37:22.735Z - warn: Producer::onEventThrottle - "event.throttle" - {"context":"CSS"} ok 603 event.throttle 2025-09-02T15:37:22.735Z - error: Consumer::onEventStats - error parsing stats: SyntaxError: Unexpected token 'e', "event.stats" is not valid JSON - {"context":"CSS"} ok 604 event.stats ok 605 delivery-report ok 606 connection result received 2025-09-02T15:37:22.736Z - warn: Producer::onDisconnected - {"connectionOpened":1756827442735} - {"context":"CSS"} 2025-09-02T15:37:22.736Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827442735} - {"context":"CSS"} ok 607 disconnected # Producer test for KafkaProducer events Test Producer::isEventStatsConnectionHealthy default ok 608 Default eventStatsConnectionHealthy should be true # Producer test for KafkaProducer events Test Producer::isEventStatsConnectionHealthy after healthy event.stats ok 609 eventStatsConnectionHealthy should be true when all brokers are UP 2025-09-02T15:37:22.741Z - warn: Producer::onDisconnected - undefined - {"context":"CSS"} 2025-09-02T15:37:22.741Z - warn: Producer::onDisconnected()[topics='undefined'] - undefined - {"context":"CSS"} 2025-09-02T15:37:22.741Z - error: Producer::onEventError - "event.error" - {"context":"CSS"} 2025-09-02T15:37:22.741Z - error: Producer::onError()[topics='undefined'] - event.error) - {"context":"CSS"} 2025-09-02T15:37:22.741Z - error: Producer::onError - "error" - {"context":"CSS"} 2025-09-02T15:37:22.741Z - error: Producer::onError()[topics='undefined'] - error) - {"context":"CSS"} 2025-09-02T15:37:22.741Z - warn: Producer::onEventThrottle - "event.throttle" - {"context":"CSS"} 2025-09-02T15:37:22.741Z - error: Consumer::onEventStats - error parsing stats: SyntaxError: Unexpected token 'e', "event.stats" is not valid JSON - {"context":"CSS"} # Producer test for KafkaProducer events Test Producer::isEventStatsConnectionHealthy after unhealthy event.stats ok 610 eventStatsConnectionHealthy should be false when any broker is DOWN 2025-09-02T15:37:22.743Z - warn: Producer::onDisconnected - undefined - {"context":"CSS"} 2025-09-02T15:37:22.743Z - warn: Producer::onDisconnected()[topics='undefined'] - undefined - {"context":"CSS"} 2025-09-02T15:37:22.743Z - error: Producer::onEventError - "event.error" - {"context":"CSS"} 2025-09-02T15:37:22.743Z - error: Producer::onError()[topics='undefined'] - event.error) - {"context":"CSS"} 2025-09-02T15:37:22.743Z - error: Producer::onError - "error" - {"context":"CSS"} 2025-09-02T15:37:22.743Z - error: Producer::onError()[topics='undefined'] - error) - {"context":"CSS"} 2025-09-02T15:37:22.743Z - warn: Producer::onEventThrottle - "event.throttle" - {"context":"CSS"} 2025-09-02T15:37:22.743Z - error: Consumer::onEventStats - error parsing stats: SyntaxError: Unexpected token 'e', "event.stats" is not valid JSON - {"context":"CSS"} # Producer test for KafkaProducer events Test Producer::isEventStatsConnectionHealthy with malformed event.stats 2025-09-02T15:37:22.745Z - error: Consumer::onEventStats - error parsing stats: SyntaxError: Expected property name or '}' in JSON at position 1 (line 1 column 2) - {"context":"CSS"} ok 611 eventStatsConnectionHealthy should be false on malformed stats 2025-09-02T15:37:22.745Z - warn: Producer::onDisconnected - undefined - {"context":"CSS"} 2025-09-02T15:37:22.745Z - warn: Producer::onDisconnected()[topics='undefined'] - undefined - {"context":"CSS"} 2025-09-02T15:37:22.745Z - error: Producer::onEventError - "event.error" - {"context":"CSS"} 2025-09-02T15:37:22.745Z - error: Producer::onError()[topics='undefined'] - event.error) - {"context":"CSS"} 2025-09-02T15:37:22.745Z - error: Producer::onError - "error" - {"context":"CSS"} 2025-09-02T15:37:22.745Z - error: Producer::onError()[topics='undefined'] - error) - {"context":"CSS"} 2025-09-02T15:37:22.745Z - warn: Producer::onEventThrottle - "event.throttle" - {"context":"CSS"} 2025-09-02T15:37:22.745Z - error: Consumer::onEventStats - error parsing stats: SyntaxError: Unexpected token 'e', "event.stats" is not valid JSON - {"context":"CSS"} # Producer test for KafkaProducer events Test Producer::isEventStatsConnectionHealthy with event.stats as string ok 612 eventStatsConnectionHealthy should be true when all brokers are UP (string) 2025-09-02T15:37:22.747Z - warn: Producer::onDisconnected - undefined - {"context":"CSS"} 2025-09-02T15:37:22.747Z - warn: Producer::onDisconnected()[topics='undefined'] - undefined - {"context":"CSS"} 2025-09-02T15:37:22.747Z - error: Producer::onEventError - "event.error" - {"context":"CSS"} 2025-09-02T15:37:22.747Z - error: Producer::onError()[topics='undefined'] - event.error) - {"context":"CSS"} 2025-09-02T15:37:22.747Z - error: Producer::onError - "error" - {"context":"CSS"} 2025-09-02T15:37:22.747Z - error: Producer::onError()[topics='undefined'] - error) - {"context":"CSS"} 2025-09-02T15:37:22.747Z - warn: Producer::onEventThrottle - "event.throttle" - {"context":"CSS"} 2025-09-02T15:37:22.748Z - error: Consumer::onEventStats - error parsing stats: SyntaxError: Unexpected token 'e', "event.stats" is not valid JSON - {"context":"CSS"} # Producer test for KafkaProducer events Test Producer::isEventStatsConnectionHealthy with event.stats missing brokers ok 613 eventStatsConnectionHealthy should be false when brokers property is missing 2025-09-02T15:37:22.749Z - warn: Producer::onDisconnected - undefined - {"context":"CSS"} 2025-09-02T15:37:22.749Z - warn: Producer::onDisconnected()[topics='undefined'] - undefined - {"context":"CSS"} 2025-09-02T15:37:22.749Z - error: Producer::onEventError - "event.error" - {"context":"CSS"} 2025-09-02T15:37:22.750Z - error: Producer::onError()[topics='undefined'] - event.error) - {"context":"CSS"} 2025-09-02T15:37:22.750Z - error: Producer::onError - "error" - {"context":"CSS"} 2025-09-02T15:37:22.750Z - error: Producer::onError()[topics='undefined'] - error) - {"context":"CSS"} 2025-09-02T15:37:22.750Z - warn: Producer::onEventThrottle - "event.throttle" - {"context":"CSS"} 2025-09-02T15:37:22.750Z - error: Consumer::onEventStats - error parsing stats: SyntaxError: Unexpected token 'e', "event.stats" is not valid JSON - {"context":"CSS"} # Producer test for KafkaProducer events Test Producer::connect - pollIntervalMs not integer 2025-09-02T15:37:22.752Z - error: Producer::onEventError - "event.error" - {"context":"CSS"} 2025-09-02T15:37:22.752Z - error: Producer::onError()[topics='undefined'] - event.error) - {"context":"CSS"} 2025-09-02T15:37:22.752Z - error: Producer::onError - "error" - {"context":"CSS"} 2025-09-02T15:37:22.752Z - error: Producer::onError()[topics='undefined'] - error) - {"context":"CSS"} 2025-09-02T15:37:22.752Z - warn: Producer::onEventThrottle - "event.throttle" - {"context":"CSS"} ok 614 Error thrown for non-integer pollIntervalMs # Producer test for KafkaProducer events Test Producer::sendMessage throws for invalid buffer 2025-09-02T15:37:22.753Z - error: Producer::onEventError - "event.error" - {"context":"CSS"} 2025-09-02T15:37:22.753Z - error: Producer::onError()[topics='undefined'] - event.error) - {"context":"CSS"} 2025-09-02T15:37:22.753Z - error: Producer::onError - "error" - {"context":"CSS"} 2025-09-02T15:37:22.754Z - error: Producer::onError()[topics='undefined'] - error) - {"context":"CSS"} 2025-09-02T15:37:22.754Z - warn: Producer::onEventThrottle - "event.throttle" - {"context":"CSS"} 2025-09-02T15:37:22.754Z - error: Error: message must be a string or an instance of Buffer. - {"context":"CSS"} ok 615 Error thrown for invalid buffer 2025-09-02T15:37:22.754Z - warn: Producer::onDisconnected - {"connectionOpened":1756827442753} - {"context":"CSS"} 2025-09-02T15:37:22.754Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827442753} - {"context":"CSS"} # otel Tests --> executeAndSetSpanStatus Tests --> should set error status and record exception in case if fn failed ok 616 span.setStatus() was called with error code ok 617 span.recordException() was called with error # otel Tests --> executeAndSetSpanStatus Tests --> should call span.end() if withSpanEnd === true ok 618 span.end() was called 2025-09-02T15:37:22.757Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438065} - {"context":"CSS"} 2025-09-02T15:37:22.757Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438065} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438072} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438072} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438074} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438074} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438075} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438075} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438077} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438077} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438078} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438078} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438084} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438084} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438086} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438086} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438087} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438087} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438088} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438088} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438089} - {"context":"CSS"} 2025-09-02T15:37:22.758Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438089} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438091} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438091} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438092} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438092} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438093} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438093} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438094} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438094} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438095} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438095} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438107} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438107} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438114} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438114} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438117} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438117} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438119} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438119} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438121} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438121} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438124} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438124} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438129} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438129} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected - {"connectionOpened":1756827438685} - {"context":"CSS"} 2025-09-02T15:37:22.759Z - warn: Consumer::onDisconnected()[topics='test'] - {"connectionOpened":1756827438685} - {"context":"CSS"} 2025-09-02T15:37:22.760Z - warn: Producer::onDisconnected - {"connectionOpened":1756827442725} - {"context":"CSS"} 2025-09-02T15:37:22.760Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827442725} - {"context":"CSS"} 2025-09-02T15:37:22.760Z - warn: Producer::onDisconnected - {"connectionOpened":1756827442727} - {"context":"CSS"} 2025-09-02T15:37:22.760Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827442727} - {"context":"CSS"} 2025-09-02T15:37:22.760Z - warn: Producer::onDisconnected - {"connectionOpened":1756827442728} - {"context":"CSS"} 2025-09-02T15:37:22.760Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827442728} - {"context":"CSS"} 2025-09-02T15:37:22.760Z - warn: Producer::onDisconnected - {"connectionOpened":1756827442730} - {"context":"CSS"} 2025-09-02T15:37:22.760Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827442730} - {"context":"CSS"} 2025-09-02T15:37:22.760Z - warn: Producer::onDisconnected - {"connectionOpened":1756827442731} - {"context":"CSS"} 2025-09-02T15:37:22.760Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827442731} - {"context":"CSS"} 2025-09-02T15:37:22.761Z - warn: Producer::onDisconnected - {"connectionOpened":1756827442752} - {"context":"CSS"} 2025-09-02T15:37:22.761Z - warn: Producer::onDisconnected()[topics='undefined'] - {"connectionOpened":1756827442752} - {"context":"CSS"} 1..618 # tests 618 # pass 618 # ok ERROR: Coverage for lines (83.33%) does not meet threshold (90%) for /home/circleci/project/src/kafka/protocol/util.js ERROR: Coverage for branches (50%) does not meet threshold (90%) for /home/circleci/project/src/kafka/protocol/util.js ERROR: Coverage for statements (83.33%) does not meet threshold (90%) for /home/circleci/project/src/kafka/protocol/util.js ERROR: Coverage for lines (75%) does not meet threshold (90%) for /home/circleci/project/src/kafka/protocol/messages.js ERROR: Coverage for branches (50%) does not meet threshold (90%) for /home/circleci/project/src/kafka/protocol/messages.js ERROR: Coverage for statements (75%) does not meet threshold (90%) for /home/circleci/project/src/kafka/protocol/messages.js ERROR: Coverage for lines (73.52%) does not meet threshold (90%) for /home/circleci/project/src/kafka/shared.js ERROR: Coverage for branches (65.38%) does not meet threshold (90%) for /home/circleci/project/src/kafka/shared.js ERROR: Coverage for statements (73.52%) does not meet threshold (90%) for /home/circleci/project/src/kafka/shared.js ERROR: Coverage for lines (18.75%) does not meet threshold (90%) for /home/circleci/project/src/util/consumer.js ERROR: Coverage for functions (0%) does not meet threshold (90%) for /home/circleci/project/src/util/consumer.js ERROR: Coverage for branches (0%) does not meet threshold (90%) for /home/circleci/project/src/util/consumer.js ERROR: Coverage for statements (18.07%) does not meet threshold (90%) for /home/circleci/project/src/util/consumer.js ERROR: Coverage for lines (15.04%) does not meet threshold (90%) for /home/circleci/project/src/util/producer.js ERROR: Coverage for functions (0%) does not meet threshold (90%) for /home/circleci/project/src/util/producer.js ERROR: Coverage for branches (0%) does not meet threshold (90%) for /home/circleci/project/src/util/producer.js ERROR: Coverage for statements (14.91%) does not meet threshold (90%) for /home/circleci/project/src/util/producer.js =============================== Coverage summary =============================== Statements : 75.31% ( 607/806 ) Branches : 66.46% ( 216/325 ) Functions : 78.65% ( 129/164 ) Lines : 75.44% ( 587/778 ) ================================================================================