{"_id":"@firefly-exchange/kafka-client","_rev":"35-91501a1493499e7f4279b77c6d4b0f12","name":"@firefly-exchange/kafka-client","dist-tags":{"pre-release":"4.2.2-alpha.1","latest":"4.4.0"},"versions":{"1.0.0":{"name":"@firefly-exchange/kafka-client","version":"1.0.0","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@1.0.0","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"dist":{"shasum":"fe5cd0e85170f276d80c0097c9c814dc6c51579b","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-1.0.0.tgz","fileCount":7,"integrity":"sha512-OkjB9JLtSwk2OCt2rR3aPFu/i+CG3pt7+bJHe3Gn+45pZqzS3hjUKfCzh8KF+RutC0R5cN0zFxvr7bQehedlRA==","signatures":[{"sig":"MEUCIEMlxPnUiV3kxWv+u0qjJ1TzxndzEmWtQbcbxfObpNn3AiEAo0tiTBkYNbjYvCJPbDLBr9RPoX4mBMCttRjLoxNPjfc=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":13219,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJj3KzYACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2VmpfgA//XN7SW1+Ndhf+Zb42p64wuDnSWAWqUJzSceDZW1pYDyrUeV2H\r\n8dxPmfEDbM+uk0Wp8X1Uj9Z0cjbOfTARN7GDf1levUW4gE2ZvbwPqopOkeUZ\r\npP+PpHqqoHpcLoPUMZZapKBT9OrWrFQz+djR/5cz/nMAPct7IAwHZyFLwdD3\r\n4KZVyw0Y2MGx0GUmWC55t+kZY+zIA9/qWVvlb54r7Qm2cTTgCe6CIVw9mKom\r\nrmVJDEa4JDARK11WhecAqN1YcnX1friClxpCxltTXB9JGlsgY2xGDUiHzMq6\r\ndNvDjQiEmte4qi0v2NLf3/z50YFZyHk0Fr/arapkdxLgSF+60Pymj934wLpE\r\nVGFm/keSaRA/cYiOHCkW8JtOaSbdmUyvfUaXzzO0aO2cBlybGqHImKyIHHoV\r\nAvQCOL0Vvdh4pHXPkGgroKZI1hRaJFXJD/eTCALrm+Y/1rKo/VoclrbXrri9\r\n/Sn5ySnbK68C2puSV0vA1OltLGjWSQM48+a/bkbk8NNuTUDrxuApkbWSh1jB\r\nziG6OcgGo2hree4eQjspvpCOL4fTpYntnhymkKrAM0hSg2LPi6yc2gyu/cNp\r\n8LAIiFE0SriNKvyX/ZA+IVixeqtil2Ya4jc4IF9ZkiAp5IBNRw5881eZsXh/\r\nhB3z4VcKk1LP2e4y/xHTySnftOIrWSmq/Os=\r\n=3shy\r\n-----END PGP SIGNATURE-----\r\n"},"main":"dist/index.js","gitHead":"837d1f10842d8a77a2b1ae96d6576c73e4dc4982","scripts":{"build":"tsc","prepare":"husky install","test:unit":"mocha --no-timeout --exit  -r ts-node/register 'tests/**/*.ts'","clean-build":"rm -rf dist; tsc","install:docker":"chmod +x local/docker.sh && local/docker.sh","start:docker:kafka":"docker-compose -f local/docker/kafka-docker-compose.yml up -d"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"_npmVersion":"8.19.3","description":"The Kafka Client library to connect with Exchange MSK.","directories":{},"_nodeVersion":"16.19.0","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_1.0.0_1675406551931_0.8150646810135997","host":"s3://npm-registry-packages"}},"1.0.1":{"name":"@firefly-exchange/kafka-client","version":"1.0.1","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@1.0.1","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"42419b7fff3a348d44cd0a4c50d36c5a857f7e8f","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-1.0.1.tgz","fileCount":10,"integrity":"sha512-4Km6khWcG5wXR/i4EmXwRsOrBfSye6+Tu3uuGFGn5CzvP5QfjsRYuweeEegen6UcxVRPZ1NH5d7TKaIm3Y26eg==","signatures":[{"sig":"MEUCICDqxpwgpL/V1W7AALCKM6UtqDn1XKq6eOGLdsEOsk4PAiEA9fPqL2FeXEgo6R6B4XNy6pQ4qEwHqDaYx5F5fsP7E5Y=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":12621,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJj8J6QACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2VmqnWQ//eUESY5khQ8Utf0OBpD8Y7/tLYF2oH3kC02wTPtzjT/b9zGGd\r\n77ispHMou0gyxdKNgi4Ld58yofICnmFt+DwIEcSF6OMT8MdJg+zNU5ExaVQ4\r\n1Wlt08qdFfbL4fuB/EUICZZBQAL4hs6xZuZHNREMqtl0s4WwcpNENC9X3zo4\r\n0RayWIxAQwgjUTNn5WMQhMYsv/rHmxAEKNC41h38PyrWd2Z2qBXSEoaW/ZZF\r\nIbgpQBIkmYf2cAXnenJ54oGy9U5fFNpkuEsxtFIMHaj1W1JqHF3oAUQDtE7k\r\nWR6VgKijKLD4zMmq6UT1PlJRPGS7BX/mcx5sWeJ7aM7Tvh8sk56ienPV9iB9\r\nxDyrqjD6glydfUMvO3Y4mLs/vlo+PFQTejc0fzsptsW0KGfuswldqd7lfrwB\r\nf3X34Md+ieVcPZs35AsyMJjLDUzwbgczdFPTW4E1LaQT2JVdx3AgeYNFwPp7\r\nirZJpRM2ve8IyLl86WmUaNJ41J7wtkVv+zfVMB5aDID0mMwLKngTi4RLcGzP\r\nEw15LwgGmi454vbuP3tZhOJDgsdi01mCRLNIaQloROBpDyZLcyJg1kJkbNAM\r\nJxF2XeTC3nthTdQY3GAviSWSufmjkhz9XqDuVCnCznma6oRMXo6EvwV5uQif\r\nxxXqawMeYH3YlSrH5iDX/B8Mo6Rd+NFY0Ns=\r\n=E20X\r\n-----END PGP SIGNATURE-----\r\n"},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"af10879340d21cdc4e18b03621576c64f3437f51","scripts":{"build":"rm -rf dist/ && tsc","prepare":"husky install","test:int":"mocha --no-timeout --exit  -r ts-node/register 'tests/**/*.ts'","install:docker":"chmod +x local/docker.sh && local/docker.sh","start:docker:kafka":"docker-compose -f local/docker/kafka-docker-compose.yml up -d"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.3","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages.","directories":{},"_nodeVersion":"16.19.0","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_1.0.1_1676713616250_0.7012689329219526","host":"s3://npm-registry-packages"}},"2.0.0":{"name":"@firefly-exchange/kafka-client","version":"2.0.0","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@2.0.0","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"1c4499aad6ef5cf8f649352da9df0a3095487f01","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-2.0.0.tgz","fileCount":10,"integrity":"sha512-eJBAfQeIyMjLMIJKuqX8a+sQuJqubptk6iyPHZvhgvrAVPIVDSY6w/TEHZiLuh5MQ1PN5KkndBkYEtZja8peMg==","signatures":[{"sig":"MEQCIEI3CFzFNxCJDqM++Uzo3cRtjvwx7WGKf27eP19Dz+nZAiB9GFVBJCFjOrqdJtGZDAFnUlbkJFMUNQYZCqWewvlDxg==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":11745},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"39970007a1d41f14fb59441575de6b43dc2900fb","scripts":{"build":"rm -rf dist/ && tsc","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages.","directories":{},"_nodeVersion":"16.20.0","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_2.0.0_1684481899290_0.3920066892797054","host":"s3://npm-registry-packages"}},"2.0.1":{"name":"@firefly-exchange/kafka-client","version":"2.0.1","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@2.0.1","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"f1bc02e984452fabb8db8a0aa1987c240780e73f","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-2.0.1.tgz","fileCount":10,"integrity":"sha512-zyQNFbUvpP7WDaq27kNpJkujAtW8oWCCx8TS5eexZQfuEdAb5cC+g3UZFjuJ0jjR3IinhzLXwhq1TpA+xFphsQ==","signatures":[{"sig":"MEYCIQCJcPgoVti2QmcxxOWzcZf5ot7DgCxg5vm9Qt3OAB2PTQIhAJ8ehejwNkEmHRwGZZHGpwaN46f1g+VvlvfHRkTDTZeQ","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":11729},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"4a432232aa87de60181f65654f679d26465c2359","scripts":{"build":"rm -rf dist/ && tsc","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages.","directories":{},"_nodeVersion":"16.20.0","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_2.0.1_1684597569906_0.9573135288983723","host":"s3://npm-registry-packages"}},"2.0.2":{"name":"@firefly-exchange/kafka-client","version":"2.0.2","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@2.0.2","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"cb663f3dc81040fc14eff685bcf9dd30e551d2ce","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-2.0.2.tgz","fileCount":10,"integrity":"sha512-WH6NhsZozVALY89QxHX2ySID6F2O+MrkiyukLDppd63ltC/TcnL+9T9MD+LQzirN0cls/skYLb8ckyhHagC+dg==","signatures":[{"sig":"MEUCIHkxBwa7IzjRsWOZHKo2BC3EX9NHllLBik88LKITFN2lAiEAoCKYvFoQCJdkRVHlTVeaTmOe70FchvldyzZVvR1LtBw=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":12076},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"ad957a3630d057bb374fb3eedf9373439d4fa923","scripts":{"build":"rm -rf dist/ && tsc","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages.","directories":{},"_nodeVersion":"16.20.0","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_2.0.2_1684826722486_0.8951704579456532","host":"s3://npm-registry-packages"}},"2.0.3":{"name":"@firefly-exchange/kafka-client","version":"2.0.3","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@2.0.3","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"3f3d3bada7704be3ce36a2176906513498fbc180","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-2.0.3.tgz","fileCount":10,"integrity":"sha512-4P58hKwnrYD8+Wfsguw+mDkYIHPouuzbp7XI2bT8w3ZE2UmuHu3UPStowq0bs/7O7u+S7MI4zKNbHMQoOBDVFA==","signatures":[{"sig":"MEUCIQDjxt316lFQlX8GXBBspAaTsiPb5FIxQE9xd8M4MjUbvwIgKFJzue/8t9U8MyPTNgrdQyZszGHXdUXENO2ZrdZs57w=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":13750},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"0452bb0b1b1f4dba6995608b9c3ee70ec7101087","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages.","directories":{},"_nodeVersion":"16.20.0","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_2.0.3_1685006924115_0.9541198761984893","host":"s3://npm-registry-packages"}},"2.0.4":{"name":"@firefly-exchange/kafka-client","version":"2.0.4","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@2.0.4","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"6d80b4e80bef45c8ccb0dcd4fdc7fbdaa87116f6","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-2.0.4.tgz","fileCount":12,"integrity":"sha512-PAcRVoZzc7h4tJ/Fz8ll+fZcPyGxi9VPZpan/zOp1OYy79Jt/vepoqokE7iPPCHi/GJ4cbWYvSdvbKtPmtIVkQ==","signatures":[{"sig":"MEQCICya6Lwaa5dpEr05ddPO9DNnxZWmwQ8khTb8/mX7dJ/JAiBtZyFXfiQqCwvB1rzcnRkDAoI4c9FwYtXXPmR69VC4mw==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":14620},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"88c166908d61c95c253b685d3a5452d7455e0acc","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages.","directories":{},"_nodeVersion":"16.20.0","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_2.0.4_1685285498643_0.16908119104525965","host":"s3://npm-registry-packages"}},"2.0.5":{"name":"@firefly-exchange/kafka-client","version":"2.0.5","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@2.0.5","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"11be9bdb6ddc19068cfab61cbcba47c096459330","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-2.0.5.tgz","fileCount":12,"integrity":"sha512-WCmZoI1Z92mSNMJaRtX7q/EKp8AkoN8HoxYkOzmDvfn7FG4HJYDUWV6GfIs8AzDz1yXeORqVoVJLfjpQNpS1iA==","signatures":[{"sig":"MEYCIQCAr6UxByZTThodPtome/J450bdF1r7dj1BFXGLXf1zBAIhALwPor9ENdptGiKkfw0oZ5DtE0yNs/AI2b8tXI6oXnlw","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":14757},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"a4fae1c41d190b8723bd62fe3bd3acedc51f7626","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages.","directories":{},"_nodeVersion":"16.20.0","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_2.0.5_1685341618359_0.07035254213710607","host":"s3://npm-registry-packages"}},"2.0.6":{"name":"@firefly-exchange/kafka-client","version":"2.0.6","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@2.0.6","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"c5fbcb391e84c8469f21609e7cac85ce309410fb","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-2.0.6.tgz","fileCount":12,"integrity":"sha512-mo+Jg3QMuacHOWnu79ic7SKctoBjfOpDIuBShn4KjpP//dKJTUA4032aGwa6zClWp93v3NXhZ1Ir3Fk9mopVaQ==","signatures":[{"sig":"MEUCIQD8LPy0nfYRvTMpydCWXdQADG8XSxi3BnZpTdCMKStXSgIgNR7fefK0zmTcpVRH9Nl1RnxjLxILxm6KILnMCyIgWZw=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":14737},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"04dbee481e3ada33c357f611b955476e2af6e4c7","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages.","directories":{},"_nodeVersion":"16.20.0","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_2.0.6_1685344974579_0.7882766730266866","host":"s3://npm-registry-packages"}},"2.0.7":{"name":"@firefly-exchange/kafka-client","version":"2.0.7","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@2.0.7","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"95bca9430a012c8108e34d7c978eb54a4623d7e6","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-2.0.7.tgz","fileCount":12,"integrity":"sha512-bEdytywc47dbRdZCY0Zn5cwnG5OEoDjtvoceNEI9Mr2DzKypiK5h3AY+pZju17B3/n2w8keI1BGizYZ/zhjHvw==","signatures":[{"sig":"MEYCIQCJh0zUKqWdNtl6ImaguwL60EneL7HfRHG13CFe9Q4eVQIhAMX056G+jzE7hmuRlWrSduM/8VfD41iKFVtwgdEMtBF9","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":14565},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"34ad27392406b8ca8d37a190b3dcac4c9c84c443","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages.","directories":{},"_nodeVersion":"16.20.0","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_2.0.7_1685354467309_0.6464684424881195","host":"s3://npm-registry-packages"}},"2.0.8":{"name":"@firefly-exchange/kafka-client","version":"2.0.8","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@2.0.8","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"9a31ff58af2c1051833228dd3cc16582d58fc9c6","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-2.0.8.tgz","fileCount":12,"integrity":"sha512-YMh54q5q1J92CCIE4WkeljdLwcXrrEntOkcFrgjBoTbRRkOiN2dsislA/gseFwG9/pS8cu5a63ZJXpsG4Wd97Q==","signatures":[{"sig":"MEUCIQC1DRyfGvoeVEA50j5kmhhCyR1v4BnIGttUoAD8anflKQIgCTcGm60jwKUy8rskBisjABpsYBNdguSTnkq3Jqm2h8M=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":15099},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"fe89ff78ef59c6fb89b3a3d29958c87cf3873803","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages.","directories":{},"_nodeVersion":"16.20.0","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_2.0.8_1685608128492_0.701652677558559","host":"s3://npm-registry-packages"}},"2.0.9":{"name":"@firefly-exchange/kafka-client","version":"2.0.9","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@2.0.9","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"dd41af6851261d146a255822600bea11508c3304","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-2.0.9.tgz","fileCount":12,"integrity":"sha512-crmtaRJf9DyNn8azFBE4xvCtM50ZnxPy07ymUvFAc2IFbzAYnLB3ytnYQEfIuzkAEnoO+WSr0hoGf1W3Slr+2g==","signatures":[{"sig":"MEUCIG+uqGlICx7qBN0pMp1CO3GNN5lqzlHUofOYS1KWa3BhAiEArgNHe1mFIFmqZRwpfzWgItrscvbCw1H5/WY+zJof90s=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":17013},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"ee8e8ebf997e91721248f95d09d9350e548daef0","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages.","directories":{},"_nodeVersion":"16.20.0","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_2.0.9_1685940670282_0.3375968611614071","host":"s3://npm-registry-packages"}},"2.0.10":{"name":"@firefly-exchange/kafka-client","version":"2.0.10","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@2.0.10","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"64855f157d78acce38f1b321a5e87725a8871b93","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-2.0.10.tgz","fileCount":12,"integrity":"sha512-BbmeWUqfFYfr+XagXjS+e6GF74RZmw2K+dtCbWmdnKwgUfX71hKPNMo3m7xwXybu/m1QFBQLUA4pO2fkwfjLLg==","signatures":[{"sig":"MEYCIQCw9QjYHuupWysWuobPrHzClPOTLQ/cJigqZaBK5NUuuAIhALDO3xOQagzBf57hCIYaQ1IzsnfKvuoQrI17fLRcKTWz","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":17139},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"fb4efe6020d3c54d6806274aed303f4d12bb78cb","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages.","directories":{},"_nodeVersion":"16.20.0","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_2.0.10_1686053742688_0.2817955822879481","host":"s3://npm-registry-packages"}},"2.0.11":{"name":"@firefly-exchange/kafka-client","version":"2.0.11","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@2.0.11","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"64604d72a0c608caa17a5926118398dbbf3b4dc0","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-2.0.11.tgz","fileCount":12,"integrity":"sha512-2Uv7NnrwKnbrK7IbsdbWLXjAkdQA5FjAhu7SVAARFWj5h6K978lyZl96+82vZhnZionZ9g4Hx4v3qgEDNhn0HA==","signatures":[{"sig":"MEUCIA7hgoAVU/Q0qE8Tk3+3mIsVKgs8kwJWiERZqHFmy156AiEA2AJOwmVdfmkVGUcX1URYcu+q9eoUScXaOta/76GgrSQ=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":17356},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"369a08f5b6b5f79df69a74aed77fe3286dccc92b","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages.","directories":{},"_nodeVersion":"16.20.0","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_2.0.11_1686214153024_0.1446691443459831","host":"s3://npm-registry-packages"}},"3.0.0":{"name":"@firefly-exchange/kafka-client","version":"3.0.0","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@3.0.0","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"6b152c4c1e03a770b5f83ccbacd9c7856f3fa291","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-3.0.0.tgz","fileCount":12,"integrity":"sha512-GA027Md5Vz2fPjGCkWusxOEybpgsP/g/axmcmwC0muwmWp00uaeQlPp4Sq1Mfkj6HJJgN8yP9OCjE8UlXcZklQ==","signatures":[{"sig":"MEUCIQCGhpJ/O4lIK3qCbe/grTlsVuHBJFhbnnifIJi4jxS+EwIgBrV2qKKcMI1Yv7v8Fwf9ezJOHgTN6MTBxHobk0j5FWM=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":18111},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"2134a073a49dac3c44a06620166f932c603e2299","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.1","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^1.16.0","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_3.0.0_1688642263055_0.09134393975683763","host":"s3://npm-registry-packages"}},"4.0.0":{"name":"@firefly-exchange/kafka-client","version":"4.0.0","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.0.0","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"f858b62e37ef63874bcb0e60e2f4c9b4c3abab5b","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.0.0.tgz","fileCount":12,"integrity":"sha512-S0wS6IsOc4wqmh3gsoEcrGW5RA6ySkYjlDOtXdydLCG5pVVmilRg2mTooXACBeHRS7VU7XT13T6m6v+WLIPnzQ==","signatures":[{"sig":"MEUCIQCWhkeWom9P0NNSq5/7uZwTKqWHS1A8zIYodWrN5fbWrQIgWe6idDSzX7fMz/GVB8GwWV9mIAPeryQ+gnmOSS6nu8E=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":18110},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"7aa38e712ec37007002cf24b8e1af7e9ba6c2b45","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.1","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.0.0_1688668277424_0.9920953492066591","host":"s3://npm-registry-packages"}},"4.1.0":{"name":"@firefly-exchange/kafka-client","version":"4.1.0","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.1.0","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"eff548ff4da6178a9040c2617c2172ab768034bc","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.1.0.tgz","fileCount":14,"integrity":"sha512-g1zZ0BwdrG9hhbxmtqlcRPf2ob7NfJDFd7aVS41kkJQcKGxrCnyfLVMZbm5VY6uHdXphFFN4/A+/1wLG7Eo3uQ==","signatures":[{"sig":"MEUCIBpOMtVBxkaXhmM6lpA9yL5hU+5a/IlFb2rjg7LQVDNrAiEA30K3J8AxJ/Mmusp2sgdSNUhqE6urnAazhqEN93kdwMo=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":18634},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"6c3c014565d636bcbb53970d0311c6155af1c716","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.1","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.1.0_1688920257025_0.39223352208048157","host":"s3://npm-registry-packages"}},"4.1.1":{"name":"@firefly-exchange/kafka-client","version":"4.1.1","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.1.1","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"e295c49474a9e354e37934bf202c4a41912c2257","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.1.1.tgz","fileCount":14,"integrity":"sha512-NvhjTfhh4qG2ePc9ctA7J+iZg5RJZWkY4CclUxuvMiZq0TfBQhuiseb7gX4mV9FAEyho1YBsI/wzMkHt9j43Ow==","signatures":[{"sig":"MEUCIQDP6o6VwXkLQQEJWUFIqmTaFW2UZsEa3ZjHKGi/Y4ScegIgI4/15q7tGgPp7uo/iL8vWZ2/KEHoWiqAiJSuDfMl22E=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":18795},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"71a61b9bc967483a23dd76c887e40b4a7af82c13","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.1","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.1.1_1689355638958_0.8328227985826007","host":"s3://npm-registry-packages"}},"4.1.2":{"name":"@firefly-exchange/kafka-client","version":"4.1.2","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.1.2","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"208046e3668783e597f055098c03bac28de1cea5","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.1.2.tgz","fileCount":16,"integrity":"sha512-+1sGTqJiL/LTYZCz23pkhe0e+udaJ59/PAPkNsUpUYGKsK95aZjhURPuQX+5OS4usndM1OAAZaNJMIJpU1gTZg==","signatures":[{"sig":"MEUCIC5n/px9+VJ07lD9/LmTCygvUfKwgTI3ozmgK3ugZa/vAiEAk78NsfEH0ViCFNjeavZGPTJ4dI8+reMsphfRvCA+04c=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":20672},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"fde7102da15ca3a4900a18747c961755989d0dfc","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.1","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.1.2_1690449332858_0.41727948509155444","host":"s3://npm-registry-packages"}},"4.1.3":{"name":"@firefly-exchange/kafka-client","version":"4.1.3","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.1.3","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"9cf70d956a77c2c87ad4e50e87e94ac2a7734d77","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.1.3.tgz","fileCount":16,"integrity":"sha512-jTlt4lGPRC6rMMu4+wlxJuIEAzmzzFIydVtYNLMct/HGLUx3Hd7KIR0AonJsMoH5IAlNWUrwGTSvl5nhZn2SiQ==","signatures":[{"sig":"MEYCIQDzdKecIBXWRHEyMkNfGPu6SEQRZXQI3+ONMqm+wj3GZwIhAO2uZ0vwbcfpnYW4rZ3AWqBoWidEKrM5iBDPh/6Bd460","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":20773},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"fcc55423a99cbec0c03b6c383054a9b6df22bdc8","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.1","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.1.3_1690729254945_0.3408336284815656","host":"s3://npm-registry-packages"}},"4.1.4":{"name":"@firefly-exchange/kafka-client","version":"4.1.4","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.1.4","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"14460120e2b417cc5faf7d82a674d43220e22abb","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.1.4.tgz","fileCount":16,"integrity":"sha512-sEFcmddxVBmKOCdVDN7HDJwNwW+egBstR1KD82b/FfYTiDOEhUMoIDvtPlBWksQW+rmElj9Yl4SYQiFw0yuzKg==","signatures":[{"sig":"MEYCIQDHSLJmFyhq5LwHqjxEv/wZznb+y/PUNjq12ZbxkHsZUQIhALeMBv4hcyBD+CLI60v8PA2uKw3avK1nIPH7tHKs+i/X","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":21177},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"ffe6c32997a287bbc6c612da622a902e11635294","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.1","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.1.4_1690802264622_0.09041449566537119","host":"s3://npm-registry-packages"}},"4.1.5":{"name":"@firefly-exchange/kafka-client","version":"4.1.5","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.1.5","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"ab146378063e137ab585bdeae416305fd2d1d41b","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.1.5.tgz","fileCount":16,"integrity":"sha512-rqpvVDJsIrtxCnamOGVyj00bgH9OmSdI4B90r9mKTI9JRO2ya0NmwzWta/+e9tR8mRL3FGYmJp2jT7eG4snigQ==","signatures":[{"sig":"MEQCIBVmraEmXpHN1LkFMGRdBqw1sBEqm3WRo2yvkbfZGlP0AiABPaohNU7YcXxF8VKfOIs71KYKjowN/YfP1jaPsegVgQ==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":20481},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"73f9460b26e4af7ba05b901670dc6639d31ded0e","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.2","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.1.5_1693398616783_0.9286708997569428","host":"s3://npm-registry-packages"}},"4.1.6":{"name":"@firefly-exchange/kafka-client","version":"4.1.6","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.1.6","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"3430c22ab80bb754455705182537eddc6ef4e501","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.1.6.tgz","fileCount":16,"integrity":"sha512-USdRSdtLrvVcNpWAdAUkWJHsfM7M5vu367gVTTEzr35E+NrKAT3Q3roc0VlzjaQ2Q3PVw1khd0Jv1agihf48YA==","signatures":[{"sig":"MEUCIQDeka7HeEztqlVUU0OfNwedDtgO4yamhljHFKYTprmx2gIgDHX8CUIt8O1tfEFfYY0x1nAUnXYTrw3JcF5bFrdzZxg=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":20401},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"922f6f61d6da100e051bcbcf4a750daf6df25b05","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.2","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.1.6_1695841980394_0.8832010521760125","host":"s3://npm-registry-packages"}},"4.1.7":{"name":"@firefly-exchange/kafka-client","version":"4.1.7","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.1.7","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"4021ca91e6bc19b2b40eabf45d0c3ad9162c0d12","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.1.7.tgz","fileCount":16,"integrity":"sha512-Q9Txl9QqvmHmUTHeZLRocLc+AWmhQrLe1wqVsLjq6lm+jyc3sLPqjONLB5dzEtIQY/86p3OM1tHQ2fCxZLJO6g==","signatures":[{"sig":"MEYCIQC/YlaPzeWT0AQMzXn15SrVdVXwMtl0+/XXIbtmnJiH3QIhAJuaVYWKaH9y81GAL6QcP/pgEPuSgjSc0mZvEuHQvp1a","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":20903},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"3313545f821e9ca6811a6004d89220856a353f7f","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.2","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.1.7_1700831432398_0.7261171231644936","host":"s3://npm-registry-packages"}},"4.1.8":{"name":"@firefly-exchange/kafka-client","version":"4.1.8","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.1.8","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"63b9128c94a3afcccf7e4821f51bacbb2943dcdb","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.1.8.tgz","fileCount":16,"integrity":"sha512-BhTueeJpzJrAIi0NOvX6kin2C5BfU6pSkTV+EHXG9ixcpcz9vlXWoWUPwDvZ0xpJ+gCuBek3JLo1Q/u5n5MhoQ==","signatures":[{"sig":"MEYCIQCPqe4sG4fDxcgdIUVBauQ60U1NFvy40uPMcywpoM9xMAIhAMHhU+2w8kgXuPMrSuk4VUSKAa+CAgX4qX/Nu84/K1fr","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":21371},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"c5a18cfe60bfd47bfecc79f994afc60d55481fc4","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.2","dependencies":{"pino":"^8.8.0","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.1.8_1709475468132_0.686091531944071","host":"s3://npm-registry-packages"}},"4.1.9":{"name":"@firefly-exchange/kafka-client","version":"4.1.9","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.1.9","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"a9d3ed8a750ffe34b41254085fc8ae9bdd204a12","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.1.9.tgz","fileCount":16,"integrity":"sha512-HI6TaNXbNB/PaD0l3wFi6WAxfjmNCWRXPnlQ1wCGdDEQSlMeykolRDFdU/KmPvj4eIJkvmpZT3MVykdBNT0tLg==","signatures":[{"sig":"MEQCIBLvBZu5zoFqKQDvYExQybns25OK7mYF+ECtJwN6Sy1LAiAXfFgHcm0tF0Kb2IgTjHGg23B3ozThPkG8alheAbT8qA==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":21440},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"d543ce2a2417f3c1abecc6f692955865eef989ac","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.2","dependencies":{"pino":"^8.14.1","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.1.9_1713779579603_0.29236275450406146","host":"s3://npm-registry-packages"}},"4.2.0":{"name":"@firefly-exchange/kafka-client","version":"4.2.0","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.2.0","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"27a23f2ae77320381cee6c82d1360f39b4ff7542","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.2.0.tgz","fileCount":16,"integrity":"sha512-qTLYxQjBiNt9erm4EZZl+a1YkCzxmx89lAt2f2Bsxx9XHdBRtQg6Z2A25xqSt0QjXEaXVxTxxRYJbGbEoXK5aA==","signatures":[{"sig":"MEYCIQC3+QrMIwDAZeiZwBq0swKr4lybk/CahHx9OcoBSUI7/gIhANzr7pskIdDWwzOPRJ02pchOOVf/uhyfZjBR9bkP0iJ3","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":21489},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"bea16c3293bc5710181dd7b4197b2464434cab8f","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.2","dependencies":{"pino":"^8.14.1","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.2.0_1719979185743_0.0736811825853485","host":"s3://npm-registry-packages"}},"4.2.2-alpha.0":{"name":"@firefly-exchange/kafka-client","version":"4.2.2-alpha.0","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.2.2-alpha.0","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"5b807e6092feaf64d2891a1c5712cb47f3245ff3","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.2.2-alpha.0.tgz","fileCount":16,"integrity":"sha512-5aVRXpivzv1ECX9R0kNwlwuq5SPQJXBcUO4njrBD44EllDodQmLDwzZaI/TmZp40HcFN5fv6YAd0snOZgdBbbw==","signatures":[{"sig":"MEUCIBub6SQ58e8CbEQx3VVF0qGq6wVVqJiI15Qv7xPdxaI2AiEAhYdB0mmfzGLsOX7xIifRejqRah2DhDMrMIInxdspwCY=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":23416},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"3f04d13a7332a75ebd88806f1367e4ea8a9b758c","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.6.0","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"18.0.0","dependencies":{"pino":"^8.14.1","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.2.2-alpha.0_1720619296699_0.7661011819136103","host":"s3://npm-registry-packages"}},"4.2.2-alpha.1":{"name":"@firefly-exchange/kafka-client","version":"4.2.2-alpha.1","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.2.2-alpha.1","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"81bff639cc35a80359335918481ec4b21da8099d","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.2.2-alpha.1.tgz","fileCount":16,"integrity":"sha512-jIS6lfskfnvKsb6un7w6/dUg/c2KNthQJjrWUVIw1gxHM651YEUbN8baY1cNKWyVtG3a/avXZjslalJAUAOPAA==","signatures":[{"sig":"MEQCIChx7jrMk4sJa7jn1b0mhiW9V1TgQSwYNj+QOR7kkOiVAiBYSQZLmIQcStyZ6teloxQhYF8WhOsxk8F471LkYNISaw==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":23535},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"3f04d13a7332a75ebd88806f1367e4ea8a9b758c","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.6.0","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"18.0.0","dependencies":{"pino":"^8.14.1","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.2.2-alpha.1_1720796392223_0.6798273703163611","host":"s3://npm-registry-packages"}},"4.2.1":{"name":"@firefly-exchange/kafka-client","version":"4.2.1","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.2.1","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"46eb26cb9b5759d838c7dc429c136bd8363b0dbf","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.2.1.tgz","fileCount":16,"integrity":"sha512-SpMi2hzMNLmYYAIxsFTx6fYSAi4haZdtMEipKn0dGWViabvuXoqStyU+IRx2iLI2TGpU/hj7b2E+bUOKHDN6MA==","signatures":[{"sig":"MEUCIQDlYHjvoibpUCnBdyBKvuQwfDAeP46R70CVDypLNrBHpQIgOXSK0Gv0zwYZnsUbwrUxGYooEe+WsJ4bIiNb/6O4gCA=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":23437},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"14624385f71152706f7b5af015929c1a07f3a951","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.2","dependencies":{"pino":"^8.14.1","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.2.1_1721645626053_0.6749329538089668","host":"s3://npm-registry-packages"}},"4.2.2":{"name":"@firefly-exchange/kafka-client","version":"4.2.2","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.2.2","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"bd84de7d6279d7885e33bc2ab5e12cb2dabc2e41","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.2.2.tgz","fileCount":16,"integrity":"sha512-rt6dZS43mVYmC1CXx7CAf59NH4mZqZQWTIgYXfwOGR9rtVlz/sd02dypF87rXCaoPg8yPbL2CDQ8TMYCMycFNA==","signatures":[{"sig":"MEUCIQDS6sFoXvlO4yreM8c3cjCFYgrD1T7aY54n0/gTPEi5bAIgFNDH+ZvmyXSkUffnr+X/iSUYXMYL2AZhduWd8gAu8GU=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":23552},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"c7c7fb7f17218b574e7e6c242acc4b3cbd1cd507","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.2","dependencies":{"pino":"^8.14.1","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.2.2_1722337927913_0.08864380256113158","host":"s3://npm-registry-packages"}},"4.3.0":{"name":"@firefly-exchange/kafka-client","version":"4.3.0","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.3.0","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"602ef92b5fe1b2140c8d51b7d9fb955f8120d684","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.3.0.tgz","fileCount":16,"integrity":"sha512-NtCCVnBZSbibu66PqudYYFKf+PhjH5EgVeFfQUMsHUl+L+pZai17mwGiFjIUDWWju3glA1/K4ipym2a3sNV2ZQ==","signatures":[{"sig":"MEUCIQCe8nH7jRfC4vpA5Lv1ysBEM9Q91H+4HedKeAWqhk8gjAIgAzNLMaKwO30ZRueoXmnnW7ZVuS8Ti5Vx3IaNV0aVhc0=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":23887},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"651607bf9863284e23592ab2ebb250eefe9f5baf","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.2","dependencies":{"pino":"^8.14.1","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.3.0_1723184524001_0.46431200834271613","host":"s3://npm-registry-packages"}},"4.3.1":{"name":"@firefly-exchange/kafka-client","version":"4.3.1","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.3.1","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"3fc494fdde54e943f1e16e1e787f9e135079135b","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.3.1.tgz","fileCount":16,"integrity":"sha512-RkpKLYDCIcVNH+JzqQAJeRhx1c4qdQ2WyZHpvSVNRgtsSerbCtmgTzrAeU9KcGbt+scj9OqXglgfu0G0FSdMmQ==","signatures":[{"sig":"MEUCIAT/gzXKAZmNjs/kMBdHmwIHJ3cOIaX2CtXGtBbaOWUcAiEA0VAGzNo2DqiBEY2r4bFZhaqPxHa5dQuY52mDVRuOq28=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":24412},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"59b07ee69d390fc484f5b457b38560d0a49adf4a","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.2","dependencies":{"pino":"^8.14.1","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.3.1_1741873198250_0.9476636034991162","host":"s3://npm-registry-packages-npm-production"}},"4.3.2":{"name":"@firefly-exchange/kafka-client","version":"4.3.2","keywords":[],"author":"","license":"ISC","_id":"@firefly-exchange/kafka-client@4.3.2","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"dist":{"shasum":"7b2391d69084e8a3bc62de0c1ddde6bb4d77833e","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.3.2.tgz","fileCount":16,"integrity":"sha512-VjaI8gxva7rw/koP5w1cvmP06ox2JhKG1Qbm2uekazVj+zeddHiHYsNbeeOcCpjrOXRUr2wPzhYgIjnPEaWaKA==","signatures":[{"sig":"MEUCIQC1US0vBRDan6TJeH6gyLJjz4coX7rSgjCvZaVRptIx2wIgbU22AMXIWWd8g1enG9RTnXnUzKBiWvtMHVGaeHiJazs=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":24918},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"845b956900880f4c84e7a32b6ec1c9469e6a39ee","scripts":{"build":"rm -rf dist/ && tsc","debug":"yarn debug","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d","ci:code-style":"yarn eslint .","teardown:kafka":"docker-compose -f local/docker-compose.yml down","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","ci:code-formatting":"yarn pretty-quick --check"},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"repository":{"url":"git+https://github.com/fireflyprotocol/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","directories":{},"_nodeVersion":"16.20.2","dependencies":{"pino":"^8.14.1","dotenv":"^16.0.3","kafkajs":"^2.2.4","ts-mocha":"^10.0.0","pino-http":"^8.3.2","typescript":"^4.3.5","dotenv-parse-variables":"^2.0.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.3.7","husky":"^7.0.0","mocha":"^10.2.0","eslint":"^7.32.0","ts-node":"^10.8.1","prettier":"^2.6.2","@types/chai":"^4.3.4","@types/node":"^16.11.7","@types/mocha":"^10.0.1","pretty-quick":"^3.1.3","@typescript-eslint/parser":"^4.32.0","@typescript-eslint/eslint-plugin":"^4.32.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_4.3.2_1745595524337_0.6082863928146733","host":"s3://npm-registry-packages-npm-production"}},"4.4.0":{"name":"@firefly-exchange/kafka-client","repository":{"type":"git","url":"git+https://github.com/fireflyprotocol/kafka-client.git"},"version":"4.4.0","description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"debug":"yarn debug","build":"rm -rf dist/ && tsc","ci:code-formatting":"yarn pretty-quick --check","ci:code-style":"yarn eslint .","prepare":"husky install","setup:kafka":"docker-compose -f local/docker-compose.yml up -d && timeout 180 sh -c 'until docker-compose -f local/docker-compose.yml exec -T kafka kafka-broker-api-versions --bootstrap-server localhost:9092 >/dev/null 2>&1; do sleep 2; done'","teardown:kafka":"docker-compose -f local/docker-compose.yml down","test:integration":"mocha --no-timeout --exit  -r ts-node/register 'tests/integration.test.ts'","run:integration":"yarn setup:kafka && yarn test:integration && yarn teardown:kafka"},"devDependencies":{"@types/chai":"^4.3.4","@types/mocha":"^10.0.1","@types/node":"^16.11.7","@typescript-eslint/eslint-plugin":"^4.32.0","@typescript-eslint/parser":"^4.32.0","chai":"^4.3.7","eslint":"^7.32.0","husky":"^7.0.0","mocha":"^10.2.0","prettier":"^2.6.2","pretty-quick":"^3.1.3","ts-node":"^10.8.1"},"dependencies":{"dotenv":"^16.0.3","dotenv-parse-variables":"^2.0.0","kafkajs":"^2.2.4","kafkajs-lz4":"^1.2.1","kafkajs-snappy":"^1.1.0","pino":"^8.14.1","pino-http":"^8.3.2","ts-mocha":"^10.0.0","typescript":"^4.3.5"},"publishConfig":{"access":"public"},"keywords":[],"author":"","license":"ISC","gitHead":"f94646251dbc024b991c7a06d8ba14dcba4ef1e5","bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"homepage":"https://github.com/fireflyprotocol/kafka-client#readme","_id":"@firefly-exchange/kafka-client@4.4.0","_nodeVersion":"16.20.2","_npmVersion":"8.19.4","dist":{"integrity":"sha512-OTaidmjQVh8fMEpq/3vObeuuqPuYEdxOaCs9QQi00Wudz6j+4m8/SiJggiHq/wLqQf7zQQzB615r/3qZ6le87A==","shasum":"e87da1fd08a9b83c57b56da7be1a0480a930efd5","tarball":"https://registry.npmjs.org/@firefly-exchange/kafka-client/-/kafka-client-4.4.0.tgz","fileCount":18,"unpackedSize":29162,"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEYCIQC1n1M1rEhBzvmGQKWRBubagqaq5R+heB9zoTgeGsjq9QIhAIVyj0QZ3E0rQCQ1pqB9Qnxq/laO583WsHd0HnHina2r"}]},"_npmUser":{"name":"fireflyorg","email":"npm@firefly.exchange"},"directories":{},"maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/kafka-client_4.4.0_1779913224969_0.4634363439878384"},"_hasShrinkwrap":false}},"time":{"created":"2023-02-03T06:42:31.857Z","modified":"2026-05-27T20:20:25.278Z","1.0.0":"2023-02-03T06:42:32.207Z","1.0.1":"2023-02-18T09:46:56.493Z","2.0.0":"2023-05-19T07:38:19.431Z","2.0.1":"2023-05-20T15:46:10.075Z","2.0.2":"2023-05-23T07:25:22.643Z","2.0.3":"2023-05-25T09:28:44.272Z","2.0.4":"2023-05-28T14:51:38.828Z","2.0.5":"2023-05-29T06:26:58.509Z","2.0.6":"2023-05-29T07:22:54.749Z","2.0.7":"2023-05-29T10:01:07.501Z","2.0.8":"2023-06-01T08:28:48.670Z","2.0.9":"2023-06-05T04:51:10.454Z","2.0.10":"2023-06-06T12:15:42.950Z","2.0.11":"2023-06-08T08:49:13.205Z","3.0.0":"2023-07-06T11:17:43.268Z","4.0.0":"2023-07-06T18:31:17.588Z","4.1.0":"2023-07-09T16:30:57.254Z","4.1.1":"2023-07-14T17:27:19.113Z","4.1.2":"2023-07-27T09:15:33.029Z","4.1.3":"2023-07-30T15:00:55.074Z","4.1.4":"2023-07-31T11:17:44.773Z","4.1.5":"2023-08-30T12:30:16.941Z","4.1.6":"2023-09-27T19:13:00.620Z","4.1.7":"2023-11-24T13:10:32.587Z","4.1.8":"2024-03-03T14:17:48.271Z","4.1.9":"2024-04-22T09:52:59.766Z","4.2.0":"2024-07-03T03:59:45.884Z","4.2.2-alpha.0":"2024-07-10T13:48:16.877Z","4.2.2-alpha.1":"2024-07-12T14:59:52.345Z","4.2.1":"2024-07-22T10:53:46.210Z","4.2.2":"2024-07-30T11:12:08.072Z","4.3.0":"2024-08-09T06:22:04.158Z","4.3.1":"2025-03-13T13:39:58.396Z","4.3.2":"2025-04-25T15:38:44.500Z","4.4.0":"2026-05-27T20:20:25.137Z"},"bugs":{"url":"https://github.com/fireflyprotocol/kafka-client/issues"},"license":"ISC","homepage":"https://github.com/fireflyprotocol/kafka-client#readme","keywords":[],"repository":{"type":"git","url":"git+https://github.com/fireflyprotocol/kafka-client.git"},"description":"The Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages from topics.","maintainers":[{"name":"fireflyorg","email":"npm@firefly.exchange"}],"readme":"# kafka-client\n\nThe Kafka Client library is a tiny wrapper over kafka.js to produce and consume messages\nfrom topics.\n\n# Usage\n\n## Installation\n\nInstall kafka-client using yarn:\n\n```bash\nyarn add @firefly-exchange/kafka-client\n```\n\n## Message compression\n\nImporting `@firefly-exchange/kafka-client` registers compression codecs into\n`kafkajs.CompressionCodecs` as a side effect, so consumers and producers can\nread and write messages in the org's standard compression algorithms without\nextra setup:\n\n| Algorithm | Source              | Notes                                            |\n| --------- | ------------------- | ------------------------------------------------ |\n| gzip      | `kafkajs` built-in  | Always available.                                |\n| lz4       | `kafkajs-lz4`       | Unblocks turning on compression for the matching-engine events producer — see note below. |\n| snappy    | `kafkajs-snappy`    | Available as a freebie; not currently in heavy use. |\n| zstd      | _not registered_    | Pending — see \"zstd\" note below.                 |\n\n**Why lz4 specifically.** In pro-mono, the `matching-engine-v3` events producer\nthat publishes `pro-trading-engine.events`\n(`rust/service/matching-engine-v3/src/boundary/kafka/producer.rs:153`) runs\nuncompressed today, with the comment on line 176:\n\n> `// If our TS clients ever upgrade, we can enable compression here for even better performance.`\n\nThat comment is exactly what this codec registration resolves. Once consumers\nof this wrapper have picked up `^4.4.0`, the events producer can set\n`compression.type=lz4` and TS consumers will decode it transparently.\n\n**zstd.** The `@kafkajs/zstd` codec wraps the native `cppzst` module, which\nrequires install scripts to build the native binary. Services that run with\n`enableScripts: false` (supply-chain hardening) cannot install it. A separate\nfollow-up will add zstd once a pure-JS/WASM zstd codec is in place or an\nagreed install-scripts exception path exists.\n\n**lz4 install-scripts caveat.** `kafkajs-lz4@1.x` depends on the `lz4` Node\npackage, which builds a native binary via `node-gyp` at install time. If your\nservice runs with `enableScripts: false`, you'll need an explicit\nyarnrc exception for `lz4` (and its build-tooling deps `nan`, `node-gyp`).\nAlternatively, the `kafkajs-lz4@2.x` line uses pure-WASM `lz4-asm` and\nneeds no install scripts but is currently a beta release.\n\n## Publishing a message\n\nTo publish a message first create a new instance of the `KafkaProducer` class using its\nstatic `create` method. The method accepts the following parameters\n\n-   `bootstrapServers: string` a comma separated list of Kafka nodes\n-   `logger: pino.Logger` supply your customised pino logger function here\n-   `connectionTimeout: number` (optional) connection timeout in ms, default to 10000ms =\n    10s\n-   `clientId: string` (optional) kafka client id, default to anonymous-client\n\ncode example:\n\n```js\nkafkaProducer = KafkaProducer.create({\n    bootstrapServers: \"localhost:9092,localhost:9093\",\n    logger: pino()\n});\n```\n\nNow to send message, call use send method. It accepts the following parameters\n\n-   `payload: any` payload to publish to topic\n-   `topic: string` name of topic to publish data to\n-   `key: string` (optional) partition key\n-   `acks: int` ack mode, by default is set to -1 (In kafkajs -1 = ALL)\n\n```js\nawait kafkaProducer.send({\n    payload: payload,\n    topic: topic,\n    key: \"order-hash-1\", // optional\n    acks: -1 // optional\n});\n```\n\nNOTE: To read about kafka ack please refer\nhttps://betterprogramming.pub/kafka-acks-explained-c0515b3b707e\n\n## Consuming a message\n\nNow to create a consumer to consume messages from a topic:\n\n```js\nconst consumer = await KafkaConsumer.create(messageBrokerURL);\nawait consumer.consumeTopic(topicName, callback);\nawait consumer.stop();\n```\n\nThere are two concepts in Kafka autocommit and manual commit, autocommit means that once\nconsumer have given you the messages it means its done, consumer dont care if your message\nis processed sucessfully on your end or not. However on manual commit, you specify after\nprocessing that yes you have received the message to kafka.\n\nhow to specify it here, Note that by default AUTOCOMMIT IS TRUE. For autocommit you can\nuse this approach\n\n```js\nkafkaConsumer = await KafkaConsumer.create({\n      bootstrapServers: broker,\n      logger: logger,\n      consumerGroupId: consumerGroup,\n      autoCommit: true\n});\n// The first argument is topic name, second argument is the fromBegining=true or false. the third argument is the callback func\nawait consumer.consumeTopic(topicName,true ,callback);\nawait consumer.stop();\n```\n\nfor using manual commit, you can use this approach:\n\n```js\nkafkaConsumer = await KafkaConsumer.create({\n      bootstrapServers: broker,\n      logger: logger,\n      consumerGroupId: consumerGroup,\n      autoCommit: false\n});\n// The first argument is topic name, second argument is the fromBegining=true or false. the third argument is the callback func\nkafkaConsumer.consumeTopic(topic,true, async function (msg) {\n      // Do some processing\n\n      // once processing is done then commit the message\n      // commit the message\n      await kafkaConsumer.commit({\n            topic: topic,\n            partition: msg.partition,\n            offset: msg.offset\n      });\n});\nawait consumer.stop();\n```\n\nThe consumeTopic message run the handlerFunction with an await meaning that it wont\nprocess next message until one is processed. If you DO not want that then you can use this\napproach.\n\n```js\nkafkaConsumer.consumeTopicAsync(topic,true, async function (msg) {\n      // Do some processing\n\n      // once processing is done then commit the message\n      // commit the message\n      await kafkaConsumer.commit({\n            topic: topic,\n            partition: msg.partition,\n            offset: msg.offset\n      });\n});\nawait consumer.stop();\n```\n\nPlease also note that in manual commit, the code will commit after your callback function\nis finished.\n","readmeFilename":"README.md"}