{"_id":"@awsmag/power-msk","_rev":"19-2e1ea047b6a46857d1c62356e1836cf4","name":"@awsmag/power-msk","dist-tags":{"latest":"2.2.2"},"versions":{"1.0.0":{"name":"@awsmag/power-msk","version":"1.0.0","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@1.0.0","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"1bf515ff61a4ad943aeb1b33dcc45bf407a9a8d3","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-1.0.0.tgz","fileCount":8,"integrity":"sha512-IuKGhXTbmneJfcrN+vehxAgTsG2xIZ90Sz8wAozEhinbhsSyhBVLI2/+g0YMw/uaT8OumUWyLRTDYj6kor2t+g==","signatures":[{"sig":"MEUCIQCzLgrUDB6Q6PJjU/zXv+8dvWht+Ubr0uM1dAWE28VaJwIgW3QbbW2J657eB/SyWuwszRcmgMmW9MFELlb1LK4nnxw=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":312215},"main":"dist/index.js","types":"dist/types","gitHead":"3670c35abb67f40f0a4fc624633e6480e7f11b3f","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"10.2.5","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"18.17.1","dependencies":{"kafkajs":"^2.2.4"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","eslint":"^8.56.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.1.1","@types/koa":"^2.13.12","typescript":"^5.3.3","@types/node":"^20.10.5","@types/mocha":"^10.0.6","tsconfig-paths":"^4.2.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11","@typescript-eslint/eslint-plugin":"^6.16.0"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_1.0.0_1703915213508_0.8142462815092386","host":"s3://npm-registry-packages"}},"1.0.1":{"name":"@awsmag/power-msk","version":"1.0.1","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@1.0.1","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"e89341803c365a1fec0f310c24ba1f1e89ae8bc7","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-1.0.1.tgz","fileCount":8,"integrity":"sha512-bqoCpfBUj6k4z6KuZB6V9r1FL2BLhO4gR7Ei7OUgdUk8Us/9cqenkDEZADB0mmdqD0XEfzNZH4OkzSK98JzctQ==","signatures":[{"sig":"MEQCIEhFMzPDZbKAv0tc/7xjq8Prs4GxZew5UXxkyN6PVDyBAiBR6wwAaCXkJKx0QoSDeMZPlq11DGd+Lm/DvxuxE7F5aw==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":312255},"main":"dist/index.js","types":"dist/types","gitHead":"5f8e8292ccfebbe29761314a10184df6f07d70e9","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"10.2.5","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"18.17.1","dependencies":{"kafkajs":"^2.2.4"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","eslint":"^8.56.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.1.1","@types/koa":"^2.13.12","typescript":"^5.3.3","@types/node":"^20.10.5","@types/mocha":"^10.0.6","tsconfig-paths":"^4.2.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11","@typescript-eslint/eslint-plugin":"^6.16.0"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_1.0.1_1703922280214_0.12828393350357703","host":"s3://npm-registry-packages"}},"1.0.2":{"name":"@awsmag/power-msk","version":"1.0.2","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@1.0.2","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"3f4829c74bb115241cb4ec0b210a4d4093247f42","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-1.0.2.tgz","fileCount":8,"integrity":"sha512-vhKuvLpkGQAYj7YE+y7YD7NN90J/RKuqqqvMguBRWXpPtJTlLikFaduDIlshVshgbzVKXLgCfqYYMbOksqkoEQ==","signatures":[{"sig":"MEYCIQCzEljEMmFLTy8a2VfYVLHGHzWNS6ko1uwUkzLuxmsy+AIhAOzx6hNZYOdgc+ZO7TJU8xxoJNZzeRfRSiGU7l5ZWFcW","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":312255},"main":"dist/index.js","types":"dist/types","gitHead":"38a571b4b321963b8989b29f8e38a8d4432ec2d2","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"10.2.5","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"18.17.1","dependencies":{"kafkajs":"^2.2.4"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","eslint":"^8.56.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.1.1","@types/koa":"^2.13.12","typescript":"^5.3.3","@types/node":"^20.10.5","@types/mocha":"^10.0.6","tsconfig-paths":"^4.2.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11","@typescript-eslint/eslint-plugin":"^6.16.0"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_1.0.2_1703922600723_0.1132581220025295","host":"s3://npm-registry-packages"}},"1.0.3":{"name":"@awsmag/power-msk","version":"1.0.3","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@1.0.3","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"507793b3eb9ad77e1cb2dbece9a490008dc6b491","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-1.0.3.tgz","fileCount":8,"integrity":"sha512-vA24Zx6E07+/yUJmuU7uOrp4aCKAtvPUYVFVnWBxBu2amyvY8b/hzHjtQWl7DHNoNnH7KgcbNbR2Se8yqEg5FA==","signatures":[{"sig":"MEUCIDAGpvnRnAnnx3K3fKaeBqoEaXwHeKbUKNbkKESZSYGiAiEAnhhCdru8y+kYNOp3AZGvww/6187n+I8RSm3mC1xnFrE=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":312246},"main":"dist/index.js","types":"dist/types","gitHead":"0e830432aedf48293e4171c0a61736a2c1d3cef3","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"10.2.5","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"18.17.1","dependencies":{"kafkajs":"^2.2.4"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","eslint":"^8.56.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.1.1","@types/koa":"^2.13.12","typescript":"^5.3.3","@types/node":"^20.10.5","@types/mocha":"^10.0.6","tsconfig-paths":"^4.2.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11","@typescript-eslint/eslint-plugin":"^6.16.0"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_1.0.3_1703922713113_0.8693966941886435","host":"s3://npm-registry-packages"}},"1.1.0":{"name":"@awsmag/power-msk","version":"1.1.0","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@1.1.0","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"510a1dac7767725f44b4ba7716a46a955e53b53b","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-1.1.0.tgz","fileCount":8,"integrity":"sha512-n98wwkWIioVQK4sICmAVsYfZsdhEN/1WGUHfiybedrAKmJ42NcrlaAAZauWuW7ozBcZy8nzAHXL3NPTh3UqNyQ==","signatures":[{"sig":"MEUCICTVP9RlGX+Sfb1Lk8QXCziNQlsoZbSEklWCfeyBeKN8AiEAsrIIKfVqOnYCsV92npfKwFpB9SXAroDNgYV0LYYySGc=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":312246},"main":"dist/index.js","types":"dist/types","gitHead":"268ce00a2e107d84d007a0bbda6535c277f4f073","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"10.2.5","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"18.17.1","dependencies":{"kafkajs":"^2.2.4"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","eslint":"^8.56.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.1.1","@types/koa":"^2.13.12","typescript":"^5.3.3","@types/node":"^20.10.5","@types/mocha":"^10.0.6","tsconfig-paths":"^4.2.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11","@typescript-eslint/eslint-plugin":"^6.16.0"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_1.1.0_1703922895039_0.04458057438034935","host":"s3://npm-registry-packages"}},"1.1.1":{"name":"@awsmag/power-msk","version":"1.1.1","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@1.1.1","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"dde44c5e4c45b0f7cd10a454a9224e3db7fef823","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-1.1.1.tgz","fileCount":8,"integrity":"sha512-1Jprzc9JV6kZwBXKfEjjGBjAdBCIRXtGMDxpO8MLbaOaJsln97/FqlCW7hhekIXOFRdxRAi0dbkRLufGgzkxmQ==","signatures":[{"sig":"MEYCIQCzjR0QerrZ4NMDfX4t9Pcf90ZT0xnhk4Vq57T7EazbUgIhALmjQCRobDEhRBnx8GSAH01GFknZiITmMWNXdsLhpJeg","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":312259},"main":"dist/index.js","types":"dist/types","gitHead":"cbe0f6c5d6f8407cbf657ea97fdaa947f10ffffa","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc","prepublishOnly":"npm run build"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"10.2.5","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"18.17.1","dependencies":{"kafkajs":"^2.2.4"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","eslint":"^8.56.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.1.1","@types/koa":"^2.13.12","typescript":"^5.3.3","@types/node":"^20.10.5","@types/mocha":"^10.0.6","tsconfig-paths":"^4.2.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11","@typescript-eslint/eslint-plugin":"^6.16.0"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_1.1.1_1703933186098_0.6657497256747211","host":"s3://npm-registry-packages"}},"1.2.0":{"name":"@awsmag/power-msk","version":"1.2.0","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@1.2.0","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"4cd1137b1777c4a81b0bb03007a5e36fec02d422","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-1.2.0.tgz","fileCount":8,"integrity":"sha512-fVw57YVP45JI2952nzZ7djsbsJUp3TLNHnS3v95OunOcagxUU6s7p5xbCBiP6tV3xjvD1ZDkSGnQ5ZojyNcR0A==","signatures":[{"sig":"MEUCIGHD+QC+3GMKyGxBEjpLMWjW7+eV0nIx2cqDq6zCgmqBAiEAx1J8BcUnX7e+U8zjRV3j+bwk1eTOo8S+sviDUOyY81I=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":312462},"main":"dist/index.js","types":"dist/types","gitHead":"83b602b5a7551eb9bc73e26d709326207abeb7d2","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc","prepublishOnly":"npm run build"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"10.4.0","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"18.17.1","dependencies":{"kafkajs":"^2.2.4"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","eslint":"^8.56.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.1.1","@types/koa":"^2.13.12","typescript":"^5.3.3","@types/node":"^20.10.5","@types/mocha":"^10.0.6","tsconfig-paths":"^4.2.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11","@typescript-eslint/eslint-plugin":"^6.16.0"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_1.2.0_1708765190832_0.20998402868295374","host":"s3://npm-registry-packages"}},"1.3.0":{"name":"@awsmag/power-msk","version":"1.3.0","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@1.3.0","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"443822b51f7e46228fe4ef7e2a98aa968b1bf90e","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-1.3.0.tgz","fileCount":8,"integrity":"sha512-jnw6TRPHSlElbks2hYTVNuzGFELUXER72BsxCWdmbuFj2a8so+73AV4SNJgItGGOIlWRFlnnEw0fG0HL2lY1dA==","signatures":[{"sig":"MEUCIEDnB+/3sN7brVptSozEjzWFf5QcLDL5tvbHM1FYO/73AiEAg9fFKQ0ChU7gjSHot/e8SdH32e7+I59wlVZL0ehvvS0=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":312588},"main":"dist/index.js","types":"dist/types","gitHead":"fb58d0ff43c62dc1a82d2a576f7c810ebf3fb233","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc","prepublishOnly":"npm run build"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"10.4.0","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"18.17.1","dependencies":{"kafkajs":"^2.2.4"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","eslint":"^8.56.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.1.1","@types/koa":"^2.13.12","typescript":"^5.3.3","@types/node":"^20.10.5","@types/mocha":"^10.0.6","tsconfig-paths":"^4.2.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11","@typescript-eslint/eslint-plugin":"^6.16.0"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_1.3.0_1708766133135_0.6180990953281189","host":"s3://npm-registry-packages"}},"1.3.1":{"name":"@awsmag/power-msk","version":"1.3.1","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@1.3.1","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"bb9c10398ab39a79ec990acb17fe3ef8e5193bfa","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-1.3.1.tgz","fileCount":8,"integrity":"sha512-ucedLs7vG819dDsn7Ept4Eg+SIjre8qjIew90UtNVj0D47alY40FyJ/zC8LTHzwWqy0F5BoXe8+lSEbg1frRkg==","signatures":[{"sig":"MEUCIQCXiZpX7OHbJrr5YEjoqwoFnuCgjpNgETg9LR0dhcrstgIgKE4shT04JORqA1eG2jE+jLG+cZgq0QE7aft9/+zduEI=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":312582},"main":"dist/index.js","types":"dist/types","gitHead":"23ea95ebd7fbf91dc8d9905425e34acec0951668","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc","prepublishOnly":"npm run build"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"10.5.0","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"18.17.1","dependencies":{"kafkajs":"^2.2.4"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","eslint":"^8.56.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.1.1","@types/koa":"^2.13.12","typescript":"^5.3.3","@types/node":"^20.10.5","@types/mocha":"^10.0.6","tsconfig-paths":"^4.2.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11","@typescript-eslint/eslint-plugin":"^6.16.0"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_1.3.1_1714465311929_0.8162724950718949","host":"s3://npm-registry-packages"}},"1.4.0":{"name":"@awsmag/power-msk","version":"1.4.0","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@1.4.0","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"a8fd6a50e57f5faaa15fc1c0700df2255d3707e0","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-1.4.0.tgz","fileCount":8,"integrity":"sha512-imWbwpNTYevgOPYi/g6qq8Du6k8Foox8kP+pJpHkZJJJUkTw5LeUA2IKWC500LH9cJa1RBP5vTJceZJv86Icrw==","signatures":[{"sig":"MEUCIFXNnc6iBWrsNqTpzd6Xit7WNn83vM88lK8ur3yUMXlGAiEAowVH6am8n2N91+ZzNT8INMZCUL4I2wx5EdvkT7oALVs=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":312905},"main":"dist/index.js","types":"dist/types","gitHead":"bc1ce26581d8753d67b756f282dbb7b5a25c0abb","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc","prepublishOnly":"npm run build"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"10.7.0","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"18.17.1","dependencies":{"kafkajs":"^2.2.4"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","eslint":"^8.56.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.1.1","@types/koa":"^2.13.12","typescript":"^5.3.3","@types/node":"^20.10.5","@types/mocha":"^10.0.6","tsconfig-paths":"^4.2.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11","@typescript-eslint/eslint-plugin":"^6.16.0"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_1.4.0_1714884924851_0.7295052408567677","host":"s3://npm-registry-packages"}},"1.5.0":{"name":"@awsmag/power-msk","version":"1.5.0","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@1.5.0","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"e79cc41826323319d5d22712034822528062fa2d","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-1.5.0.tgz","fileCount":8,"integrity":"sha512-ehayAiEvOMPRU+2uUCnf+oQaLHq20lGjaS5IGkOvla8VlZCDSxXDehWqXhVNhLxJtsmz7uYRYInZiz2JMnFheg==","signatures":[{"sig":"MEYCIQC3ygaHC92DMqYd3rEPFu+awdSRnWApM5/9faNLVLalwQIhAOpfRwG53skFmUQ1EuywnonbGEV1uL0qJxAkGIYUj2aU","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":312847},"main":"dist/index.js","types":"dist/types","gitHead":"1fdb39b34704ad72b79e36bb8b6a97609d4fe209","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc","prepublishOnly":"npm run build"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"10.8.1","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"18.17.1","dependencies":{"kafkajs":"^2.2.4"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","eslint":"^8.56.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.1.1","@types/koa":"^2.13.12","typescript":"^5.3.3","@types/node":"^20.10.5","@types/mocha":"^10.0.6","tsconfig-paths":"^4.2.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11","@typescript-eslint/eslint-plugin":"^6.16.0"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_1.5.0_1717156038494_0.5463298615984435","host":"s3://npm-registry-packages"}},"1.6.0":{"name":"@awsmag/power-msk","version":"1.6.0","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@1.6.0","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"e257d854932685f2d3728556aa233a99d5b89222","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-1.6.0.tgz","fileCount":8,"integrity":"sha512-krkXi+yzP7R1nt8hs+5YSFsVVeJH23FGridq4kcEDBbC7z1bYE3sUD+nDH3psJblrHpIVLP9sPQibtGS7spuKQ==","signatures":[{"sig":"MEUCIEjtVwvnEQGu7dePG4NpDKLpwJJDE1/+KhHtiz2Sk4YzAiEAnMFsp/eIGdmgr0m8fLd4FId60qaMy6zQC3PF3It4Afk=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":312893},"main":"dist/index.js","types":"dist/types","gitHead":"faa06c35986dcbb785c22d4040925308f972daf9","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc","prepublishOnly":"npm run build"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"10.9.0","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"20.16.0","dependencies":{"kafkajs":"^2.2.4"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","eslint":"^8.56.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.1.1","@types/koa":"^2.13.12","typescript":"^5.3.3","@types/node":"^20.10.5","@types/mocha":"^10.0.6","tsconfig-paths":"^4.2.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11","@typescript-eslint/eslint-plugin":"^6.16.0"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_1.6.0_1730262164722_0.04201839713147448","host":"s3://npm-registry-packages"}},"1.7.0":{"name":"@awsmag/power-msk","version":"1.7.0","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@1.7.0","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"ec1594c6cf1f37f30ec009c0c6a2c3cab3b1cb58","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-1.7.0.tgz","fileCount":8,"integrity":"sha512-olckn0iTScj9ULDau6YrHSsYRWzsfVrU6UxcmyLo+/hcb/gsz5UuobYxMF968E2UF9JbcxePGjD0XjJN1BLIQw==","signatures":[{"sig":"MEQCIAxgw+MNcjo87XnHjq0H0EhaCKJ5LRLG/P4/WVJbkMneAiBBag8Faa0CVywH5LhPhRQx5qZpA4Du5MJb17K3x5HSuw==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":881609},"main":"dist/index.js","types":"dist/types","gitHead":"57ce7d039060f2f03e5754cde53740b94360b8f0","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc","prepublishOnly":"npm run build"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"10.9.0","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"20.16.0","dependencies":{"kafkajs":"^2.2.4","@jm18457/kafkajs-msk-iam-authentication-mechanism":"^3.1.2"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.1.1","@eslint/js":"^9.13.0","@types/koa":"^2.13.12","typescript":"^5.6.3","@types/node":"^20.10.5","@types/mocha":"^10.0.6","tsconfig-paths":"^4.2.0","@types/eslint__js":"^8.42.3","typescript-eslint":"^8.12.2","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_1.7.0_1730385888645_0.11757739524386857","host":"s3://npm-registry-packages"}},"2.0.0":{"name":"@awsmag/power-msk","version":"2.0.0","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@2.0.0","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"d8454519e63563052bf027cf30a2494240057fbb","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-2.0.0.tgz","fileCount":9,"integrity":"sha512-7LVD5zSIBnHclabf63GhguIbY+vZF89/kqwszSKCJwOFajf++fNJJNvcZlK9m2rusCGDePXdclitmC0gB4zYdA==","signatures":[{"sig":"MEYCIQCSRhtmzd634ouzMyGssVrgFp7d0AhbznqHlSmzJ3kUIQIhAKUZOgWRnyhAus+q246Pe8ZtOqnza1cIjUxq1fhhDueU","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":317209},"main":"dist/index.js","types":"dist/types","gitHead":"20bd5f7835399ae954f0abd37528fc6a154b4cda","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc","prepublishOnly":"npm run build"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"11.5.2","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"20.18.1","dependencies":{"kafkajs":"^2.2.4","@jm18457/kafkajs-msk-iam-authentication-mechanism":"^3.1.2"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.6.2","@eslint/js":"^9.33.0","@types/koa":"^2.13.12","typescript":"^5.9.2","@types/node":"^20.10.5","@types/mocha":"^10.0.10","tsconfig-paths":"^4.2.0","@types/eslint__js":"^8.42.3","typescript-eslint":"^8.40.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_2.0.0_1755925648542_0.12744463305899112","host":"s3://npm-registry-packages-npm-production"}},"2.0.1":{"name":"@awsmag/power-msk","version":"2.0.1","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@2.0.1","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"f2cdb3fcd34cc8deed979ba8eabc340d79f67aca","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-2.0.1.tgz","fileCount":9,"integrity":"sha512-ToJ0qcXlSgMnJRN5XDggh+T5mxFqzEU1Gkf/+a7q1qR08OquFfhDuDOj46V/rledOCJsa0JATeT7TAI8T8bJ1w==","signatures":[{"sig":"MEYCIQC/03aKlr1pmJ/PFPTA4i3Mfm8h60Cud1QgGegRr5AOJwIhANN5fCdlL6ToTxx9Jd8IZswx92iiO1VtgknLxFsCEjn8","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":317348},"main":"dist/index.js","types":"dist/types","gitHead":"6982a544394872ddb8ba714a551f4ce6af99b523","scripts":{"lint":"eslint .","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc","prepublishOnly":"npm run build"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"11.5.2","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"20.18.1","dependencies":{"kafkajs":"^2.2.4","@jm18457/kafkajs-msk-iam-authentication-mechanism":"^3.1.2"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","mocha":"^10.2.0","esbuild":"^0.19.10","ts-node":"^10.9.2","prettier":"^3.6.2","@eslint/js":"^9.33.0","@types/koa":"^2.13.12","typescript":"^5.9.2","@types/node":"^20.10.5","@types/mocha":"^10.0.10","tsconfig-paths":"^4.2.0","@types/eslint__js":"^8.42.3","typescript-eslint":"^8.40.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_2.0.1_1756190489327_0.40588712420939066","host":"s3://npm-registry-packages-npm-production"}},"2.1.0":{"name":"@awsmag/power-msk","version":"2.1.0","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@2.1.0","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"0460ae44bb850f568e8560d68acae416ed308a3f","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-2.1.0.tgz","fileCount":19,"integrity":"sha512-wgJNJ5gatKkMcgpO0N4EM1PBZ5xnhZpubHTPBkCu2yedc//6SOKaia6VW5MT6zfbd1rknCv13Yb21WdqnuyCRg==","signatures":[{"sig":"MEQCIENC+LQImo4ADXUL5iXbaOLXSewtneSQW7U46hna9wp+AiB6MJJejKJz8YGdYFMpSp7a+a1j+W+LTpw3pVO1u/3y+Q==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":400115},"main":"dist/index.js","types":"dist/types","gitHead":"cf8c78e97673dbd8e409c55a72b864b5f1805d94","scripts":{"lint":"eslint .","test":"mocha -r esbuild-register \"test/**/*.spec.ts\" --exit","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc","test:consumer":"BROKERS=localhost:9092 ts-node --transpile-only integ/consumerdebug.ts --topic=test --group=g1 --fromBeginning","test:producer":"ts-node --transpile-only integ/producerdebug.ts","prepublishOnly":"npm run build"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"11.5.2","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"20.18.1","dependencies":{"pino":"^9.9.0","kafkajs":"^2.2.4","@jm18457/kafkajs-msk-iam-authentication-mechanism":"^3.1.2"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","chai":"^6.0.1","mocha":"^10.8.2","sinon":"^21.0.0","esbuild":"^0.19.12","ts-node":"^10.9.2","prettier":"^3.6.2","supertest":"^7.1.4","@eslint/js":"^9.33.0","@types/koa":"^2.13.12","typescript":"^5.9.2","@types/chai":"^5.2.2","@types/node":"^20.10.5","@types/mocha":"^10.0.10","@types/sinon":"^17.0.4","tsconfig-paths":"^4.2.0","@types/supertest":"^6.0.3","esbuild-register":"^3.6.0","@types/eslint__js":"^8.42.3","typescript-eslint":"^8.40.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_2.1.0_1756301722147_0.9827218862835057","host":"s3://npm-registry-packages-npm-production"}},"2.2.0":{"name":"@awsmag/power-msk","version":"2.2.0","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@2.2.0","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"15d1ea00f0f4a194252f9fa6287a8d941cbff990","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-2.2.0.tgz","fileCount":19,"integrity":"sha512-GbbxxH/ZgeEL8RQ7j/R6ktObzQs7SWzPWCrIx6sIb7VOFmdRbSA2jDHfP+wdwXKI73Gsy0/IbZk5+LJFl7euqg==","signatures":[{"sig":"MEYCIQD1C1+cJTdYZRqeMcUHkK3f11H5X2vp6/rbmHAWKx5mJQIhAIcQPDg1WvA/VFfX0qxaibNauHjqYAGqfXZpLaNwGF2h","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":400896},"main":"dist/index.js","types":"dist/types","gitHead":"aa7b8eeb3e96aba346d739fdf323fe8266dc50ce","scripts":{"lint":"eslint .","test":"mocha -r esbuild-register \"test/**/*.spec.ts\" --exit","build":"node build.js","prettier":"prettier --write .","postbuild":"tsc","test:consumer":"BROKERS=localhost:9092 ts-node --transpile-only integ/consumerdebug.ts --topic=test --group=g1 --fromBeginning","test:producer":"ts-node --transpile-only integ/producerdebug.ts","prepublishOnly":"npm run build"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"11.5.2","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"20.18.1","dependencies":{"pino":"^9.9.0","kafkajs":"^2.2.4","@jm18457/kafkajs-msk-iam-authentication-mechanism":"^3.1.2"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","chai":"^6.0.1","mocha":"^10.8.2","sinon":"^21.0.0","esbuild":"^0.19.12","ts-node":"^10.9.2","prettier":"^3.6.2","supertest":"^7.1.4","@eslint/js":"^9.33.0","@types/koa":"^2.13.12","typescript":"^5.9.2","@types/chai":"^5.2.2","@types/node":"^20.10.5","@types/mocha":"^10.0.10","@types/sinon":"^17.0.4","tsconfig-paths":"^4.2.0","@types/supertest":"^6.0.3","esbuild-register":"^3.6.0","@types/eslint__js":"^8.42.3","typescript-eslint":"^8.40.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_2.2.0_1757046787275_0.3285073843197721","host":"s3://npm-registry-packages-npm-production"}},"2.2.1":{"name":"@awsmag/power-msk","version":"2.2.1","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","_id":"@awsmag/power-msk@2.2.1","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"dist":{"shasum":"dc3c4c1c704e924284ade08c92c78dd78a30ccce","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-2.2.1.tgz","fileCount":14,"integrity":"sha512-ZSOwnQWRDQFPScbwRc3uqaFJNUp1M7g6WhGC8pbicRpRwWelchu3ezmKeOedPPBTeIOQgpXAj9ur+5XRb4DqjQ==","signatures":[{"sig":"MEUCIQDxSjCmzIKwepTrZCp5Jr3meg/vzChssI0n6Dhgeds0QwIgIsqvXa+HiCz5Uaxjj7MQyNauX2Dgqe2MFBaY0xLf5tI=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":397423},"main":"dist/index.js","types":"dist/types","gitHead":"2045badb3e39d56c735c3a3212e1923cbeef8422","scripts":{"lint":"eslint .","test":"mocha -r esbuild-register \"test/**/*.spec.ts\" --exit","build":"node build.js","prebuild":"rimraf dist","prettier":"prettier --write .","postbuild":"tsc","test:consumer":"BROKERS=localhost:9092 ts-node --transpile-only integ/consumerdebug.ts --topic=test --group=g1 --fromBeginning","test:producer":"ts-node --transpile-only integ/producerdebug.ts","prepublishOnly":"npm run build"},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"_npmVersion":"11.5.2","description":"A package to connect and work with AWS Kafka service","directories":{"test":"test"},"_nodeVersion":"20.18.1","dependencies":{"pino":"^9.9.0","kafkajs":"^2.2.4"},"_hasShrinkwrap":false,"devDependencies":{"koa":"^2.14.2","nyc":"^15.1.0","chai":"^6.0.1","mocha":"^10.8.2","sinon":"^21.0.0","rimraf":"^6.0.1","esbuild":"^0.19.12","ts-node":"^10.9.2","prettier":"^3.6.2","supertest":"^7.1.4","@eslint/js":"^9.33.0","@types/koa":"^2.13.12","typescript":"^5.9.2","@types/chai":"^5.2.2","@types/node":"^20.10.5","@types/mocha":"^10.0.10","@types/sinon":"^17.0.4","tsconfig-paths":"^4.2.0","@types/supertest":"^6.0.3","esbuild-register":"^3.6.0","@types/eslint__js":"^8.42.3","typescript-eslint":"^8.40.0","eslint-config-prettier":"^9.1.0","typescript-json-decoder":"^1.0.11"},"_npmOperationalInternal":{"tmp":"tmp/power-msk_2.2.1_1757047902403_0.663867914171892","host":"s3://npm-registry-packages-npm-production"}},"2.2.2":{"name":"@awsmag/power-msk","version":"2.2.2","description":"A package to connect and work with AWS Kafka service","main":"dist/index.js","scripts":{"lint":"eslint .","prettier":"prettier --write .","prebuild":"rimraf dist","build":"node build.js","postbuild":"tsc","prepublishOnly":"npm run build","test":"mocha -r esbuild-register \"test/**/*.spec.ts\" --exit","test:consumer":"BROKERS=localhost:9092 ts-node --transpile-only integ/consumerdebug.ts --topic=test --group=g1 --fromBeginning","test:producer":"ts-node --transpile-only integ/producerdebug.ts"},"types":"dist/types/src","keywords":[],"author":{"name":"Simranjeet Singh"},"license":"MIT","dependencies":{"kafkajs":"^2.2.4","pino":"^9.9.0"},"devDependencies":{"@eslint/js":"^9.33.0","@types/chai":"^5.2.2","@types/eslint__js":"^8.42.3","@types/koa":"^2.13.12","@types/mocha":"^10.0.10","@types/node":"^20.10.5","@types/sinon":"^17.0.4","@types/supertest":"^6.0.3","chai":"^6.0.1","esbuild":"^0.19.12","esbuild-register":"^3.6.0","eslint-config-prettier":"^9.1.0","koa":"^2.14.2","mocha":"^10.8.2","nyc":"^15.1.0","prettier":"^3.6.2","rimraf":"^6.0.1","sinon":"^21.0.0","supertest":"^7.1.4","ts-node":"^10.9.2","tsconfig-paths":"^4.2.0","typescript":"^5.9.2","typescript-eslint":"^8.40.0","typescript-json-decoder":"^1.0.11"},"directories":{"test":"test"},"_id":"@awsmag/power-msk@2.2.2","gitHead":"2b705eaa776ec67a5e58c2b98dd7db2ce51c5866","_nodeVersion":"20.18.1","_npmVersion":"11.5.2","dist":{"integrity":"sha512-wVyMg/LhNbHqTjuRD2Vwb5KvsWXnAG8NXTti1JNPJDO0wzYfnbuPYkKYbPVClAo5rBHHAVfEas0ejep6OBjWUg==","shasum":"73ddd56b5bc2c8386ca29c155fbc3cea4885065e","tarball":"https://registry.npmjs.org/@awsmag/power-msk/-/power-msk-2.2.2.tgz","fileCount":14,"unpackedSize":397427,"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEYCIQCndA/bbusXfr2fNhQfSit3FZBG7EXfry0WRnkIvUBVOQIhAL1kd52Z2WfazH4thw2eRW+P+JVHZhyrfCS3stNdN8Dv"}]},"_npmUser":{"name":"simranjeet2589","email":"simranjeet@s25.digital"},"maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/power-msk_2.2.2_1757049006867_0.9394729053734197"},"_hasShrinkwrap":false}},"time":{"created":"2023-12-30T05:46:53.391Z","modified":"2025-09-05T05:10:07.635Z","1.0.0":"2023-12-30T05:46:53.703Z","1.0.1":"2023-12-30T07:44:40.456Z","1.0.2":"2023-12-30T07:50:01.014Z","1.0.3":"2023-12-30T07:51:53.280Z","1.1.0":"2023-12-30T07:54:55.210Z","1.1.1":"2023-12-30T10:46:26.260Z","1.2.0":"2024-02-24T08:59:51.114Z","1.3.0":"2024-02-24T09:15:33.292Z","1.3.1":"2024-04-30T08:21:52.105Z","1.4.0":"2024-05-05T04:55:25.031Z","1.5.0":"2024-05-31T11:47:18.666Z","1.6.0":"2024-10-30T04:22:44.985Z","1.7.0":"2024-10-31T14:44:48.926Z","2.0.0":"2025-08-23T05:07:28.756Z","2.0.1":"2025-08-26T06:41:29.511Z","2.1.0":"2025-08-27T13:35:22.335Z","2.2.0":"2025-09-05T04:33:07.476Z","2.2.1":"2025-09-05T04:51:42.582Z","2.2.2":"2025-09-05T05:10:07.090Z"},"author":{"name":"Simranjeet Singh"},"license":"MIT","keywords":[],"description":"A package to connect and work with AWS Kafka service","maintainers":[{"name":"simranjeet2589","email":"simranjeet@s25.digital"}],"readme":"# power-msk v2\n\n**Resilience-first KafkaJS helpers** for production-grade apps on [KafkaJS](https://kafka.js.org/).\n\n👉 Focused on **robust consumers & producers** + simple **Koa middleware**.\n\n👉 You bring your own Kafka config (brokers, SSL, SASL, etc).\n\n---\n\n## ✨ Features\n\n### Resilient Consumer\n\n* Auto-recreate on fatal errors (`STOP` / `CRASH` with `restart=false`)\n* Partition-level isolation via pause/resume\n* Full-jitter exponential backoff\n* Health & readiness probes\n\n### Resilient Producer\n\n* Auto-reconnect & recreate on send errors\n* Batching (`lingerMs`, `maxBatchSize`) for throughput\n* Backpressure (`maxQueueBytes`) to prevent OOM\n* Idempotence & transactions supported\n* Health & readiness probes\n\n### Koa Middleware\n\n* Exposes a shared resilient producer on `ctx.kafkaClient`\n* `sendMessages()`, `isHealthy()`, `isReady()` available in requests\n* Graceful shutdown hook (`mw.shutdown()`) for clean exits\n\n---\n\n## 📦 Install\n\n```bash\nnpm install @awsmag/power-msk kafkajs\n# or\nyarn add @awsmag/power-msk kafkajs\n```\n\n---\n\n## 🚀 Quickstart\n\n### 1) Consumer (eachMessage)\n\n```ts\nimport { Kafka } from \"kafkajs\";\nimport { ConsumerSupervisor } from \"@awsmag/power-msk\";\n\nconst kafka = new Kafka({\n  clientId: \"orders-app\",\n  brokers: [\"b1:9092\",\"b2:9092\",\"b3:9092\"],\n  ssl: true,\n});\n\nconst sup = new ConsumerSupervisor({\n  kafka,\n  groupId: \"orders-g1\",\n  topics: [\"orders\"],\n  eachMessage: async ({ topic, partition, message }) => {\n    const payload = JSON.parse(message.value!.toString());\n    console.log(\"Received\", payload);\n  },\n});\n\nawait sup.startForever();\n```\n\n### 2) Consumer (eachBatch)\n\n```ts\nconst sup = new ConsumerSupervisor({\n  kafka,\n  groupId: \"orders-g1\",\n  topics: [\"orders\"],\n  eachBatch: async ({ batch, commitOffsetsIfNecessary }) => {\n    for (const m of batch.messages) {\n      console.log(\"Received\", m.offset, m.value?.toString());\n    }\n    await commitOffsetsIfNecessary();\n  },\n  runConfig: { autoCommit: false, eachBatchAutoResolve: false },\n});\n\nawait sup.startForever();\n```\n\n### 3) Producer\n\n```ts\nimport { ResilientProducer } from \"@awsmag/power-msk\";\n\nconst producer = new ResilientProducer({\n  kafka,\n  idempotent: true,\n  acks: -1,\n  lingerMs: 10,\n  maxBatchSize: 500,\n  maxQueueBytes: 5 * 1024 * 1024,\n});\n\nawait producer.start();\n\nawait producer.sendOne(\"orders\", {\n  key: Buffer.from(\"o:123\"),\n  value: Buffer.from(JSON.stringify({ id: 123, status: \"created\" })),\n});\n```\n\n### 4) Koa Middleware\n\n```ts\nimport Koa from \"koa\";\nimport Router from \"@koa/router\";\nimport { getKafkaClientMw } from \"@awsmag/power-msk\";\n\nconst app = new Koa();\nconst router = new Router();\n\nconst kafkaMw = getKafkaClientMw({\n  clientId: \"my-app\",\n  brokers: [\"b1:9092\", \"b2:9092\"],\n  ssl: true,\n});\n\napp.use(kafkaMw);\n\nrouter.post(\"/broadcast\", async (ctx) => {\n  const events = [{ id: 1, msg: \"hello\" }];\n  await ctx.kafkaClient!.sendMessages(events, \"my-topic\");\n  ctx.status = 202;\n});\n\nrouter.get(\"/healthz\", (ctx) => { ctx.status = ctx.kafkaClient!.isHealthy() ? 200 : 500; });\nrouter.get(\"/readyz\",  (ctx) => { ctx.status = ctx.kafkaClient!.isReady() ? 200 : 503; });\n\napp.use(router.routes()).use(router.allowedMethods());\napp.listen(3000);\n\n// optional: stop producer cleanly in tests or shutdown scripts\n// await kafkaMw.shutdown();\n```\n\n---\n\n## 🛠 API\n\n### ConsumerSupervisor\n\n* `startForever()`: run until stopped\n* `stop()`: graceful stop\n* `isHealthy()` / `isReady()`\n\n### ResilientProducer\n\n* `start()` / `stop()`\n* `send(topic, messages)` / `sendOne(topic, message)`\n* `withTransaction(fn)`\n* `isHealthy()` / `isReady()`\n\n### Koa Middleware\n\n* `getKafkaClientMw(opts)`\n\n  * Attaches `ctx.kafkaClient` with:\n\n    * `sendMessages(events[], topic)`\n    * `isHealthy()`\n    * `isReady()`\n  * Provides `.shutdown()` for clean exits (esp. in tests)\n\n---\n\n## 📚 Detailed Scenarios\n\nWant to understand how the **ConsumerSupervisor** and **ResilientProducer** behave in real-world cases (errors, crashes, rebalances, backpressure)?  \n\n👉 See [SCENARIOS.md](./Scenario.md) for sequence diagrams and lifecycle walkthroughs.\n\n---\n\n## 🔄 Migration (v1 → v2)\n\n* **IAM/MSK helpers** dropped. Bring your own `ssl/sasl`.\n* **Producer/Consumer APIs** are now resilience-focused.\n* **Koa middleware** switched from per-request producer → shared resilient producer with auto-recreate.\n\n---\n\nMaintained by [AWSMAG](https://awsmag.com) C/O [S25Digital](https://s25.digital).\n\n---\n","readmeFilename":"README.md"}