{"_id":"kafka-ts","_rev":"95-849fe7a84e00edad69be7ea14337c5cd","name":"kafka-ts","dist-tags":{"latest":"1.5.0"},"versions":{"0.0.1-beta":{"name":"kafka-ts","version":"0.0.1-beta","author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.1-beta","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"dist":{"shasum":"6732d6efc94095b008632d0417c03629ab2c41b3","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.1-beta.tgz","fileCount":196,"integrity":"sha512-PBgb5q1ZLtig1mTUNbX2gaz/N0sNFLWJDVS3vnBZTAEOTljQJD/guMCNbiOVyebY5QzGM8OEBA065AZtg/UEHw==","signatures":[{"sig":"MEQCIFWC8ClA9JGzv0yFtn8mZDEAbe3/YvhLcj2L3qokX5sFAiAq5V9zzOjn+DLiPo5eUt0YV6lCAMCxVXoYL4XAF6M8zg==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":435897},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"37efb607f31949cbcc6da0d9403d5b8de6f43e6c","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"_npmVersion":"10.2.4","description":"**Please note that this project is still in early development and is not yet ready for production use. The interface before stable release is subject to change.**","directories":{},"_nodeVersion":"20.11.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.2.5","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.1-beta_1729426727047_0.6815349881821646","host":"s3://npm-registry-packages"}},"0.0.2-beta":{"name":"kafka-ts","version":"0.0.2-beta","author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.2-beta","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"30e7a6158097161b9594d11c836f487e860aabfb","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.2-beta.tgz","fileCount":71,"integrity":"sha512-Ixr/PN5/t+VUjg96hr0F+6sk5uuFfcKj7aEGn0Ogknlps5xLwk98vsHqZbqSXGViH1mJzthrxyXdXEMPR0C0kA==","signatures":[{"sig":"MEYCIQDdgkh+5iZnvR8P+UUPvFZiwAWIMfGnV31e+4puFQKeSwIhAOy2fpDkC0VhFpWqByP0s0lqYpq3OaOBc5GMJuMpZpol","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":182712},"main":"dist/index.js","gitHead":"7bcf681c866c29b7974882dd527fb95a8edaa68e","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.2.5","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.2-beta_1729435441731_0.9551795344997802","host":"s3://npm-registry-packages"}},"0.0.3-beta":{"name":"kafka-ts","version":"0.0.3-beta","author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.3-beta","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"9feb311954605e25bdb85449b45461311ef77081","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.3-beta.tgz","fileCount":75,"integrity":"sha512-5oubbPCTFctCrwFqBA51GerB1bMDMf3NH/FnaZNg2PxN4Sxaz0Hb1NQywnp6+eJRgDJ9UJfdVG/dSIgYzgTAMA==","signatures":[{"sig":"MEUCIEfEfeUVdUWaUCf93xctnUrJXmgwnauhr8Y14dJ7HlLnAiEAul440A8ho0jHcWOUuPiWhVaXC5jBDG7jMFEU3/eOzvI=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":192875},"main":"dist/index.js","gitHead":"6a2fef1db20ed6c88cb4756de38ad7c78afc2769","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write ."},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.3-beta_1729529711405_0.003588426489859353","host":"s3://npm-registry-packages"}},"0.0.1-beta.0":{"name":"kafka-ts","version":"0.0.1-beta.0","author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.1-beta.0","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"d2d77fd2f55e94eaaccc50a41e8cb29418956a7f","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.1-beta.0.tgz","fileCount":78,"integrity":"sha512-QemgD869VHH6A5Pa+RosswlUeV4oGQ10REHfabCgm9bC+Q54Iq3iq3+2B34yKmViMYOu1ZchegbPlBz/rt5J0g==","signatures":[{"sig":"MEYCIQC9pZrzCA+T1NL3i1Mt9s8atldHlfBfPIg22QRanHk3LQIhAIYdJwC98bepd3gV99RmNQ7f3TaEEhdjxmskNpinaAwG","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":199328},"main":"dist/index.js","gitHead":"1457759caf9da09fb0050758cfa0a2c372e924ac","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:bump":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.1-beta.0_1729619197255_0.42572406586253764","host":"s3://npm-registry-packages"}},"0.0.1-beta.1":{"name":"kafka-ts","version":"0.0.1-beta.1","author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.1-beta.1","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"f9453e28375ba8bd6a8e2704209f443a582d8c42","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.1-beta.1.tgz","fileCount":81,"integrity":"sha512-9TWcPDjxfog4XiwkDMFOofIJcqz43mYtQY4Jj0rWdGi+sQiJ/3zMf/XYpu9kboPs62RWXZ28tv92b8dQiwAs7g==","signatures":[{"sig":"MEUCIFXFJ6/+88y0flZXV8d7f05yn4zFFP7vY8iJvRpjcMlyAiEAokQ3V9YAz3D3ML+brdk6B4GRbq5J3inio6xVkAYJ5No=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":200188},"main":"dist/index.js","gitHead":"a27e959b9e1d9322f1346e6c2f4f6a42bc3b71e1","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:bump":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.1-beta.1_1729623667107_0.34308426730425556","host":"s3://npm-registry-packages"}},"0.0.1-beta.2":{"name":"kafka-ts","version":"0.0.1-beta.2","author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.1-beta.2","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"6bb23ae7a2613c0836e2306bece0b030c9d1f264","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.1-beta.2.tgz","fileCount":83,"integrity":"sha512-F1Dn3/8W41L15PT5eUMe+YcSbweVbnq0+5sc9u/n8ophcnpr7pKgtZSRYkJVach4k6q7npZbD3e+tHa84QdNPA==","signatures":[{"sig":"MEUCIBYZUMLGi8fQLd7ylDeDFG/Ezwj7hAyOEakIDTLg2BRbAiEA65m3GYTfT4kbqqUj5NE7SBQyghfRU2ZXt0p1CQ6AJ+w=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":215842},"main":"dist/index.js","gitHead":"c2b6d297e0ef811dbc0ec82da9fd20f15cafbca3","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:bump":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.1-beta.2_1729711138881_0.7915375324157223","host":"s3://npm-registry-packages"}},"0.0.1-beta.3":{"name":"kafka-ts","version":"0.0.1-beta.3","author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.1-beta.3","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"a661eb8b76eb651d183a4e04a121f52126957afb","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.1-beta.3.tgz","fileCount":83,"integrity":"sha512-mkJJo2YVqmSqmk//ApU5CWq9dQCck23yzD0cqC0v7edEnNxTObVVN8bg7/L7aE/WZUGVct27+BkdD5fOG1kpcw==","signatures":[{"sig":"MEUCIQC5KtK0I0eRj42/ygJJZ03uD8oUYSqn3giN9Wqlo/kZQwIgI1ym/jTXgaDR0KKOXW41zknKyl46Sc7GSe/UdHRMgXE=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":217981},"main":"dist/index.js","gitHead":"dd75da4d7bf218492dc4dd881b74bf75b3310559","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:bump":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.1-beta.3_1729711760332_0.8329152292689839","host":"s3://npm-registry-packages"}},"0.0.1-beta.4":{"name":"kafka-ts","version":"0.0.1-beta.4","author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.1-beta.4","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"b9ff687cf84adc8faf9f86d187f37a325e8d9738","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.1-beta.4.tgz","fileCount":88,"integrity":"sha512-eTSqbQqUojAUyZQh4LL0lVTPwvZjsc2BXdmUG+h5mynsDt26rRYJO9GosDXg6OXpdIQ/Zp/55GIX+cBJ70kuYw==","signatures":[{"sig":"MEYCIQCdg11urUnbG1InAN4OmUn6123hJiF8Ht1paVcKJQPodAIhAKOT2DofVQ0cJgOPMjLDxnpJZ9U/pi/qEwLeQtVhsMzD","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":230332},"main":"dist/index.js","gitHead":"1d7ca3766617b4df0793239953c459e2cc8e92c2","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:bump":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.1-beta.4_1729788763387_0.3551760104252182","host":"s3://npm-registry-packages"}},"0.0.1-beta.6":{"name":"kafka-ts","version":"0.0.1-beta.6","author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.1-beta.6","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"3bf68d610752bd6c948cc5e26587cd8f33912acc","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.1-beta.6.tgz","fileCount":200,"integrity":"sha512-KcbdzOOrjXhu+yeKxlJ+sfw1gIMHeixC0ddn2z0Ioa+/IBnoJhwCKa344UXSiKGjoa435GD7b8sBggzXVzzrog==","signatures":[{"sig":"MEYCIQCxMtPWNoi4FlHbsjpfOHBe8efDXyJO//81Man8+1FgoAIhAMokm+LohE4VUO7oJLdidpEXBp/69zP8k9ZKGGJTaH2/","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":584281},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"c1fdd1264003d255b7c5926b4b72e8b7023acd51","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:beta":"npm version prerelease --preid=beta","version:patch":"npm version patch"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.1-beta.6_1730204358276_0.45204570775202546","host":"s3://npm-registry-packages"}},"0.0.2":{"name":"kafka-ts","version":"0.0.2","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.2","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"a0d6564ee58bf7ef3d247a1841c56f59636af633","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.2.tgz","fileCount":177,"integrity":"sha512-0W17kxMGGOjGYsp5774XPz3ljjcWtwoAZlyg7lCPU8S4Gf81wFldVpAdOXHPZWrKjhOLsCReWzJSUJGmqNpTSA==","signatures":[{"sig":"MEUCIBJJxDPDjbNZ6/RYP3Gbtkwh4T1MfYI+x/YKTl4qrXpUAiEAgcH4ZT1ulx2+XF0z3t9cVyBM3XWBLqbN2cJsYtBdrVQ=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":378227},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"d355bebdc025a2290f6150f5c6b6d2ea695ac042","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:beta":"npm version prerelease --preid=beta","version:patch":"npm version patch"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.2_1730204633056_0.8873789605679245","host":"s3://npm-registry-packages"}},"0.0.3":{"name":"kafka-ts","version":"0.0.3","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.3","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"d23832818cb891fdfa7b15f0e0ec99d953b5e2fa","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.3.tgz","fileCount":177,"integrity":"sha512-Df9vEHYHzH4o49S2u8kc/TAxYcmSZFLa7Su0lAVNXLl2FF7RCpCKCNG0XQCdlqQ6Iw0vnCij2eCob2/ET1aKFA==","signatures":[{"sig":"MEUCIQDuE01ZGgguS0Hb+trPNTlI9mZikV3Ny67Ggy5DtmxamQIgKmsergHJU9oU4jIdwGEl8HvgeYFjx8Js6stx/IOK94c=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":377637},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"cb4f8c27ea30d3e7a0f0799018a2e92dc8b95a6f","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:beta":"npm version prerelease --preid=beta","version:patch":"npm version patch"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.3_1730206634025_0.2628625021652742","host":"s3://npm-registry-packages"}},"0.0.4":{"name":"kafka-ts","version":"0.0.4","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.4","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"ccde279b0800c8a8e90dd8275c90787df758bcce","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.4.tgz","fileCount":117,"integrity":"sha512-VZ6D7UbZvMbtIVeBe8gxMbH60Xu0Wag3WBzHUr2KvC7uBQhthFRbG+HMpjdnPnxZoJGHg8tEGygkDdM5jIAt9w==","signatures":[{"sig":"MEQCIH8UVoaFLRWDSUPQr3rpYGCezJC6ndsUOfwEJmxfYwqZAiAbCrLK3/pSzbez7PsPR0YKuj3fNUE5Qih/VeuhE83r5A==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":206428},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"48895dc04a5c235964ee938f1d4c740d09a2a61b","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:beta":"npm version prerelease --preid=beta","version:patch":"npm version patch"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.4_1730296556260_0.2163288608517231","host":"s3://npm-registry-packages"}},"0.0.5":{"name":"kafka-ts","version":"0.0.5","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.5","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"feb44fcc01e3e3fd70e98eaee09855f75fe532ce","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.5.tgz","fileCount":117,"integrity":"sha512-yqxy+yksJpURG2t/TfiRMVh+faENZ72ul07r/D8bnRLc/mo+te1oIMEXlGn1lhtuqaH+hMQ+oM2OL6d3Mr9RiA==","signatures":[{"sig":"MEQCIGrplrDXamCkv2jCXH+sN7Qj3Rq/qNTdr74PosnwlCJNAiB2o0hd4d2zVjtuBJKLZzJupcjKZPc1bpH53JIIM6gaTA==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":208648},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"e25e3e243e2cbb7665de13577e92d78ac5a633e2","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:beta":"npm version prerelease --preid=beta","version:patch":"npm version patch"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.5_1730389842900_0.9505395648072255","host":"s3://npm-registry-packages"}},"0.0.6-beta.0":{"name":"kafka-ts","version":"0.0.6-beta.0","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.6-beta.0","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"063a6d4a6acfcc3eb5d91af1330ee496a1e06bbc","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.6-beta.0.tgz","fileCount":117,"integrity":"sha512-AWVcf1+1THf3XgtJW6G2z4jdBfE5qyW1zUbDYDRlxWUBtjewhb4vSlp4sTYytfJEPB5GrDWBGGpykeyb0WRDPQ==","signatures":[{"sig":"MEUCIGit2ZZF8DKeLYKPE9MWegFngx/eq4QlNeFaXSI8rN/qAiEAp+8Oxs83cR5HiAbvBupL5SY/78i/MzGDHZX+yg+VjO0=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":208742},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"736ee2890cb1fb14831242839240d68d7deebd04","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:beta":"npm version prerelease --preid=beta","version:patch":"npm version patch"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.6-beta.0_1730465869975_0.10542459451973007","host":"s3://npm-registry-packages"}},"0.0.6-beta.1":{"name":"kafka-ts","version":"0.0.6-beta.1","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.6-beta.1","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"52105825e1ea8ad343421bf1cdab1c2547d81aba","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.6-beta.1.tgz","fileCount":117,"integrity":"sha512-ap0TpBH8NmCS14HQ16poEzv0flrn7Rg6fgtjmRUpGZEaatF0fAK2aKibpm2ML/w9o4tK/JTt2DLQ2fhpt6Pl8A==","signatures":[{"sig":"MEYCIQCEy3WA4mRrCmbMBX5oMVeO3fhVtwH8qt6gfepYh97nTwIhAM1VdkjHJ2fbmSDTra2U5i5tCqo1PWCWPm2ugXBxGsga","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":209281},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"d01b82e222f68be8f1ed18fa8f9ea996ffcce970","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.6-beta.1_1730470232291_0.01208712870343942","host":"s3://npm-registry-packages"}},"0.0.6-beta.2":{"name":"kafka-ts","version":"0.0.6-beta.2","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.6-beta.2","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"d743940c294fc49bb472c65ad1d51d674a2aa37f","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.6-beta.2.tgz","fileCount":117,"integrity":"sha512-Pg0oDy3UvL/4XQXRGWrCeYa3L+up8HiDmDISvT0kuIlMH/3rWGQ/oNIOzDnKlQ41a9cnwyMTA5H0eKKNzNSfZw==","signatures":[{"sig":"MEQCIFPKOyPc8CGERTuU1vvDUCG+h03fd2qdYXRwRBL2csfJAiAf9h2xuKeNVhXZSnJlVOIvPTPg9CYheSHNyY1qGh2b/w==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":209915},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"2c8486fcf95d43f6fdcf60789bf4c265f6ac94ca","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.6-beta.2_1730471747346_0.5748458525333571","host":"s3://npm-registry-packages"}},"0.0.6-beta.3":{"name":"kafka-ts","version":"0.0.6-beta.3","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.6-beta.3","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"29cc1dedbb1bb8cf1db7a645813f5421d5f6c49d","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.6-beta.3.tgz","fileCount":117,"integrity":"sha512-q5QQbNBDPxlkKw1ND+jZHJZHgnEhpUBI6hBm76g4kIkfPfq2tLMAWntSUzqzrD3001r4ktTDSZCPur/DfbsmxA==","signatures":[{"sig":"MEUCIQCupK50I6XGlwodauDZGoUeTx60SibtgCnrpv+wKp+R9AIge6+CQsrp/wHKJ0bnUyPm/tHFul5bl2e5p7rpiChVCvI=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":209998},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"41db63fb45d3a96a42c1d81d53ec437c466c3330","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.6-beta.3_1730474355423_0.4242461634338339","host":"s3://npm-registry-packages"}},"0.0.6-beta.4":{"name":"kafka-ts","version":"0.0.6-beta.4","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.6-beta.4","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"29c7ca18d3e14f254ce6de20760c2bba6e1a93dc","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.6-beta.4.tgz","fileCount":117,"integrity":"sha512-aA1kIdiPMfmQTczTudG5w5i8lCKrQeTnN4iltxywf3LOacckftV51yjSK+TzCII4Gg1jvaiav0vAc/34cLFT1g==","signatures":[{"sig":"MEYCIQC0QN8SrACkusoeKVCeMR4h5i07bErsDNMc+FtAXbJyIwIhAJXhv4rSdXBh3atrGHoDe4Cjc+Tge9Q0j39BvwUFR1WE","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":209164},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"7a522e4699c84c38673c8c9d07d26a119384fa0b","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.6-beta.4_1730715063081_0.14995035638315057","host":"s3://npm-registry-packages"}},"0.0.6-beta.5":{"name":"kafka-ts","version":"0.0.6-beta.5","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.6-beta.5","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"245006f5d234d035adf90ec4556dbe0833cd5139","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.6-beta.5.tgz","fileCount":117,"integrity":"sha512-RVZZwiHcsU7TTchtGVPUREp5Nrbe3ymHQu9Twsk/mDhVHw21XZe6Swrw9nG/NLctX3flxBPzoz5amsNT935Nqw==","signatures":[{"sig":"MEUCIFIsIomdcbZEw6AvBEvbtI4OJV08e0WvYtI6iuzz1cIQAiEAxHic+WwEuPxD77ha32fIXEItAoP7c/9fwaFFp1lGADc=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":209675},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"4c6f3196ac4aa84245d09663eb7e640867633420","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.6-beta.5_1730715505549_0.45632237372005613","host":"s3://npm-registry-packages"}},"0.0.6-beta.6":{"name":"kafka-ts","version":"0.0.6-beta.6","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.6-beta.6","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"1a27a0e92205de3aa1ab3a81a2fd9562a8a5c0c0","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.6-beta.6.tgz","fileCount":115,"integrity":"sha512-e8NfLFvLh21vHUdfEfZgYf3+XYrmUZm7f63lBo5n+dY06Ao5AX0hKW+7uaiuDkqADVoRkvIsx7YvmUrmy4TKzg==","signatures":[{"sig":"MEUCIAERjdrIhf9oV4HJ59KwDot7X1jfvQLZ5gLT0mY1UM0RAiEA6Rz/0zdiD7a+n9czHmTZ+Jdgm9+9hVbA68/TaC8i7Qw=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":209472},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"a266703fd804c32925bdba45f3208f3bcdf25466","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.6-beta.6_1730716856108_0.3781133741164704","host":"s3://npm-registry-packages"}},"0.0.6-beta.7":{"name":"kafka-ts","version":"0.0.6-beta.7","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.6-beta.7","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"ab528ef41646f9d4be730cf119261a85c2b1691c","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.6-beta.7.tgz","fileCount":115,"integrity":"sha512-2N1LAMebXosTFsC77HTe/0KGMry6TopwI0D2Kh+j3JCcUrvW3wSs/c9D/9khzeCrEPuz/C8ziLcLCddMuX/Baw==","signatures":[{"sig":"MEUCIAqUusRwoKg8mgMkYpNYbVAZpLzXVRdCOcTriWSrMsDnAiEAoyD8CLirxNj/HRvoaJxTB9ygcpMKR2hzUehSDp+taXc=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":209496},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"694a466e5f85d66246d9e35d81fc3e32cc365c5b","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.6-beta.7_1730717364354_0.6674926420328211","host":"s3://npm-registry-packages"}},"0.0.6-beta.8":{"name":"kafka-ts","version":"0.0.6-beta.8","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.6-beta.8","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"ff8d440fe50b83da2f09e34bb90614636ddb1924","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.6-beta.8.tgz","fileCount":115,"integrity":"sha512-X0WAIfmdvmxfJ5wlsPyiHjaWORW9u6jzqsA1B62cZxItOfDZ7raFJhYFn8vyaG9ScQu6jpICciu3F1DsJKQ1mg==","signatures":[{"sig":"MEQCIEkr4cdjdRmJtAdP5ZhQ6jrvp+D4snstXt4yrVeYLbvZAiBLD1ep7FoyDtibxNgDN9hzgeQcCZfXLw+U3wgVZyytkA==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":209493},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"90a6e6b7d8b2796f31d879c8d7efd35711f02ff2","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.6-beta.8_1730718955301_0.3162590945425836","host":"s3://npm-registry-packages"}},"0.0.6":{"name":"kafka-ts","version":"0.0.6","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.6","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"eea7a3f82589ef183b1d0883e0ac3aeabbe95dce","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.6.tgz","fileCount":115,"integrity":"sha512-oPwF//gudO/4dUrFt5Yxm74CKc9kFtmYilE5yul2wWkgOmeBn2Yi/PyjfLurQNRR/MdNXXfeTnKYO7XC7meaKA==","signatures":[{"sig":"MEYCIQD5XBuhc+qJJRED+rlCshJ1jJUGkZHaphtEen1KsXkjYQIhAJm2ean8d99PAwyKmxGCCiQSvL2wzisK+YIK4kSWxw3r","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":209486},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"86c1cc8b85f46af69eb4811f2332f8d0b449bc59","scripts":{"test":"vitest --testTimeout 60000 --bail 1","build":"tsc","start":"docker-compose down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.6_1730719215404_0.9562552525610919","host":"s3://npm-registry-packages"}},"0.0.8":{"name":"kafka-ts","version":"0.0.8","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.8","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"2c61561542b7cc2108f9ed48d75cb9b636c55c56","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.8.tgz","fileCount":115,"integrity":"sha512-Ug38/nhFlNMhNq9AUoxB6MPle9dfPEdE8Hq0h5dV+nta3IsGYOGgbvlc/0yUYjepEkXd5tG28nlnkl5Y2XaWEg==","signatures":[{"sig":"MEYCIQDNXlG5NYkLQjDVJbBNSnmKgpETykpmfqcB0alsepd1RwIhAPx9RQozUziOu2SaJgXMj6a0VSW+g9h8yoUXUd8QFqJI","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":210373},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"367261257bff1d2edc31acac47866e7f135574a7","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.8_1730727266798_0.07753558594578469","host":"s3://npm-registry-packages"}},"0.0.9-beta.0":{"name":"kafka-ts","version":"0.0.9-beta.0","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.9-beta.0","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"381ab56193d4f081fdb74f9bd0b8e68fa52a3675","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.9-beta.0.tgz","fileCount":115,"integrity":"sha512-OZvt0H2mPjJp9OGxqV+dOuSrz7xHTny8Rrm8ovjm9ETnK2uTL6bEQL6O60oFyr9xYBQd7j4RH77DCi7kJJzSEA==","signatures":[{"sig":"MEQCIFbLR3NBip+F+fbyH6TvjhNVp73in/TaQejG1DxezGEhAiA1YhjaCaEw3OB+APIikx4RAT7aGyDw+EqBkOMsYY9+NQ==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":210456},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"98c9bbf490c227348430d5e7cef850e066ba31a4","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.9-beta.0_1730729852008_0.6359550387742721","host":"s3://npm-registry-packages"}},"0.0.13":{"name":"kafka-ts","version":"0.0.13","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.13","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"6009a7e651354f17dd056b3d1fb29593a45bef8e","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.13.tgz","fileCount":115,"integrity":"sha512-yggdb5EcWLIXQ7QSwyzkR5XEI7CejPwGv+gxd4jKN5XaeBt/AXErjDsr6zRJNqdYhTgm3+Q4K3x8cAZRfgoUrQ==","signatures":[{"sig":"MEYCIQDaosU1++MdD0qPss85GCssdbzLcoXKTCKeMuaO5rgvEQIhAMfWkUzOOrkAxbIXBb5Y9LRd87gRm8jUG19fECrhcBkJ","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":210472},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"48442cdcd3ac5a0d4dd7da727fa932d9a5651500","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.13_1730730100442_0.40508654343935935","host":"s3://npm-registry-packages"}},"0.0.14":{"name":"kafka-ts","version":"0.0.14","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.14","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"fa8e6853434fc5e0c663e8bfd4aa054b86049a24","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.14.tgz","fileCount":115,"integrity":"sha512-eyVFGUEuwBXXCMACs5LYjtSPTbXkbhxKS/Z8C94Xmeo6LXhdkMYOi7qftqQnCmNsua9nSmfMLBWIfm5KzvjFPg==","signatures":[{"sig":"MEUCIQDibZu1r0pHgrgQSf+cd5xBkQTBvqvVjejpZ7tEMJsA4gIgUqeIWWGApTC4/OoYnP/cyDnPPuwP3duilPBmpviC8ME=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":210553},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"265f210863f14bd39c78859ecc0cfdd6167e9b1d","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.14_1730730854843_0.8883672099238109","host":"s3://npm-registry-packages"}},"0.0.16":{"name":"kafka-ts","version":"0.0.16","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.16","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"05cfbe49bfe8ee5b1322bcfafde63b12ca4ff365","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.16.tgz","fileCount":115,"integrity":"sha512-FVwjjo9KiTAtFMAhrnGoZ+imM0PE2EN9gTafjbQYoN5nMq3Q5/VvsHnEkOn+rq01Vrw665SrmWe+nGQKnD7epA==","signatures":[{"sig":"MEUCIQD8TC09RY/rPbQh2JLehHKnDcSFEP2xZoUtLdSi5PhTVgIgd4G7FQslnexLRTeFNmOXqpHJCYBiy++V7w75PGiwoU0=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":210834},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"9c6705ba93957f51499c624a4d65d47aa1696088","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.16_1730799178406_0.5122739109178636","host":"s3://npm-registry-packages"}},"0.0.17-beta.0":{"name":"kafka-ts","version":"0.0.17-beta.0","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.17-beta.0","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"072036953952fa0a6db93d17a89eb65c9bbf8c51","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.17-beta.0.tgz","fileCount":115,"integrity":"sha512-Emewn+kapAY74OfOWIC+bz1Hs+rifDURmnKq6CYqtTnC56ScbikZl8LlXgFP24pAv+hKfvM2MIC4pIgv5aolfA==","signatures":[{"sig":"MEUCIF80YZXdCwPSWUaOHJHDVJ7NfnNd1HYQojSTHyPHp9CEAiEAj187w7XbTXP59rTZUMovGJXI2dSxWt3Vy4O7ArNOb8c=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":212591},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"5f45b037a21ed871d527810ad4658e3a098b321a","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.17-beta.0_1730984746696_0.5996436921666795","host":"s3://npm-registry-packages"}},"0.0.17-beta.1":{"name":"kafka-ts","version":"0.0.17-beta.1","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.17-beta.1","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"c839e1b9c4c89d3d58cc0b46e98939ef98c8b792","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.17-beta.1.tgz","fileCount":115,"integrity":"sha512-Oy8rR/XIxRZFexityVmKECxAQ2TLkZi+kIj27GN1G0miMKPW1rpJoC4y1Fd+pRdQ0dRM4uxeU9re0dLqmlo+3w==","signatures":[{"sig":"MEUCIDBdEtwszfLqmEv2k7GLybCUzZ+sbajKKRauiuDBI7ZQAiEA7ZSStQhuThlNRx5gvYj9Sg2FN6nx7iCpDQTqLBnQfWQ=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":212712},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"5f478fb285015a317cc4cbc79b9a5c1ebb402aa5","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.17-beta.1_1730996446838_0.05417176337197471","host":"s3://npm-registry-packages"}},"0.0.17-beta.2":{"name":"kafka-ts","version":"0.0.17-beta.2","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.17-beta.2","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"68876af38bf539a32271186e9d6b201a2b323437","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.17-beta.2.tgz","fileCount":115,"integrity":"sha512-s36AF07eYPXY/9prlrBlsYO9yPikPacjTk80+rtTEoPT2XmZaCWdxxEBWlQ3WUKv26B4ranx0Zw/RRiwVUpgnw==","signatures":[{"sig":"MEUCIQCuBiifQoSOuovCGa5TYEehOI0NOBK0I7DzILZxNL2kHgIgXefnJcB2h5PlZVsu0gBShLq7i/HqR/512HMoEVCa0Jo=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":212908},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"2c862807c3e58e3d7dd1c99c397274bffcbab549","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.17-beta.2_1731004439990_0.6974827257436096","host":"s3://npm-registry-packages"}},"0.0.17-beta.3":{"name":"kafka-ts","version":"0.0.17-beta.3","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.17-beta.3","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"d46a24335c7506164a5124818b2d2e59c437546f","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.17-beta.3.tgz","fileCount":115,"integrity":"sha512-55e5XhgAFmLi2+uZJo3lolNTBcqewdjzUlU9Tc2UVpQRQJXrEGNMQyp1ruNJRoci2HPbjzvAeHi3A4Pam7Yqdw==","signatures":[{"sig":"MEYCIQC0mkge785kw3XFCAmETOfg7HmsBOGVrF3UF36Yve6ufAIhAMNzNDWNUSEvKyekHhRv+HZI7HxmD8P5ZERKz73CwLkh","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":213815},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"494724211066b0c30e6b881c84fb1a2d7356c5a2","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.17-beta.3_1731067949041_0.9041828131899194","host":"s3://npm-registry-packages"}},"0.0.17":{"name":"kafka-ts","version":"0.0.17","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@0.0.17","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"fcbc95dcf16dbf47fa5b999516cbb0489ab92a1b","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-0.0.17.tgz","fileCount":115,"integrity":"sha512-X2R5xzPBFkXk3A7ZpGAQW0czdkFlI5dwIMm2RmuLSwqVN6kTXDBDycAHgFfUCsvZiGYprXEZocVl9Gls2eJwlg==","signatures":[{"sig":"MEUCICusAI3llcr7DpoIvI2oaMib5806KSkbImtoPO/J/KivAiEAh0TmcGK/ESQEKIYJXdYZXG6X/gkp0HJRQvQByol8PYc=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":213808},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"72e46a436bfd02a2508d07dc42ccdb9b8bd8d267","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_0.0.17_1731087702149_0.8292312663352519","host":"s3://npm-registry-packages"}},"1.0.0":{"name":"kafka-ts","version":"1.0.0","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.0.0","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"57c4aa89ac150fe61ae3b2b7100c1c618c23aca3","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.0.0.tgz","fileCount":115,"integrity":"sha512-ntzKOuhEQ46PsQ28KVx3zM3Fjk4KUHgQThvQucCKRIcWOLxw0H0yjcuGLFD1RuiNij7sP/nprJ0a0ge1X9NnZg==","signatures":[{"sig":"MEQCIFtALl7dA7apwEBo3Oyk6e4BsxEp5wdDrVc0BB7QoUYNAiAOTgeq7z5XtiUE5f/d1Y2VAjfiWBD4C+rokej+LR5OZg==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":205835},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"60f3c261177bd212570ca9ddec62a0d4ffafbd82","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.0.0_1731506083809_0.6204237984537049","host":"s3://npm-registry-packages"}},"1.0.1":{"name":"kafka-ts","version":"1.0.1","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.0.1","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"0d653740a916d2ab5d72a44a2e794289d3b6a6d2","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.0.1.tgz","fileCount":115,"integrity":"sha512-LAzyAOO3x76/fZ/6VxPr8WOrEZ/hCbAS0/HD0f7OeftynsnIp9i5Ed4oUzLSPoQ/UQ5anQjebRNviBzvYOjaKA==","signatures":[{"sig":"MEQCICtk9a0HZRfd9lnvfyE78Q8DmwKhjedCocrI5dMK2BwtAiA7MB7Ox68MYe8G73v8UhHDfnlmAscoRe4f9d7yy1ZALQ==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":205822},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"cd524407ab15e52e3b744bc85e1f52120046616d","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.0.1_1731511190456_0.5625021921278264","host":"s3://npm-registry-packages"}},"1.0.2":{"name":"kafka-ts","version":"1.0.2","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.0.2","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"93b440de3e2c0d9093a59df703c22d02cf2ffba4","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.0.2.tgz","fileCount":115,"integrity":"sha512-eEU4j65XF/YYES7N+hUJNlxSC/mdwSZYp5NDi5wMZDTofPwbBfMevR25yDmrL3otTk80j47QBf0Zl7ZGZOa1fg==","signatures":[{"sig":"MEUCIQDqTjyNSQgx7mFFYXniIn9+Hs/HNbmY0UPqdxA7D3mFUQIgR+cl6A3tXQWjdztAGwCcsjBg2Qi5pC07MTrvKnkfods=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":202801},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"dea7051e6a846d93588b7cdd3eb95c2526b859f1","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.0.2_1731525334176_0.4239308176155747","host":"s3://npm-registry-packages"}},"1.0.3":{"name":"kafka-ts","version":"1.0.3","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.0.3","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"d67b7af1310bee634c668f13b1df38650850134f","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.0.3.tgz","fileCount":115,"integrity":"sha512-ZUZ2FcvduGJr7Wqb1I1lJT+LvvxKoLCG5WlgpBhmeWn071oLAuNUqJrtKUlhptntxLfL/FGfu3DSj73faL+IOQ==","signatures":[{"sig":"MEQCIFzVNHRV/i8WONzOITOMk1ritow7IPlIRmg1EfRaBqGdAiANTnQTZXREL+zqfNFKDzst1LWr2pql+es0Yjg3RxUICA==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":203080},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"4e9519e750cec994a24f9ec7f9998256b438a42d","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.0.3_1732032260904_0.32798747286901464","host":"s3://npm-registry-packages"}},"1.1.0":{"name":"kafka-ts","version":"1.1.0","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.0","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"52e6fbb2004e728fb38ef09317741913bc89681f","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.0.tgz","fileCount":115,"integrity":"sha512-vkqfkBJtufM9yz/5NN+ZzZgfvR+d2LOV3TfBZp3I2SDvZV4vs7fxAFUWz3rdDW/aiMP06Qi5Icu+aSPbu2e8Hg==","signatures":[{"sig":"MEYCIQDXgknIWHedf9D9EG+mfxOg4MwgYrYRUlXkUx0Kko1hCQIhAL+aczZ5DYRNxCYyzH3RmnIvU6H9nCcTGbu/y7i2Hn0/","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":203628},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"2cb3f692ef7b9837a103502697b4206b9abc3cad","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.0_1732120726148_0.20371209329124862","host":"s3://npm-registry-packages"}},"1.1.1":{"name":"kafka-ts","version":"1.1.1","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.1","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"1176a9eddd9bbc123b18ef6267200d38417e1067","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.1.tgz","fileCount":117,"integrity":"sha512-cHYNT9KuWNO2YOBk5HUKwN+znYYUFtjmnVMqG9zKrK8pqlNsOIhVNQBgitV4T/pljbnOfNniJXiL2WOTsXi/2A==","signatures":[{"sig":"MEQCIDIyL9uBT9bW2x4rmAdaidwPEGdLrWryAgU/3QNXwJfeAiBlXsGqwMo0Kj5uSQ5dDtiyt0Dag+sTzj7f3I25cB3hog==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":205821},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"fb208d3e6570cfe8ef371501897b6d969a2f08f5","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.1_1732121923769_0.28468993003310583","host":"s3://npm-registry-packages"}},"1.1.2-beta.0":{"name":"kafka-ts","version":"1.1.2-beta.0","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.2-beta.0","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"b3d5097c1cdfc3902fb0dc75fe6e38cb799f3746","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.2-beta.0.tgz","fileCount":119,"integrity":"sha512-QFk4c2hPz4r0nPbO6VFVSDQXIf70793Jb/8Dc2sCGvH8wUFHu1AauWvrBel70XmCjnOVQ0YrugTl/eCoWhzf2w==","signatures":[{"sig":"MEQCICn1UdkEffiXqdNcSYauiP4MLZCsu2lsRXMiiaiSYBskAiBjWc1eBYYZJIR/QnByZ47vMfoBkHTTL+lqf9hCbVNHsg==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":206896},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"2f8ebeafd7cdeafe63ba79820eb4dfe562927450","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.2-beta.0_1733842275059_0.9163583507295039","host":"s3://npm-registry-packages-npm-production"}},"1.1.2-beta.1":{"name":"kafka-ts","version":"1.1.2-beta.1","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.2-beta.1","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"182c426250311a92a3c61c6e1dc88cad5f2ebadc","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.2-beta.1.tgz","fileCount":119,"integrity":"sha512-+re/Ca3l+u7wXFaU3MInyneM5VHOi+FAGn8MNYuw6I/RMtRlxGNL7GYc2Dn2XXHgGjt/GmYck0z/Umt3ayYFBg==","signatures":[{"sig":"MEYCIQCXH1WW10ZSvIreiFs1JCTjVdVOmUgraBsy0WARDOPssQIhAIQPcMmxBJd5f/dyoyZrgOGDhzxdBupSuJo2dUi2VfNM","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":206971},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"66b0da17c0cde0ae0cc3c2b49f645db67fd5b37c","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.2-beta.1_1733842831889_0.7610693346959063","host":"s3://npm-registry-packages-npm-production"}},"1.1.2-beta.2":{"name":"kafka-ts","version":"1.1.2-beta.2","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.2-beta.2","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"7099bdbc945e4b956ac4c28abcf481d7056c4ef8","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.2-beta.2.tgz","fileCount":119,"integrity":"sha512-mf/eysp3Wt9FOHylmU4w3mHj8RQTGI3ICW3tdpctd1urrnp2Z+KxftxuaR7iPbfSowDIUIKgN45iPV5bdbC2QQ==","signatures":[{"sig":"MEYCIQD7O7g1MvffnoMwz0Gh+tbmotQhT05WudmQedrXwbMxGgIhALvv4ySyIbFpfhR7/HJTmw+NuZavVCVqXuU/Hr8ew+Wj","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":206964},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"765c67b2a35d67dcb17c1935d8fe286fcb9956e1","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.2-beta.2_1733843233053_0.8136113215322647","host":"s3://npm-registry-packages-npm-production"}},"1.1.2-beta.3":{"name":"kafka-ts","version":"1.1.2-beta.3","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.2-beta.3","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"4d62066e5eb7d13c89eece7902ab4b755d88c03a","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.2-beta.3.tgz","fileCount":119,"integrity":"sha512-G/WXfvsylSGS6+ow3CNpnur6RIge3ZCxWI99lbElxVQdGOsKoCbhkKqF5X88Jvswt6/FI97Cm+Ej2tinkazTGQ==","signatures":[{"sig":"MEQCIDwQF+5OUlZetRagfTpkubydC+qjrOSnSsVT/Zrw667bAiAIv9weg8nijrfXu0IHdGN5YGVvDvNus/ouu3PAltBjKQ==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":207054},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"3705c7c9410639922f24cb13bbc69b0d813f30f4","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.2-beta.3_1733996369000_0.7353122819918374","host":"s3://npm-registry-packages-npm-production"}},"1.1.2-beta.4":{"name":"kafka-ts","version":"1.1.2-beta.4","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.2-beta.4","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"f9a2b4c767591c270d2ea23646f301f42c2f5511","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.2-beta.4.tgz","fileCount":119,"integrity":"sha512-elqJ3zm5v83XDOXstk2yF5Fq8MC943BJ2n77C/nSQCkIwTjgCNkq5dUkagMSKT3tvU+dlAqgaNk5PZSAFGYAsQ==","signatures":[{"sig":"MEYCIQCdh6V0Fo8g19U9vzQiOA4mqhkkLwSz0G1aMlqTLA1DZAIhAMitGeUO8Ij6NLg3VwP4pH8KHTMzUE2mNIKvT5Q/JWsp","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":206869},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"cb602d446d7ea7cb2fe9dedea1aa13fee36b4aa2","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.2-beta.4_1734000074899_0.6058812544872718","host":"s3://npm-registry-packages-npm-production"}},"1.1.2":{"name":"kafka-ts","version":"1.1.2","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.2","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"38dd09105b7b3ec31691d8ebc87e2da1e2873baf","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.2.tgz","fileCount":119,"integrity":"sha512-P+sCWKc49qRyEP1JzlDk7ATxPFHpKzafqn9RtTIplwhRSiyg7zirQz6zygK26+3p/a8gMGg29Yzs3A/OhZm9Rg==","signatures":[{"sig":"MEUCIC/VSFgxiJgSMptR6pcgeTe3wOSeg3Lt/bZPaqgBKyi0AiEAsVAP1F6MvBRoo5iniHTMiOphwuIAJ7hzjoF+WbsBVL4=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":206862},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"ed0badb8537a23fbd7a3a3a1b3f9c021a47cbc9a","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.2_1734000941817_0.07903936269825573","host":"s3://npm-registry-packages-npm-production"}},"1.1.3-beta.0":{"name":"kafka-ts","version":"1.1.3-beta.0","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.3-beta.0","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"be03dd3e20ecfc07492d06f9fa702eda6df1d671","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.3-beta.0.tgz","fileCount":119,"integrity":"sha512-LVx9Y3k+AwC/oVIrJg60ybqc/MytZsmQPVLgRj5bzPrhacn97YAXNt82Si3dhXBVZ0DJ0UzgjvRE7Vdfe729Kg==","signatures":[{"sig":"MEYCIQC91Gwue2pk/UswmDmvov10eZuu0oOoKlPJnGsZGWEDbAIhAL4yypUXyyuTPtjeYyMUB6uq3gnozYCA/XSz4P1U87OV","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":207964},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"e0a2aad162e78e0457138507e662d61d97bff5df","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.2","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.0","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.3-beta.0_1739964215615_0.30235635867142907","host":"s3://npm-registry-packages-npm-production"}},"1.1.3":{"name":"kafka-ts","version":"1.1.3","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.3","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"930360c4122590cbf048583b30af839a902bd3d7","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.3.tgz","fileCount":119,"integrity":"sha512-kCHX6nMhdV89rNIiiO+o3wiw7aJkooSrmcOqf8O72yKuz9SnnZYDvJ2jiYJ/WsYUBIe2bZdIBe98Hdxsok7tHA==","signatures":[{"sig":"MEYCIQCIodYWgurrBu+i1JuAqrmKTPKnnb4TIuTXF8fwbGHxdwIhAOC1/p1AknDPZyWgj0TKsN1R4bMlpVAgSQbJMqY1jL5L","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":207821},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"86667c3c5fba0cbb3b4cc0176e44c89b1de8f814","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.2","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.1","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.3_1740245629373_0.9525073565621087","host":"s3://npm-registry-packages-npm-production"}},"1.1.4":{"name":"kafka-ts","version":"1.1.4","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.4","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"a174c13370db2ba2674b6c0177daefad078ecc85","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.4.tgz","fileCount":119,"integrity":"sha512-cWJoqWBiREmSziJhlsfQ7NhvNHrxQrNoA9ZTmYco8iPhIyjFTbRPEKgrEWLZUweTggUEX+NQpN2EQne3v0IZ+A==","signatures":[{"sig":"MEUCIHcjjsc+gaSQ9Dz9uh0kToGB4fHNDvcJW6GEdk1DZQx4AiEA0ERM9PuFXejXA+mC1OUx8sUkR2I6rgdylHBhaMq3PDE=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":207984},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"d186e8aca042a67143ebc693365f66ae86911fce","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.18.3","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.1","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.4_1740770946893_0.20337761047980174","host":"s3://npm-registry-packages-npm-production"}},"1.1.5":{"name":"kafka-ts","version":"1.1.5","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.5","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"2b56d6f18124692f25932aefe66cd4f5954973ff","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.5.tgz","fileCount":119,"integrity":"sha512-GlC+VuA/f6fz/JuyP1Db0CzbcESGMM8DrxIzFkpuwdNSu4ES9kGaXClhmEphrfnlYzoPJsrOIiaAJ9FX3Lj1qQ==","signatures":[{"sig":"MEUCIQCllDOBbArhq7H5PWF0LZCdyqD5Baw3PFU+Ddcd+RlGmAIgYUOsVYfEFqQ69FkBW8Z3Z2O3A2A2hpneq3uNtyB3F7Q=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":208036},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"7a25943f2a01f7570ee0e84da896401412414950","scripts":{"up":"npm run down && KAFKA_VERSION=3.7.1 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=3.7.1 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.19.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^1.6.1","prettier":"^3.3.3","typescript":"^5.4.5","@types/node":"^20.12.12"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.5_1742990369032_0.42605357711558844","host":"s3://npm-registry-packages-npm-production"}},"1.1.6-beta.1":{"name":"kafka-ts","version":"1.1.6-beta.1","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.6-beta.1","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"71545d97f032154fbf7bf9962f6a81c759e4c357","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.6-beta.1.tgz","fileCount":119,"integrity":"sha512-XZ31zRKFnEcOvoPeAoZWyyXwqlrSX1CKZDZuc3k+20lX3U1a6kj9sOOhVvIK+0MbhvBw7xkaHe8PfGBudIUWUg==","signatures":[{"sig":"MEUCIQDNOmYWF3wN6/i24/VXFXV8Eh4c2zmng5D8mkYbagOQWAIgaqO66N+4+5Q9s6kKUnDwZ/utugXjAnCoJBzurDKVYpI=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":209590},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"727ca5785c64d735ff7459ecc25028c8e828274a","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.19.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.6-beta.1_1746600845177_0.07650147049588218","host":"s3://npm-registry-packages-npm-production"}},"1.1.6":{"name":"kafka-ts","version":"1.1.6","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.6","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"77c2c6d5102edbed3247c89a7a81399b3743131b","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.6.tgz","fileCount":119,"integrity":"sha512-eKRpFJlThdhBWr3g2cGLHywIhnJSN/M2NshWj7ADda1CaGy5sZaGNt62TQSQ9HkNw+c6YZhJo5X9usoJbarj6g==","signatures":[{"sig":"MEQCICyfdNw8k4GC4nTKkf7r/DUIwwZUYNG5sBb4PUAgIMg3AiBA3rcFp9DDp5CAQEU9bbTG9a25V8tqwDnwrPeZ8e/Zlg==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":210952},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"743471ba71794e84e196eee5064005793894d244","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.19.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.6_1747829968035_0.2876175269329353","host":"s3://npm-registry-packages-npm-production"}},"1.1.7":{"name":"kafka-ts","version":"1.1.7","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.7","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"728abca51c02ebd3546343e63d88310f36a170d5","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.7.tgz","fileCount":119,"integrity":"sha512-FYJCAPyVwpOOPXdldRTjHOBen9jwp/zTfJFe+OjkiTuwSml6J197Zh4na0GW0Kn2u00jTVFt5H7uPc/I12Xqdw==","signatures":[{"sig":"MEUCIQDzNaoYxBqKAjr/aB+uJUkyWPzAlixoUpWjf5e21Wgn1QIgFmEKqBpHQJyg6wMGN82uO9YKreOTOIjvn8MGr4B/v/8=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":216390},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"96cdf3bfd60b4459ab89ca4656fa5bba1df0ac9c","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.19.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.7_1747914746559_0.059403374935093956","host":"s3://npm-registry-packages-npm-production"}},"1.1.8":{"name":"kafka-ts","version":"1.1.8","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.8","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"254fcffaf5b091b64cb1c86911b18768a52b1120","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.8.tgz","fileCount":164,"integrity":"sha512-U3PTSBT25gjycJfjhnfMWnSyaLq65Ct9wmVinm9Ymy0NWlnfLYSLweb5Q1qcSQ+AeZesTaWLLmPwIv4FV0S8+Q==","signatures":[{"sig":"MEUCIQDVUmJwf8z/lNyxss4YHXBLKR6F6ScNH0rl+n1wl8JjXwIgFTpQgeBLMUtjXCkVMEOh3sqY2DIGAUHbOVpuRYu0T3Y=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":314771},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"22d259860f6585563c622dbbfb460c92aa2a3f4c","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.9.0","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"22.12.0","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.8_1748252608984_0.6477062130793425","host":"s3://npm-registry-packages-npm-production"}},"1.1.9":{"name":"kafka-ts","version":"1.1.9","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.1.9","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"c1c41d8e305a403c5fb1268e6a3e11f6a71970f1","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.1.9.tgz","fileCount":121,"integrity":"sha512-Qj0MrHc5QMpcsafuNV6SLcSda6MkgYV/q8L6HfFWv+PzQQKzX+VOZe9dF2VPcx/naO6fUVLiQCxKjCskvwHBDg==","signatures":[{"sig":"MEQCIH1qntOdtn5i2ALpOr34C7K6Sfp59puObp3OgbljJAQmAiBXyKVL7Xvw68VaOYF3I5i3OVS8uvh5kMKacafGxAgwBQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":217100},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"2a8d1f9a94ea176bc3c87866fa02835678fd18cc","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.19.2","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.1.9_1748853169945_0.097601891463857","host":"s3://npm-registry-packages-npm-production"}},"1.2.0":{"name":"kafka-ts","version":"1.2.0","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.2.0","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"b63834cb69e9956c46e1a56c5996282398e5958f","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.2.0.tgz","fileCount":125,"integrity":"sha512-O+I+1UshTZncUg8IQXU0nPsco2IdM5uAqbb1O4xU/WCSwLjcI9EkjDLfZpLYIORwfu99aGR2AbfkPfH60czcBg==","signatures":[{"sig":"MEQCIGhUOzJMU4gc7eISfETX8NcbBAn+FO7GZApnlHQ+c61sAiBGRO2C0tMh30Q17ZnvSMNnOJlMETpBWJLOsvk8vOwmUQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":219315},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"373113cf42bf34f8aac2c08b2825f75e081b0fe7","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.19.5","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.2.0_1759758059620_0.7018921208087376","host":"s3://npm-registry-packages-npm-production"}},"1.2.1":{"name":"kafka-ts","version":"1.2.1","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.2.1","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"376bfc5930eb5d46ac91471991a8fe6f629d79ec","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.2.1.tgz","fileCount":125,"integrity":"sha512-QEnZRRcmvec8C/EQKCedmGMCJEOxQ6S2LB5oIb2E/R4I8qTB2OqFkvTeSmiWA7V2xSNKthFVcxX+2ugsrpiYGw==","signatures":[{"sig":"MEUCIQDAJh+dS0mXKE2zgKh2YfxouS2LWV6F6GiU3OcA5/9pwgIgM0aA+c8GvUwY1ILLAZcdiyVK+7+MubaZ7nATagXpJrk=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":219405},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"e2a0f477769af3682e0c898dee75b09804f560c4","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.19.5","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.2.1_1762255617228_0.5311760037731659","host":"s3://npm-registry-packages-npm-production"}},"1.3.0":{"name":"kafka-ts","version":"1.3.0","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.0","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"d130fd85bc82356b55ec1be61939bdeb640224b5","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.0.tgz","fileCount":125,"integrity":"sha512-5+QwrUQnQvKU4rf5By5DyVSjIx7ISYUOyMCA0lJIuOH5eftlp9pv1jnf2u4q8YFDq+2CozLhYYy0kiff744HlQ==","signatures":[{"sig":"MEYCIQCiVQY+8/iDIBAX/96EOsQLBeYGUnNcuJuuNxIq8Wx3+gIhAIxiCUSXVl/vmIT+13BnTRO4oyUiJRoIe3TPnhKbol+A","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":220122},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"2c087eaf2d302455eb54eb952002c397c9beb43c","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.19.6","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.0_1765885445254_0.8477612731407509","host":"s3://npm-registry-packages-npm-production"}},"1.3.1-beta.0":{"name":"kafka-ts","version":"1.3.1-beta.0","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.1-beta.0","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"3a667ca68ebdc7bfe52d3c1162aa26729d579a96","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.1-beta.0.tgz","fileCount":127,"integrity":"sha512-TLtzLVh//TA18laNMn4tmuxS3iweXVsuKPa+25b7gadfPUl1rhLk/J2Qs9VIF2Ea6ua8320M9cPfTDv6aYNs7w==","signatures":[{"sig":"MEYCIQDyiUgK1+fQteFF8U65z9wp/jV0ldOYO4a7ZcrBV6Ib+wIhAMGjj5cwauOiaEEr8W63s+IhqPufWScJCuhl8JH4jI+t","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":223810},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"9bca1ac8e99b8ff004e1a73edd298001c422e263","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.19.6","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.1-beta.0_1766153751423_0.9031645965819419","host":"s3://npm-registry-packages-npm-production"}},"1.3.1-beta.1":{"name":"kafka-ts","version":"1.3.1-beta.1","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.1-beta.1","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"9547317b07ebfa6dff80f7565c9128c451e7c8c3","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.1-beta.1.tgz","fileCount":129,"integrity":"sha512-ibwL6Tg0ocVtV6YitZuD01wdHH/sOm9I01W7vA5rQNV39p4ejSOUhK0TMXRIfdRChIEpB4EWAQdG7BdGOzutIw==","signatures":[{"sig":"MEQCIEmUv6HkQV7/M8fr0EzrgrP+MFaszHYhBFMa56qQ+01rAiACl7LSoBvKLQI90jICjN5eRA0mTR2SCbOBuEy20r5CsA==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":224218},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"b337c9cee10860593edea25decc2f6e32d55a385","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.19.6","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.1-beta.1_1766396146946_0.894763601767326","host":"s3://npm-registry-packages-npm-production"}},"1.3.1-beta.2":{"name":"kafka-ts","version":"1.3.1-beta.2","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.1-beta.2","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"f78fc3c3a296455fb004d5b09d0c5eee69cd7ace","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.1-beta.2.tgz","fileCount":184,"integrity":"sha512-iM+apj7KJPAg6XyRudSgondx0WDiFGenNaizGuzBsP0DuGZ17+LwwCKUoZMRgDGR9PWNMvaZjVG84PN2RCjmxw==","signatures":[{"sig":"MEQCIFEmk9gP8pHmZrQXIP/++NZIl/On9IcPjSlWK0wf7PmVAiA0NnIHrypiSOJVi/389jSxvfIuU8xd0LV39uzNG9tQPQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":370963},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"9740ece7db690cc40c2073661a9792af7d5e531c","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.9.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"22.17.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.1-beta.2_1766411714979_0.7336669962487792","host":"s3://npm-registry-packages-npm-production"}},"1.3.1-beta.3":{"name":"kafka-ts","version":"1.3.1-beta.3","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.1-beta.3","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"a873b5f9d5f82b075df6457b2c37c0828acfc4bc","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.1-beta.3.tgz","fileCount":184,"integrity":"sha512-2/uzg7lYGngkvAcXzHc8Po7slaFEPPAwxoUiHLNLY8vS99g1+kvbibYTlZgwAagnzgAfq1cVQpOy0xie29rzpw==","signatures":[{"sig":"MEUCIBxB1Xl+p3Gyf/SkzPW4LreZABR5GDUR42WvaBz049oyAiEA1wqXWOhcQn1z7MBOMeTSa4P43n8TW/EOwc354hFZG/M=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":371161},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"9740ece7db690cc40c2073661a9792af7d5e531c","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.9.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"22.17.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.1-beta.3_1766412570861_0.2844001238465159","host":"s3://npm-registry-packages-npm-production"}},"1.3.1-beta.4":{"name":"kafka-ts","version":"1.3.1-beta.4","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.1-beta.4","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"9083f1caba5bdda55e5ad2bc9cb525c1ae87ec93","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.1-beta.4.tgz","fileCount":184,"integrity":"sha512-43lSuigWh5lHM6sRXPRHFCr7+KmQw4+yQ5Naf/SXQRYuop3X0QR9ezDLZLv8W65KGqE9jXY4USSzEiHEVXGcnw==","signatures":[{"sig":"MEUCIEzLkWRF8BjZ2ZLdQcmvEnsiCvbYEatXooygTZiUc+B9AiEAvQ/8uJHouj9x0BPgYcu/Wid8Xtr3LyzeU59w2NDlm5A=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":371048},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"12031d7d8428046c43c15d3e39f8e2bbd492dd57","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.9.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"22.17.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.1-beta.4_1766415495937_0.5251507473094179","host":"s3://npm-registry-packages-npm-production"}},"1.3.1-beta.5":{"name":"kafka-ts","version":"1.3.1-beta.5","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.1-beta.5","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"58c4839eb9eca651480516444a1509abc40143ec","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.1-beta.5.tgz","fileCount":184,"integrity":"sha512-rXAUSsT6GSLtsWEJkynoR+mMELe3sP1ycvg/P33mVq8CzmNSBNJ4y0iDqXaX7IESafWKnHDeG4e80uTRIAQ2Lg==","signatures":[{"sig":"MEUCIDrDDqQy0pHffItniuHVPdJEjkge/Q7qfbsMl7VEDeKZAiEAjvK+to2d7Y07T0kQ73D/bGDiQXKHguxYqW2cHljvzeM=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":371723},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"12031d7d8428046c43c15d3e39f8e2bbd492dd57","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.9.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"22.17.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.1-beta.5_1766417344076_0.896831219080416","host":"s3://npm-registry-packages-npm-production"}},"1.3.1-beta.6":{"name":"kafka-ts","version":"1.3.1-beta.6","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.1-beta.6","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"1c9061c752ede5a8b0d3e3edeb1df690d7ba5bc9","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.1-beta.6.tgz","fileCount":184,"integrity":"sha512-kh9vurCEVtNX/o135BaqmwF8bLHAU6twv6L6qyH/RK3M0/3Mc/Pc6IuUwnNxHIhxaSZJMicNkZC33UQY9joerA==","signatures":[{"sig":"MEYCIQD4drrKYh+5lDuKL5L60R9BMU+9c0Cj5v2zESXdC+QEDgIhANpH8IZcgvEWrQvv/XeL/K6+QUSTzLkirsTLulrUD9Na","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":373553},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"12031d7d8428046c43c15d3e39f8e2bbd492dd57","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.9.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"22.17.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.1-beta.6_1766419681046_0.5654537887012023","host":"s3://npm-registry-packages-npm-production"}},"1.3.1":{"name":"kafka-ts","version":"1.3.1","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.1","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"5e4efc8f484e38ab08435c5088f6931becb69f49","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.1.tgz","fileCount":132,"integrity":"sha512-H0TzACYd1xFT3u7Nl6kX8izK7vqpgC9IjCZWT6nB4WD1OSBc2NwD8TH5i32dga9P9AtLdi5/249vRgyeAWnvjA==","signatures":[{"sig":"MEUCIQDJOH90q9dVgAhf4RJ2bmuvukpqo/j3zA7qhKWjHTtAhAIgVoGo9zgwEV/ntBA9330k765sb0TUMQLU6VMV2u9G/5o=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":274389},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"6b2a8f4ae8a4779962d99dd7f5d4866abfd85f48","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.19.6","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.1_1766995712137_0.11235613302315994","host":"s3://npm-registry-packages-npm-production"}},"1.3.2-beta.0":{"name":"kafka-ts","version":"1.3.2-beta.0","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.2-beta.0","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"56e22d32db5ba6ebafe737cb9c37890e1f613872","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.2-beta.0.tgz","fileCount":132,"integrity":"sha512-SU6KmjtIW1CJ49+F9I1c1J9XIybOb7mvaqyMyo+rsEXpvUp+gu9DTZON4eTF9jhQow1rCFsDhoMVLRwAHcZbow==","signatures":[{"sig":"MEUCIQC2p5cNyCP/D+lZ4YmFSyrVnX7tWf1tsBn2QX70dTHKrgIgc9XCGTohi3uDpLRbG/K5gEVVKroi0FIOVFsYGg/bo9Y=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":274654},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"43ad65ec71b7795626a210a6780241361cc77cd8","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.19.6","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.2-beta.0_1767000027053_0.030158705606258218","host":"s3://npm-registry-packages-npm-production"}},"1.3.2-beta.1":{"name":"kafka-ts","version":"1.3.2-beta.1","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.2-beta.1","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"262b7e43b00e081f1e4d2f15acbafd612f59f3ec","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.2-beta.1.tgz","fileCount":185,"integrity":"sha512-1z6DzRF3OMEIRcyYi5dlWgW14TXXw7lV5DyuJa0tqbFEzdzk2TqMLIuaMGRAyfyy01FNblOqYWu2b4rdJicUOw==","signatures":[{"sig":"MEUCIQD8UZwJTT10X/OEambLm8LU7i1DKhnDApu0Ay1UgCDIgQIgRV3bVG+eHsCXuSz7Js547NTGtyR5rY1sqECmJol2zjI=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":378741},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"43ad65ec71b7795626a210a6780241361cc77cd8","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.9.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"22.17.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.2-beta.1_1767001755361_0.5603189877028343","host":"s3://npm-registry-packages-npm-production"}},"1.3.2-beta.2":{"name":"kafka-ts","version":"1.3.2-beta.2","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.2-beta.2","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"fb00bf80d9d1a3c979b0d8f0fb1cc59e1a8193d9","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.2-beta.2.tgz","fileCount":185,"integrity":"sha512-a/KXXUrXzExUA+R8ZJeOuQMqDq7skUuYcexfUYueRX5fdUfueZ1ux/RsuT24E3Aefd4nP/l+55j8T2oqBsCdjg==","signatures":[{"sig":"MEQCIFXL0uBgGse6ytQFlsz86WEooun56ZyjCFP/4cAyEIC1AiBuiqb4Q3fCFVd4xE8E6GuVJwwfq6QFsrciTJuLVY/CxQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":379105},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"43ad65ec71b7795626a210a6780241361cc77cd8","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.9.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"22.17.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.2-beta.2_1767004174437_0.3904014621771734","host":"s3://npm-registry-packages-npm-production"}},"1.3.2-beta.3":{"name":"kafka-ts","version":"1.3.2-beta.3","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.2-beta.3","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"2df6c56f8fd304b17fa6c8e835098282f6e75475","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.2-beta.3.tgz","fileCount":185,"integrity":"sha512-cfj6sCfQBHjwDziQsic2HYl1HpUhVsTbtB+z8+fjPotGImkmjGKB3WAbvml3f4JoqDoA07Q5cimRkUd7uibTMQ==","signatures":[{"sig":"MEUCIQDDfUODcO4zOI07p+rtxu0hQvoLuCq2KaSwIjmCng5KvQIgPbED+o1rOsK51Ulg97Papl7KGGlkRZKebWpFjnDBQMU=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":379027},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"43ad65ec71b7795626a210a6780241361cc77cd8","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.9.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"22.17.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.2-beta.3_1767005233485_0.9964855259592027","host":"s3://npm-registry-packages-npm-production"}},"1.3.2-beta.4":{"name":"kafka-ts","version":"1.3.2-beta.4","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.2-beta.4","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"2b3dad0b145a3154149e3f0f86d0443b0c03c2f9","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.2-beta.4.tgz","fileCount":185,"integrity":"sha512-tzfOrI71H3VfTZTPTJ95RBkn8taKcTK20UuCvufio5/YE2+GNhQuwzOQ+fx33MMJgsLrTMC7ICkH9PW/nmZa2g==","signatures":[{"sig":"MEUCIQCqjUNyc6jL6rBxyYOBq3mPWH8HJlx6iXL07yJsx7C9OwIgG+DDRP3vCYGGFKPbzKiP2/tqPlbsiC8hqlAAF497RvE=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":380430},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"43ad65ec71b7795626a210a6780241361cc77cd8","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.9.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"22.17.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.2-beta.4_1767006112037_0.5692209532718056","host":"s3://npm-registry-packages-npm-production"}},"1.3.2-beta.5":{"name":"kafka-ts","version":"1.3.2-beta.5","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.2-beta.5","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"ff9c9a6069bc9ad3350dc4af3622e7ab8a2306e5","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.2-beta.5.tgz","fileCount":185,"integrity":"sha512-+X7IpwWT9XE5DW5QvMkJul3Vdg13jyrm2RucLJ6h2lyrtc0e8sFAlZBkXf40ycNaLoe+MtOMuOcPUCkoj8YTZQ==","signatures":[{"sig":"MEQCIHfO+OId6uyQPbCkta4LQs6w30Hs539k8gDh+VIgrW7qAiBW7WzNiaHyYFjdpO8gjsHPD4/IhgZuTxAE9dvY4WJTQA==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":383106},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"43ad65ec71b7795626a210a6780241361cc77cd8","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.9.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"22.17.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.2-beta.5_1767011735233_0.4978960857766763","host":"s3://npm-registry-packages-npm-production"}},"1.3.2-beta.6":{"name":"kafka-ts","version":"1.3.2-beta.6","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.2-beta.6","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"6696375520130b9a366cca8c9e80203c09732ce2","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.2-beta.6.tgz","fileCount":185,"integrity":"sha512-TX6t2so0ghXd6WDL9xx/C1J3u09CmCJ0/lh2SVnMsgGIlp4CuENuqeH1H3joP5E5TeZ1mADtOPGr/LzoeVsSTw==","signatures":[{"sig":"MEYCIQD6ktNj9uWf9RSAyltkvxb7pIaT9AKCWcFexzDjoqEFxwIhAPB8Wa3CGfYuUouex6DJkcdcq+xbpOME4MakpJzE6K1p","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":387727},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"43ad65ec71b7795626a210a6780241361cc77cd8","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.9.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"22.17.1","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.2-beta.6_1767014201346_0.8689804598203488","host":"s3://npm-registry-packages-npm-production"}},"1.3.2":{"name":"kafka-ts","version":"1.3.2","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.2","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"cb0014fdd53b213b245a4612cf65304d1440c2ce","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.2.tgz","fileCount":132,"integrity":"sha512-hyGBURxo9CTfctiVjYZYxl21CeLVdZXaVav0t6cg90DLwqNF/w3WqyEAtWAn6rEvZz/AD/845i+aqhkPQMkEMA==","signatures":[{"sig":"MEQCIFPck9Y2F14Y27RJMgOPKkJ1ZFZ4moWuJ0aoym2YRAT9AiAZ+9YPN15n880V+XC8hqbCaqgsWPymBYO5QgaohZbGtQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":283363},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"f683637acd9ce40b1ff143a380315336a5351c76","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.19.6","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.2_1767015266098_0.10501533279202468","host":"s3://npm-registry-packages-npm-production"}},"1.3.3":{"name":"kafka-ts","version":"1.3.3","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.3.3","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"09cf157b00dac708cf91e7bf7092061ad35be10a","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.3.3.tgz","fileCount":132,"integrity":"sha512-6iNrey+OwbSl/SpBpT7028wkR0NfJ/CjzNevXriyehBxsdjB37WWRz5fexTOCi1K3IcAEqHA7EbdEDjR0b1InA==","signatures":[{"sig":"MEUCIQCZVuIqgFCkh3orLrNzKmk2wQbnOVixPMHvMzol/ux6sQIgTSOIhVDQuVMIEpmwktgSxqrlZzNf84KBEJaEFdHDE+o=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":283362},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"107ef2381313b4b03e33796e7d9f40d36d63d255","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.20.2","_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.1.1","prettier":"^3.5.3","typescript":"^5.8.3","@types/node":"^22.14.1"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.3.3_1783595167728_0.04343513800030907","host":"s3://npm-registry-packages-npm-production"}},"1.4.0":{"name":"kafka-ts","version":"1.4.0","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.4.0","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"34ebc0ead8b11bb0da53bc33f5557fde3338b3ae","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.4.0.tgz","fileCount":132,"integrity":"sha512-dAwzXdSL4NY80OKDIpopKkJ7tCxQkeTrlHtu+6ptfcaMxKe6cnbeXrZIah/+lJAchRoo/BCa0U1LucxtT7q9Ww==","signatures":[{"sig":"MEYCIQDLWuI8/5Vlh580TL2Bo0HKsLy3dv0FVnsAehT1EUzkRgIhANAhO7acO1Las9ZNcmw+qWxmjhLX2n1EX5sKbgVGPsvj","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":280419},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"ef881805e9454167eb08c3d0cef78d0941f6b55f","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc","watch":"tsc -w","format":"prettier --write .","typecheck":"tsc -p tsconfig.test.json","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.20.2","_hasShrinkwrap":false,"devDependencies":{"vitest":"^4.1.11","prettier":"^3.9.6","typescript":"^7.0.2","@types/node":"^26.3.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.4.0_1787660505288_0.5490776011207779","host":"s3://npm-registry-packages-npm-production"}},"1.4.1":{"name":"kafka-ts","version":"1.4.1","keywords":["kafka","client","producer","consumer"],"author":{"name":"Priit Käärd"},"license":"MIT","_id":"kafka-ts@1.4.1","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"homepage":"https://github.com/priitkaard/kafka-ts#readme","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"640e61d762c79bd339dcbc444bd20c52b7ee80d5","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.4.1.tgz","fileCount":195,"integrity":"sha512-bgl93nXbbJYXozNW6RAp46U2n5yeHkFwXXlb2f0tjRglOJdCQ5lVDkxKc5/74jDwsZT3bU8Lk157Oxhck9mh5w==","signatures":[{"sig":"MEQCIElUQNq1XyLud+TbUZThq1hSJ+rFNGFNetxtIt7QRAv7AiB3AwsCqyijMeq6abn9puN1YkY59TER+DJwq2VHUtAWjw==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEQCIAdkVITViwq6qkjUcjzu8fckODqgZasJ+7b/1ssGmas5AiAJN2lvBmk+vhVHD2l7gRVUGwVWf/XNXiBPbYwadQNqUA==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":688623},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"9a9b60f8416311d8a882cc8de795e2c0f6b13247","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc -p tsconfig.build.json","watch":"tsc -p tsconfig.build.json -w","format":"prettier --write .","typecheck":"tsc --noEmit","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"_nodeVersion":"20.20.2","_hasShrinkwrap":false,"devDependencies":{"vitest":"^4.1.11","prettier":"^3.9.6","typescript":"^7.0.2","@types/node":"^26.3.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.4.1_1790240476969_0.27046323403018735","host":"s3://npm-registry-packages-npm-production"}},"1.5.0":{"_id":"kafka-ts@1.5.0","bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"dist":{"shasum":"80e0fccd9aac53c027995a9d646d7f7e88448ac7","tarball":"https://registry.npmjs.org/kafka-ts/-/kafka-ts-1.5.0.tgz","fileCount":1455,"integrity":"sha512-G6fHf3dcAim5CiomTF9CM3fd/azv4OduROJBqcYLQtnX4NyO9AT4nd89lIrjZ0DPSHSkTeSFKmUUyrl0bntijw==","signatures":[{"sig":"MEQCIAv29wcV8UidLrdtsjlbzOYTh9Tp1IPX/dyUVej5xt91AiBaLofumfhchUyl0jF6up+UnrectTdLzdKFdON9jDw3ew==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEUCIQC82sqDweLDm2LDEueX8YaDioHLsJFRR/mxAOb5t40F1AIgTBuytwIGnuUp9d53tyaD2ZK2+f4ad7pSzNt62+AS9W8="}],"unpackedSize":2363805},"main":"dist/index.js","name":"kafka-ts","types":"./dist/index.d.ts","author":{"name":"Priit Käärd"},"gitHead":"cdc0246166d172ad7d7f1ac33452ce856f7f665d","license":"MIT","scripts":{"up":"npm run down && KAFKA_VERSION=4.0.0 docker-compose up -d && sleep 5 && bash ./scripts/create-scram-user.sh","down":"KAFKA_VERSION=4.0.0 docker-compose down","test":"vitest --testTimeout 60000 --bail 1","build":"tsc -p tsconfig.build.json","watch":"tsc -p tsconfig.build.json -w","format":"prettier --write .","typecheck":"tsc --noEmit","version:major":"npm version major","version:minor":"npm version minor","version:patch":"npm version patch","version:prerelease":"npm version prerelease --preid=beta"},"version":"1.5.0","_npmUser":{"name":"priitkaard","email":"priitkaard123@gmail.com"},"homepage":"https://github.com/priitkaard/kafka-ts#readme","keywords":["kafka","client","producer","consumer"],"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"_npmVersion":"10.8.2","description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","directories":{},"maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"_nodeVersion":"20.20.2","_hasShrinkwrap":false,"devDependencies":{"vitest":"^4.1.11","prettier":"^3.9.6","typescript":"^7.0.2","@types/node":"^26.3.0"},"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/kafka-ts_1.5.0_1790333679495_0.5229265156703298"}}},"time":{"created":"2024-10-20T12:18:47.046Z","modified":"2026-09-25T10:54:39.978Z","0.0.1":"2019-07-22T17:01:21.211Z","0.0.7":"2019-07-23T18:20:52.573Z","0.0.9":"2019-08-02T19:17:07.446Z","0.0.10":"2019-08-05T16:36:55.683Z","0.0.11":"2019-08-05T17:38:31.181Z","0.0.12":"2019-08-05T17:56:23.127Z","0.1.0":"2019-09-04T13:21:47.164Z","0.2.0":"2019-10-02T14:27:42.882Z","0.3.0":"2019-10-21T15:29:39.381Z","0.0.1-beta":"2024-10-20T12:18:47.332Z","0.0.2-beta":"2024-10-20T14:44:01.939Z","0.0.3-beta":"2024-10-21T16:55:11.660Z","0.0.1-beta.0":"2024-10-22T17:46:37.535Z","0.0.1-beta.1":"2024-10-22T19:01:07.330Z","0.0.1-beta.2":"2024-10-23T19:18:59.221Z","0.0.1-beta.3":"2024-10-23T19:29:20.550Z","0.0.1-beta.4":"2024-10-24T16:52:43.675Z","0.0.1-beta.6":"2024-10-29T12:19:18.489Z","0.0.2":"2024-10-29T12:23:53.276Z","0.0.3":"2024-10-29T12:57:14.295Z","0.0.4":"2024-10-30T13:55:56.454Z","0.0.5":"2024-10-31T15:50:43.133Z","0.0.6-beta.0":"2024-11-01T12:57:50.196Z","0.0.6-beta.1":"2024-11-01T14:10:32.506Z","0.0.6-beta.2":"2024-11-01T14:35:47.589Z","0.0.6-beta.3":"2024-11-01T15:19:15.644Z","0.0.6-beta.4":"2024-11-04T10:11:03.313Z","0.0.6-beta.5":"2024-11-04T10:18:25.760Z","0.0.6-beta.6":"2024-11-04T10:40:56.327Z","0.0.6-beta.7":"2024-11-04T10:49:24.574Z","0.0.6-beta.8":"2024-11-04T11:15:55.469Z","0.0.6":"2024-11-04T11:20:15.614Z","0.0.8":"2024-11-04T13:34:26.981Z","0.0.9-beta.0":"2024-11-04T14:17:32.220Z","0.0.13":"2024-11-04T14:21:40.714Z","0.0.14":"2024-11-04T14:34:15.128Z","0.0.16":"2024-11-05T09:32:58.589Z","0.0.17-beta.0":"2024-11-07T13:05:46.886Z","0.0.17-beta.1":"2024-11-07T16:20:47.114Z","0.0.17-beta.2":"2024-11-07T18:34:00.192Z","0.0.17-beta.3":"2024-11-08T12:12:29.237Z","0.0.17":"2024-11-08T17:41:42.406Z","1.0.0":"2024-11-13T13:54:44.027Z","1.0.1":"2024-11-13T15:19:50.729Z","1.0.2":"2024-11-13T19:15:34.368Z","1.0.3":"2024-11-19T16:04:21.128Z","1.1.0":"2024-11-20T16:38:46.315Z","1.1.1":"2024-11-20T16:58:43.957Z","1.1.2-beta.0":"2024-12-10T14:51:15.308Z","1.1.2-beta.1":"2024-12-10T15:00:32.124Z","1.1.2-beta.2":"2024-12-10T15:07:13.252Z","1.1.2-beta.3":"2024-12-12T09:39:29.147Z","1.1.2-beta.4":"2024-12-12T10:41:15.076Z","1.1.2":"2024-12-12T10:55:42.014Z","1.1.3-beta.0":"2025-02-19T11:23:35.873Z","0.0.9-0":"2025-02-19T11:23:37.005Z","1.1.3":"2025-02-22T17:33:49.563Z","1.1.4":"2025-02-28T19:29:07.075Z","1.1.5":"2025-03-26T11:59:29.224Z","1.1.6-beta.1":"2025-05-07T06:54:05.397Z","1.1.6":"2025-05-21T12:19:28.243Z","1.1.7":"2025-05-22T11:52:26.789Z","1.1.8":"2025-05-26T09:43:29.192Z","1.1.9":"2025-06-02T08:32:50.154Z","1.2.0":"2025-10-06T13:40:59.798Z","1.2.1":"2025-11-04T11:26:57.426Z","1.3.0":"2025-12-16T11:44:05.403Z","1.3.1-beta.0":"2025-12-19T14:15:51.620Z","1.3.1-beta.1":"2025-12-22T09:35:47.088Z","1.3.1-beta.2":"2025-12-22T13:55:15.139Z","1.3.1-beta.3":"2025-12-22T14:09:31.046Z","1.3.1-beta.4":"2025-12-22T14:58:16.089Z","1.3.1-beta.5":"2025-12-22T15:29:04.235Z","1.3.1-beta.6":"2025-12-22T16:08:01.193Z","1.3.1":"2025-12-29T08:08:32.288Z","1.3.2-beta.0":"2025-12-29T09:20:27.187Z","1.3.2-beta.1":"2025-12-29T09:49:15.517Z","1.3.2-beta.2":"2025-12-29T10:29:34.668Z","1.3.2-beta.3":"2025-12-29T10:47:13.650Z","1.3.2-beta.4":"2025-12-29T11:01:52.207Z","1.3.2-beta.5":"2025-12-29T12:35:35.394Z","1.3.2-beta.6":"2025-12-29T13:16:41.517Z","1.3.2":"2025-12-29T13:34:26.379Z","1.3.3":"2026-07-09T11:06:07.949Z","1.4.0":"2026-08-25T12:21:45.443Z","1.4.1":"2026-09-24T09:01:17.059Z","1.5.0":"2026-09-25T10:54:39.586Z"},"bugs":{"url":"https://github.com/priitkaard/kafka-ts/issues"},"author":{"name":"Priit Käärd"},"license":"MIT","homepage":"https://github.com/priitkaard/kafka-ts#readme","keywords":["kafka","client","producer","consumer"],"repository":{"url":"git+https://github.com/priitkaard/kafka-ts.git","type":"git"},"description":"**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.","maintainers":[{"name":"priitkaard","email":"priitkaard123@gmail.com"}],"readme":"# KafkaTS\n\n**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.\n\n**Tested Kafka versions:** 3.7.2, 3.8.1, 3.9.1, 4.0.1, 4.1.1, 4.2.0, 4.3.0\n\nEvery request is sent with the highest protocol version supported by both KafkaTS and the broker, so older and newer brokers work as long as they support the oldest API versions listed in the [Kafka protocol specification](https://kafka.apache.org/protocol). See [Supported APIs](#supported-apis).\n\n## Installation\n\n```bash\nnpm install kafka-ts\n```\n\n## Quick start\n\n### Create kafka client\n\n```typescript\nexport const kafka = createKafkaClient({\n    clientId: 'my-app',\n    bootstrapServers: [{ host: 'localhost', port: 9092 }],\n});\n```\n\n#### Consuming messages\n\n```typescript\nconst consumer = await kafka.startConsumer({\n    groupId: 'my-consumer-group',\n    topics: ['my-topic'],\n    onBatch: (messages) => {\n        console.log(messages);\n    },\n});\n```\n\n#### Producing messages\n\n```typescript\nexport const producer = kafka.createProducer();\n\nawait producer.send([{ topic: 'my-topic', key: 'key', value: 'value' }]);\n```\n\n#### Low-level API\n\n```typescript\nconst cluster = kafka.createCluster();\nawait cluster.connect();\n\nconst { controllerId } = await cluster.sendRequest(API.METADATA, {\n    allowTopicAutoCreation: false,\n    includeTopicAuthorizedOperations: false,\n    topics: [],\n});\n\nawait cluster.sendRequestToNode(controllerId)(API.CREATE_TOPICS, {\n    validateOnly: false,\n    timeoutMs: 10_000,\n    topics: [\n        {\n            name: 'my-topic',\n            numPartitions: 10,\n            replicationFactor: 3,\n            assignments: [],\n            configs: [],\n        },\n    ],\n});\n\nawait cluster.disconnect();\n```\n\n#### Graceful shutdown\n\n```typescript\nprocess.once('SIGTERM', async () => {\n    await consumer.close(); // waits for the consumer to finish processing the last batch and disconnects\n    await producer.close();\n});\n```\n\nSee the [examples](./examples) for more detailed examples.\n\n#### Logging\n\nBy default KafkaTS logs out using a JSON logger. This can be globally replaced by calling setLogger method (see [src/utils/logger.ts](./src/utils/logger.ts))\n\n#### Retries\n\nBy default KafkaTS retries `onBatch` using an exponential backoff delay up to 5 times (see [src/utils/retrier.ts](./src/utils/retrier.ts)). In case of failure the consumer is restarted.\n\nIn case you want to skip failed messages or implement a DLQ-like mechanism, you can overwrite `retrier` on `startConsumer()` and execute your own logic `onFailure`.\n\nExample if you simply want to skip the failing messages:\n\n```typescript\nawait kafka.startConsumer({\n    // ...\n    retrier: createExponentialBackoffRetrier({ onFailure: () => {} }),\n});\n```\n\n#### Static membership\n\nSetting `groupInstanceId` makes the consumer a static group member. A static member doesn't leave the group when it is closed, so it keeps its partitions for `sessionTimeoutMs`. A new consumer that starts with the same `groupInstanceId` within that time takes over the partitions without rebalancing the rest of the group, and a consumer still running with that id is fenced and closes itself. This allows replacing instances one by one (e.g. during a rolling deployment) without stalling the other consumers.\n\nUse a stable, unique `groupInstanceId` per instance (e.g. the pod name of a StatefulSet) and a `sessionTimeoutMs` longer than the time it takes to replace an instance. When an instance is removed for good, its partitions are reassigned after `sessionTimeoutMs`.\n\n```typescript\nconst consumer = await kafka.startConsumer({\n    groupId: 'my-consumer-group',\n    groupInstanceId: process.env.HOSTNAME,\n    sessionTimeoutMs: 60_000,\n    topics: ['my-topic'],\n    onBatch: (messages) => console.log(messages),\n});\n```\n\n#### Partitioning\n\nBy default, messages are partitioned by message key or round-robin if the key is null or undefined. Partition can be overwritten by `partition` property in the message. You can also override the default partitioner per producer instance `kafka.createProducer({ partitioner: customPartitioner })`.\n\n**Keyed messages change partition in 1.4.0.** The default partitioner's murmur2 lost precision on the 32-bit multiplications before 1.4.0, so it disagreed with the Java client for most keys. It is now byte-for-byte identical, which means a key can hash to a different partition than it did in 1.3.3 - about 8 in 10 keys move on a 6-partition topic. Both partitioners are live during a rolling upgrade, so per-key ordering is not preserved across it, and keys written before the upgrade stay co-partitioned by the old assignment. If either matters, drain the topic before upgrading, or keep the old assignment by copying the 1.3.3 `murmur2` into a custom `partitioner`.\n\nA simple example how to partition messages by the value in message header `x-partition-key`:\n\n```typescript\nimport type { Partitioner } from 'kafka-ts';\nimport { defaultPartitioner } from 'kafka-ts';\n\nconst myPartitioner: Partitioner = (context) => {\n    const partition = defaultPartitioner(context);\n    return (message) => partition({ ...message, key: message.headers?.['x-partition-key'] });\n};\n\nconst producer = kafka.createProducer({ partitioner: myPartitioner });\n\nawait producer.send([{ topic: 'my-topic', value: 'value', headers: { 'x-partition-key': '123' } }]);\n```\n\n## Motivation\n\nThe existing low-level libraries (e.g. node-rdkafka) are bindings on librdkafka, which doesn't give enough control over the consumer logic.\nThe existing high-level libraries (e.g. kafkajs) are missing a few crucial features.\n\n### New features compared to kafkajs\n\n- **Static consumer membership** - Rebalancing during rolling deployments causes delays. Using `groupInstanceId` in addition to `groupId` can avoid rebalancing and continue consuming partitions in the existing assignment.\n- **Consuming messages without consumer groups** - When you don't need the consumer to track the partition offsets, you can simply create a consumer without groupId and always either start consuming messages from the beginning or from the latest partition offset.\n- **Low-level API requests** - It's possible to communicate directly with the Kafka cluster using the kafka api protocol.\n\n## Benchmarks\n\nCompared with [kafkajs](https://github.com/tulios/kafkajs) and librdkafka (via [@confluentinc/kafka-javascript](https://github.com/confluentinc/confluent-kafka-javascript)). Median of 3 runs:\n\n|                             |  kafka-ts | kafkajs | librdkafka |\n| --------------------------- | --------: | ------: | ---------: |\n| Consume throughput (msg/s)  | 1,692,047 | 589,623 |    241,488 |\n| Produce throughput (msg/s)  |   214,500 | 151,100 |     76,650 |\n| End-to-end latency avg (ms) |         6 |     107 |         11 |\n| End-to-end latency p99 (ms) |        20 |     182 |         20 |\n\n- **Consume throughput** - time to consume a backlog of 1,000,000 messages, from the first message to the last.\n- **Produce throughput** - awaited sends of 1,000 messages at a time for 20 seconds.\n- **End-to-end latency** - time from send to consume while producing 10 messages every 10ms.\n\nWhy the others are slower:\n\n- **kafkajs** commits offsets after every batch (the default `autoCommit`) and waits for the commit before fetching again. It also doesn't fetch the next batch while the current one is being processed. At 1,000 messages/s that is ~130 commits per second, which leaves each fetcher idle ~80ms between fetches.\n- **librdkafka** does its networking in native threads, but every message crosses into JavaScript individually: each produced message is a separate native call that resolves on its own delivery report, and consumed messages are pulled from librdkafka's queue and converted into JavaScript objects before reaching `eachBatch`. The producer also waits up to `linger.ms` (5ms by default) to batch messages.\n\nSetup: Apple M1 Max, Node.js 24.13, Kafka 4.0.0 with 3 brokers in Docker, SASL_SSL, 10 partitions, replication factor 3, `acks: -1`, 100-byte messages. kafka-ts 1.4.1, kafkajs 2.2.4, @confluentinc/kafka-javascript 1.10.1 (librdkafka 2.15.1) using its KafkaJS-compatible API with `js.consumer.max.batch.size: -1`. All other settings are defaults.\n\nTo run them yourself, start the local cluster with `npm run up`, then run `npm run build` and `cd examples && npm install && npm run benchmark`.\n\n## Configuration\n\n### `createKafkaClient()`\n\n| Name             | Type                   | Required | Default | Description                                          |\n| ---------------- | ---------------------- | -------- | ------- | ---------------------------------------------------- |\n| clientId         | string                 | false    | _null_  | The client id used for all requests.                 |\n| bootstrapServers | TcpSocketConnectOpts[] | true     |         | List of kafka brokers for initial cluster discovery. |\n| sasl             | SASLProvider           | false    |         | SASL provider                                        |\n| ssl              | TLSSocketOptions       | false    |         | SSL configuration.                                   |\n| requestTimeout   | number                 | false    | 60000   | Request timeout in milliseconds.                     |\n| connectTimeout   | number                 | false    | 10000   | Connect and handshake timeout in milliseconds.       |\n\n#### Supported SASL mechanisms\n\n- PLAIN: `saslPlain({ username, password })`\n- SCRAM-SHA-256: `saslScramSha256({ username, password })`\n- SCRAM-SHA-512: `saslScramSha512({ username, password })`\n- OAUTHBEARER: `oAuthBearer(oAuthAuthenticator({ endpoint, clientId, clientSecret }))`\n\nCustom SASL mechanisms can be implemented following the `SASLProvider` interface. See [src/auth](./src/auth) for examples.\n\n### `kafka.startConsumer()`\n\n| Name                   | Type                                   | Required | Default                         | Description                                                                          |\n| ---------------------- | -------------------------------------- | -------- | ------------------------------- | ------------------------------------------------------------------------------------ |\n| topics                 | string[]                               | true     |                                 | List of topics to subscribe to                                                       |\n| groupId                | string                                 | false    | _null_                          | Consumer group id                                                                    |\n| groupInstanceId        | string                                 | false    | _null_                          | Static group member id (see [Static membership](#static-membership))                 |\n| groupProtocol          | 'classic' \\| 'consumer'                | false    | 'classic'                       | Group protocol. `'consumer'` uses the incremental rebalance protocol (Kafka 4.0+)    |\n| rackId                 | string                                 | false    | _null_                          | Rack id                                                                              |\n| isolationLevel         | IsolationLevel                         | false    | IsolationLevel.READ_UNCOMMITTED | Isolation level                                                                      |\n| sessionTimeoutMs       | number                                 | false    | 30000                           | Session timeout in milliseconds (classic protocol only)                              |\n| rebalanceTimeoutMs     | number                                 | false    | 60000                           | Rebalance timeout in milliseconds                                                    |\n| maxWaitMs              | number                                 | false    | 5000                            | Fetch long poll timeout in milliseconds. Must be lower than `requestTimeout`.        |\n| minBytes               | number                                 | false    | 1                               | Minimum number of bytes to wait for before returning a fetch response                |\n| maxBytes               | number                                 | false    | 52_428_800                      | Maximum number of bytes to return in the fetch response                              |\n| partitionMaxBytes      | number                                 | false    | 1_048_576                       | Maximum number of bytes to return per partition in the fetch response                |\n| allowTopicAutoCreation | boolean                                | false    | false                           | Allow kafka to auto-create topic when it doesn't exist                               |\n| fromTimestamp          | bigint                                 | false    | -1                              | Start consuming messages from timestamp (-1 = latest offsets, -2 = earliest offsets) |\n| onBatch                | (batch: Message[]) => Promise<unknown> | true     |                                 | Callback executed when a batch of messages is received                               |\n\n### `kafka.createProducer()`\n\n| Name                   | Type        | Required | Default            | Description                                                                             |\n| ---------------------- | ----------- | -------- | ------------------ | --------------------------------------------------------------------------------------- |\n| allowTopicAutoCreation | boolean     | false    | false              | Allow kafka to auto-create topic when it doesn't exist                                  |\n| partitioner            | Partitioner | false    | defaultPartitioner | Custom partitioner function. By default, it uses a default java-compatible partitioner. |\n| maxBatchSize           | number      | false    | 500                | Maximum number of messages from separate `send()` calls batched into one request.       |\n| maxRetries             | number      | false    | 5                  | Maximum number of retries per `send()` after a recoverable error.                       |\n| retryDelayMs           | number      | false    | 100                | Delay before the first retry in milliseconds. Doubled on every subsequent attempt.      |\n| maxRetryDelayMs        | number      | false    | 3000               | Upper bound for the exponential retry delay in milliseconds.                            |\n\nRetries resend the same batch with the same producer id and sequence, so the broker discards duplicates. A message may be written twice only if `send()` rejects and is called again.\n\n### `producer.send(messages: Message[])`\n\n<!-- export type Message = {\n    topic: string;\n    partition?: number;\n    timestamp?: bigint;\n    key?: Buffer | null;\n    value: Buffer | null;\n    headers?: Record<string, string>;\n}; -->\n\n| Name      | Type                   | Required | Default | Description                                                                                                                |\n| --------- | ---------------------- | -------- | ------- | -------------------------------------------------------------------------------------------------------------------------- |\n| topic     | string                 | true     |         | Topic to send the message to                                                                                               |\n| partition | number                 | false    | _null_  | Partition to send the message to. By default partitioned by key. If key is also missing, partition is assigned round-robin |\n| timestamp | bigint                 | false    | _null_  | Message timestamp in milliseconds                                                                                          |\n| key       | Buffer \\| null         | false    | _null_  | Message key                                                                                                                |\n| value     | Buffer \\| null         | true     |         | Message value                                                                                                              |\n| headers   | Record<string, string> | false    | _null_  | Message headers                                                                                                            |\n\n## Supported APIs\n\nAll client-facing APIs of the [Kafka protocol](https://kafka.apache.org/protocol) are implemented in every version listed in the protocol specification, and are available through the low-level API (`cluster.sendRequest(API.<CONSTANT>, request)`). Each request uses the highest version supported by both KafkaTS and the broker.\n\n| Key | API                          | Constant                              | Versions | Supported |\n| --- | ---------------------------- | ------------------------------------- | -------- | :-------: |\n| 0   | Produce                      | `API.PRODUCE`                         | 3–13     |    ✅     |\n| 1   | Fetch                        | `API.FETCH`                           | 4–18     |    ✅     |\n| 2   | ListOffsets                  | `API.LIST_OFFSETS`                    | 1–11     |    ✅     |\n| 3   | Metadata                     | `API.METADATA`                        | 0–13     |    ✅     |\n| 8   | OffsetCommit                 | `API.OFFSET_COMMIT`                   | 2–10     |    ✅     |\n| 9   | OffsetFetch                  | `API.OFFSET_FETCH`                    | 1–10     |    ✅     |\n| 10  | FindCoordinator              | `API.FIND_COORDINATOR`                | 0–6      |    ✅     |\n| 11  | JoinGroup                    | `API.JOIN_GROUP`                      | 0–9      |    ✅     |\n| 12  | Heartbeat                    | `API.HEARTBEAT`                       | 0–4      |    ✅     |\n| 13  | LeaveGroup                   | `API.LEAVE_GROUP`                     | 0–5      |    ✅     |\n| 14  | SyncGroup                    | `API.SYNC_GROUP`                      | 0–5      |    ✅     |\n| 15  | DescribeGroups               | `API.DESCRIBE_GROUPS`                 | 0–6      |    ✅     |\n| 16  | ListGroups                   | `API.LIST_GROUPS`                     | 0–5      |    ✅     |\n| 17  | SaslHandshake                | `API.SASL_HANDSHAKE`                  | 0–1      |    ✅     |\n| 18  | ApiVersions                  | `API.API_VERSIONS`                    | 0–4      |    ✅     |\n| 19  | CreateTopics                 | `API.CREATE_TOPICS`                   | 2–7      |    ✅     |\n| 20  | DeleteTopics                 | `API.DELETE_TOPICS`                   | 1–6      |    ✅     |\n| 21  | DeleteRecords                | `API.DELETE_RECORDS`                  | 0–2      |    ✅     |\n| 22  | InitProducerId               | `API.INIT_PRODUCER_ID`                | 0–6      |    ✅     |\n| 23  | OffsetForLeaderEpoch         | `API.OFFSET_FOR_LEADER_EPOCH`         | 2–4      |    ✅     |\n| 24  | AddPartitionsToTxn           | `API.ADD_PARTITIONS_TO_TXN`           | 0–5      |    ✅     |\n| 25  | AddOffsetsToTxn              | `API.ADD_OFFSETS_TO_TXN`              | 0–4      |    ✅     |\n| 26  | EndTxn                       | `API.END_TXN`                         | 0–5      |    ✅     |\n| 27  | WriteTxnMarkers              | `API.WRITE_TXN_MARKERS`               | 1–2      |    ✅     |\n| 28  | TxnOffsetCommit              | `API.TXN_OFFSET_COMMIT`               | 0–5      |    ✅     |\n| 29  | DescribeAcls                 | `API.DESCRIBE_ACLS`                   | 1–3      |    ✅     |\n| 30  | CreateAcls                   | `API.CREATE_ACLS`                     | 1–3      |    ✅     |\n| 31  | DeleteAcls                   | `API.DELETE_ACLS`                     | 1–3      |    ✅     |\n| 32  | DescribeConfigs              | `API.DESCRIBE_CONFIGS`                | 1–4      |    ✅     |\n| 33  | AlterConfigs                 | `API.ALTER_CONFIGS`                   | 0–2      |    ✅     |\n| 34  | AlterReplicaLogDirs          | `API.ALTER_REPLICA_LOG_DIRS`          | 1–2      |    ✅     |\n| 35  | DescribeLogDirs              | `API.DESCRIBE_LOG_DIRS`               | 1–5      |    ✅     |\n| 36  | SaslAuthenticate             | `API.SASL_AUTHENTICATE`               | 0–2      |    ✅     |\n| 37  | CreatePartitions             | `API.CREATE_PARTITIONS`               | 0–3      |    ✅     |\n| 38  | CreateDelegationToken        | `API.CREATE_DELEGATION_TOKEN`         | 1–3      |    ✅     |\n| 39  | RenewDelegationToken         | `API.RENEW_DELEGATION_TOKEN`          | 1–2      |    ✅     |\n| 40  | ExpireDelegationToken        | `API.EXPIRE_DELEGATION_TOKEN`         | 1–2      |    ✅     |\n| 41  | DescribeDelegationToken      | `API.DESCRIBE_DELEGATION_TOKEN`       | 1–3      |    ✅     |\n| 42  | DeleteGroups                 | `API.DELETE_GROUPS`                   | 0–2      |    ✅     |\n| 43  | ElectLeaders                 | `API.ELECT_LEADERS`                   | 0–2      |    ✅     |\n| 44  | IncrementalAlterConfigs      | `API.INCREMENTAL_ALTER_CONFIGS`       | 0–1      |    ✅     |\n| 45  | AlterPartitionReassignments  | `API.ALTER_PARTITION_REASSIGNMENTS`   | 0–1      |    ✅     |\n| 46  | ListPartitionReassignments   | `API.LIST_PARTITION_REASSIGNMENTS`    | 0        |    ✅     |\n| 47  | OffsetDelete                 | `API.OFFSET_DELETE`                   | 0        |    ✅     |\n| 48  | DescribeClientQuotas         | `API.DESCRIBE_CLIENT_QUOTAS`          | 0–1      |    ✅     |\n| 49  | AlterClientQuotas            | `API.ALTER_CLIENT_QUOTAS`             | 0–1      |    ✅     |\n| 50  | DescribeUserScramCredentials | `API.DESCRIBE_USER_SCRAM_CREDENTIALS` | 0        |    ✅     |\n| 51  | AlterUserScramCredentials    | `API.ALTER_USER_SCRAM_CREDENTIALS`    | 0        |    ✅     |\n| 55  | DescribeQuorum               | `API.DESCRIBE_QUORUM`                 | 0–2      |    ✅     |\n| 57  | UpdateFeatures               | `API.UPDATE_FEATURES`                 | 0–2      |    ✅     |\n| 60  | DescribeCluster              | `API.DESCRIBE_CLUSTER`                | 0–2      |    ✅     |\n| 61  | DescribeProducers            | `API.DESCRIBE_PRODUCERS`              | 0        |    ✅     |\n| 64  | UnregisterBroker             | `API.UNREGISTER_BROKER`               | 0        |    ✅     |\n| 65  | DescribeTransactions         | `API.DESCRIBE_TRANSACTIONS`           | 0        |    ✅     |\n| 66  | ListTransactions             | `API.LIST_TRANSACTIONS`               | 0–2      |    ✅     |\n| 68  | ConsumerGroupHeartbeat       | `API.CONSUMER_GROUP_HEARTBEAT`        | 0–1      |    ✅     |\n| 69  | ConsumerGroupDescribe        | `API.CONSUMER_GROUP_DESCRIBE`         | 0–1      |    ✅     |\n| 71  | GetTelemetrySubscriptions    | `API.GET_TELEMETRY_SUBSCRIPTIONS`     | 0        |    ✅     |\n| 72  | PushTelemetry                | `API.PUSH_TELEMETRY`                  | 0        |    ✅     |\n| 74  | ListConfigResources          | `API.LIST_CONFIG_RESOURCES`           | 0–1      |    ✅     |\n| 75  | DescribeTopicPartitions      | `API.DESCRIBE_TOPIC_PARTITIONS`       | 0        |    ✅     |\n| 76  | ShareGroupHeartbeat          | `API.SHARE_GROUP_HEARTBEAT`           | 1        |    ✅     |\n| 77  | ShareGroupDescribe           | `API.SHARE_GROUP_DESCRIBE`            | 1        |    ✅     |\n| 78  | ShareFetch                   | `API.SHARE_FETCH`                     | 1–2      |    ✅     |\n| 79  | ShareAcknowledge             | `API.SHARE_ACKNOWLEDGE`               | 1–2      |    ✅     |\n| 80  | AddRaftVoter                 | `API.ADD_RAFT_VOTER`                  | 0–1      |    ✅     |\n| 81  | RemoveRaftVoter              | `API.REMOVE_RAFT_VOTER`               | 0        |    ✅     |\n| 83  | InitializeShareGroupState    | `API.INITIALIZE_SHARE_GROUP_STATE`    | 0        |    ✅     |\n| 84  | ReadShareGroupState          | `API.READ_SHARE_GROUP_STATE`          | 0        |    ✅     |\n| 85  | WriteShareGroupState         | `API.WRITE_SHARE_GROUP_STATE`         | 0–1      |    ✅     |\n| 86  | DeleteShareGroupState        | `API.DELETE_SHARE_GROUP_STATE`        | 0        |    ✅     |\n| 87  | ReadShareGroupStateSummary   | `API.READ_SHARE_GROUP_STATE_SUMMARY`  | 0–1      |    ✅     |\n| 88  | StreamsGroupHeartbeat        | `API.STREAMS_GROUP_HEARTBEAT`         | 0        |    ✅     |\n| 89  | StreamsGroupDescribe         | `API.STREAMS_GROUP_DESCRIBE`          | 0        |    ✅     |\n| 90  | DescribeShareGroupOffsets    | `API.DESCRIBE_SHARE_GROUP_OFFSETS`    | 0–1      |    ✅     |\n| 91  | AlterShareGroupOffsets       | `API.ALTER_SHARE_GROUP_OFFSETS`       | 0        |    ✅     |\n| 92  | DeleteShareGroupOffsets      | `API.DELETE_SHARE_GROUP_OFFSETS`      | 0        |    ✅     |\n","readmeFilename":"README.md"}