{"_id":"@alt-stack/workers-warpstream","_rev":"10-389ea7adedf63010250fba33397cd107","name":"@alt-stack/workers-warpstream","dist-tags":{"latest":"1.6.2"},"versions":{"0.0.1":{"name":"@alt-stack/workers-warpstream","version":"0.0.1","keywords":["kafka","warpstream","workers","jobs","queue","typescript","zod"],"author":"","license":"MIT","_id":"@alt-stack/workers-warpstream@0.0.1","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"06f98bbe1d18c9ea6f8960e2ae35f3b5a2f9c2ce","tarball":"https://registry.npmjs.org/@alt-stack/workers-warpstream/-/workers-warpstream-0.0.1.tgz","fileCount":14,"integrity":"sha512-FORfYRGobj3+TyScedvaG0scLElhLV+WRIiFAYHTOnrTdqEQnB33eN+r7MoEPlij7I8pu31T4BdDalqMPaATGQ==","signatures":[{"sig":"MEQCIHHyTqU+guNaM+GEsnulsIqcT1Iqh3yJigPvPXumC2EPAiBxjIBycDRCRc5XWgBO08AHNu7YdjqjW8+42IxfIQ0wYw==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":90266},"main":"./dist/index.js","_from":"file:alt-stack-workers-warpstream-0.0.1.tgz","types":"./dist/index.d.ts","module":"./dist/index.mjs","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.mjs","require":"./dist/index.js"}},"scripts":{"test":"vitest","build":"tsup","check-types":"tsc --noEmit"},"_npmUser":{"name":"aaltieri","email":"anthony@timebyping.com"},"_resolved":"/private/var/folders/ff/zvy71s_n7rxb4v2fjzqyrzv40000gn/T/cd306d32f9e45cb4c482ff268cc81154/alt-stack-workers-warpstream-0.0.1.tgz","_integrity":"sha512-FORfYRGobj3+TyScedvaG0scLElhLV+WRIiFAYHTOnrTdqEQnB33eN+r7MoEPlij7I8pu31T4BdDalqMPaATGQ==","_npmVersion":"11.6.2","description":"WarpStream/Kafka integration for @alt-stack/workers-core","directories":{},"_nodeVersion":"22.21.1","dependencies":{"@alt-stack/workers-core":"0.2.0"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.0.0","typescript":"^5.9.2","@types/node":"^22.0.0"},"peerDependencies":{"zod":"^3.25.0 || ^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/workers-warpstream_0.0.1_1764542102418_0.17932745134078432","host":"s3://npm-registry-packages-npm-production"}},"0.0.2":{"name":"@alt-stack/workers-warpstream","version":"0.0.2","keywords":["kafka","warpstream","workers","jobs","queue","typescript","zod"],"author":"","license":"MIT","_id":"@alt-stack/workers-warpstream@0.0.2","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"409f4e40b67d4305f094b1bda7468cd4e22cee0f","tarball":"https://registry.npmjs.org/@alt-stack/workers-warpstream/-/workers-warpstream-0.0.2.tgz","fileCount":15,"integrity":"sha512-mhaVozhln1LeIw6RY9+WgKWphCbLQHKhrFrZJBId5QrSGuo9DONBM8mCZp7NOL0fbkS7LijV01h5nKvjYvamEw==","signatures":[{"sig":"MEYCIQD8ziuQVPCpXtGClP4LJMRheEnhlRqj8R9PguLYAcDsSwIhALxwqeHlbKGYXwCSfEOweuFwlOX2P1ustEFG2JMCtvDS","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":91647},"main":"./dist/index.js","_from":"file:alt-stack-workers-warpstream-0.0.2.tgz","types":"./dist/index.d.ts","module":"./dist/index.mjs","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.mjs","require":"./dist/index.js"}},"scripts":{"test":"vitest","build":"tsup","check-types":"tsc --noEmit"},"_npmUser":{"name":"aaltieri","email":"anthony@timebyping.com"},"_resolved":"/tmp/04a7238b81a1b73731bf9fd7a5c2f19d/alt-stack-workers-warpstream-0.0.2.tgz","_integrity":"sha512-mhaVozhln1LeIw6RY9+WgKWphCbLQHKhrFrZJBId5QrSGuo9DONBM8mCZp7NOL0fbkS7LijV01h5nKvjYvamEw==","_npmVersion":"10.8.2","description":"WarpStream/Kafka integration for @alt-stack/workers-core","directories":{},"_nodeVersion":"20.19.6","dependencies":{"@alt-stack/workers-core":"0.3.0"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.0.0","typescript":"^5.9.2","@types/node":"^22.0.0"},"peerDependencies":{"zod":"^3.25.0 || ^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/workers-warpstream_0.0.2_1764886795242_0.4133444823581516","host":"s3://npm-registry-packages-npm-production"}},"0.0.3":{"name":"@alt-stack/workers-warpstream","version":"0.0.3","keywords":["kafka","warpstream","workers","jobs","queue","typescript","zod"],"author":"","license":"MIT","_id":"@alt-stack/workers-warpstream@0.0.3","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"1b23ab3e3f320b08647e85188fc8386d5e32a506","tarball":"https://registry.npmjs.org/@alt-stack/workers-warpstream/-/workers-warpstream-0.0.3.tgz","fileCount":15,"integrity":"sha512-jPZY9tHp7tUawkP29rHdCu004TGU3XUaapqT8ASkAkcQ/JFLyZy6akJh7wknB0cIXX6kPk4OETKW1UZSkMIDnw==","signatures":[{"sig":"MEQCIBmMUoueCNxiXw8Fb9R7ENWmVuzKbv51d4DH4K99FYqvAiA3ckUyFRbps3XU4k0qY6QqiX3H871cjJhlBLx5HClYug==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":91647},"main":"./dist/index.js","_from":"file:alt-stack-workers-warpstream-0.0.3.tgz","types":"./dist/index.d.ts","module":"./dist/index.mjs","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.mjs","require":"./dist/index.js"}},"scripts":{"test":"vitest","build":"tsup","check-types":"tsc --noEmit"},"_npmUser":{"name":"aaltieri","email":"anthony@timebyping.com"},"_resolved":"/tmp/0f2ad61fb6c9e8d7c64e41d6986f80ed/alt-stack-workers-warpstream-0.0.3.tgz","_integrity":"sha512-jPZY9tHp7tUawkP29rHdCu004TGU3XUaapqT8ASkAkcQ/JFLyZy6akJh7wknB0cIXX6kPk4OETKW1UZSkMIDnw==","_npmVersion":"10.8.2","description":"WarpStream/Kafka integration for @alt-stack/workers-core","directories":{},"_nodeVersion":"20.19.6","dependencies":{"@alt-stack/workers-core":"0.4.0"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.0.0","typescript":"^5.9.2","@types/node":"^22.0.0"},"peerDependencies":{"zod":"^3.25.0 || ^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/workers-warpstream_0.0.3_1765256834783_0.3030878196509781","host":"s3://npm-registry-packages-npm-production"}},"0.1.0":{"name":"@alt-stack/workers-warpstream","version":"0.1.0","keywords":["kafka","warpstream","workers","jobs","queue","typescript","zod"],"author":"","license":"MIT","_id":"@alt-stack/workers-warpstream@0.1.0","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"ef485c8f63814996218350b8167d5c1fb0726eb4","tarball":"https://registry.npmjs.org/@alt-stack/workers-warpstream/-/workers-warpstream-0.1.0.tgz","fileCount":15,"integrity":"sha512-VO5i7wbIzecJU+HUEiPfDgoaxN8A5pPM8Iyi2FhosX05cdNkwIQNrN1fE9NLCnxBnobIZMra60Zw2MsU1R+oqw==","signatures":[{"sig":"MEYCIQDWtmUXOzQDspdbaV90P/7lVltps5JIWS7xt1QQyrpqtQIhAMSUsHJgHeAG3b8QVDd/6Wlenlf0igpzrMmNGAEgdRMU","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":91647},"main":"./dist/index.js","_from":"file:alt-stack-workers-warpstream-0.1.0.tgz","types":"./dist/index.d.ts","module":"./dist/index.mjs","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.mjs","require":"./dist/index.js"}},"scripts":{"test":"vitest","build":"tsup","check-types":"tsc --noEmit"},"_npmUser":{"name":"aaltieri","email":"anthony@timebyping.com"},"_resolved":"/tmp/b7d270cf2e84a7b5e80bf094ee8f2c89/alt-stack-workers-warpstream-0.1.0.tgz","_integrity":"sha512-VO5i7wbIzecJU+HUEiPfDgoaxN8A5pPM8Iyi2FhosX05cdNkwIQNrN1fE9NLCnxBnobIZMra60Zw2MsU1R+oqw==","_npmVersion":"10.8.2","description":"WarpStream/Kafka integration for @alt-stack/workers-core","directories":{},"_nodeVersion":"20.19.6","dependencies":{"@alt-stack/workers-core":"0.6.0"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.0.0","typescript":"^5.9.2","@types/node":"^22.0.0"},"peerDependencies":{"zod":"^3.25.0 || ^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/workers-warpstream_0.1.0_1765326092145_0.9378842441416457","host":"s3://npm-registry-packages-npm-production"}},"1.4.0":{"name":"@alt-stack/workers-warpstream","version":"1.4.0","keywords":["kafka","warpstream","workers","jobs","queue","typescript","zod"],"author":"","license":"MIT","_id":"@alt-stack/workers-warpstream@1.4.0","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"28dbbe72e1dde670afea5d9be372790b593044b2","tarball":"https://registry.npmjs.org/@alt-stack/workers-warpstream/-/workers-warpstream-1.4.0.tgz","fileCount":17,"integrity":"sha512-hDZU4mBNBhBP7rEPWHK+39c3UZ1jukPdKKnE7u1E7keV0wGbUgEjJw++e2TFlfKxHGGOLeshnAC5joNXyxfbmA==","signatures":[{"sig":"MEYCIQD9dFc21QHvzecE4DFwHGh1b3e9MVrbwfsqRHXBDKVCDAIhAM6npUDZeHmwnxrZwm6vHXEvehQmmWwtf2C00D6Cw3oa","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":121730},"main":"./dist/index.js","_from":"file:alt-stack-workers-warpstream-1.4.0.tgz","types":"./dist/index.d.ts","module":"./dist/index.mjs","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.mjs","require":"./dist/index.js"}},"scripts":{"test":"vitest","build":"tsup","check-types":"tsc --noEmit"},"_npmUser":{"name":"aaltieri","email":"anthony@timebyping.com"},"_resolved":"/tmp/cb0a59eb95fd6dafde67f6212d96131c/alt-stack-workers-warpstream-1.4.0.tgz","_integrity":"sha512-hDZU4mBNBhBP7rEPWHK+39c3UZ1jukPdKKnE7u1E7keV0wGbUgEjJw++e2TFlfKxHGGOLeshnAC5joNXyxfbmA==","_npmVersion":"10.8.2","description":"WarpStream/Kafka integration for @alt-stack/workers-core","directories":{},"_nodeVersion":"20.20.2","dependencies":{"@alt-stack/workers-core":"1.4.0"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.0.0","typescript":"^5.9.2","@types/node":"^22.0.0","@opentelemetry/api":"^1.9.0","@opentelemetry/sdk-trace-base":"^2.0.0","@opentelemetry/sdk-trace-node":"^2.0.0"},"peerDependencies":{"zod":"^3.25.0 || ^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/workers-warpstream_1.4.0_1783621697545_0.8845437015426925","host":"s3://npm-registry-packages-npm-production"}},"1.5.0":{"name":"@alt-stack/workers-warpstream","version":"1.5.0","keywords":["kafka","warpstream","workers","jobs","queue","typescript","zod"],"author":"","license":"MIT","_id":"@alt-stack/workers-warpstream@1.5.0","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"daabad5840d6357f93ce16c9a2d4be701659f0e3","tarball":"https://registry.npmjs.org/@alt-stack/workers-warpstream/-/workers-warpstream-1.5.0.tgz","fileCount":18,"integrity":"sha512-B8lMrNoMqxUNd65V0IKTAU2uAUlHWNQX2FCMcolw2m9n+wcWoXFsPBM+eB0GSininubfDrHob5hibzuIzDIaBA==","signatures":[{"sig":"MEUCIB1LFvEwl+7l843yu96Lle8taj+FFeNtYeojMUEpEHnhAiEA1kGSXjSW+gVTyYbiS4A6+NmPBEhFywk8qZ+wfxWmkUI=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":123832},"main":"./dist/index.js","_from":"file:alt-stack-workers-warpstream-1.5.0.tgz","types":"./dist/index.d.ts","module":"./dist/index.mjs","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.mjs","require":"./dist/index.js"}},"scripts":{"test":"vitest","build":"tsup","check-types":"tsc --noEmit"},"_npmUser":{"name":"aaltieri","email":"anthony@timebyping.com"},"_resolved":"/tmp/ca98eeefb0539cae0042b9c53f070060/alt-stack-workers-warpstream-1.5.0.tgz","_integrity":"sha512-B8lMrNoMqxUNd65V0IKTAU2uAUlHWNQX2FCMcolw2m9n+wcWoXFsPBM+eB0GSininubfDrHob5hibzuIzDIaBA==","_npmVersion":"10.8.2","description":"WarpStream/Kafka integration for @alt-stack/workers-core","directories":{},"_nodeVersion":"20.20.2","dependencies":{"@alt-stack/workers-core":"1.5.0"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.0.0","typescript":"^5.9.2","@types/node":"^22.0.0","@opentelemetry/api":"^1.9.0","@opentelemetry/sdk-trace-base":"^2.0.0","@opentelemetry/sdk-trace-node":"^2.0.0"},"peerDependencies":{"zod":"^3.25.0 || ^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/workers-warpstream_1.5.0_1783713615817_0.8133728789543329","host":"s3://npm-registry-packages-npm-production"}},"1.5.1":{"name":"@alt-stack/workers-warpstream","version":"1.5.1","keywords":["kafka","warpstream","workers","jobs","queue","typescript","zod"],"author":"","license":"MIT","_id":"@alt-stack/workers-warpstream@1.5.1","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"af7439266b53f9a50dde178a1e3b7544d1eb4646","tarball":"https://registry.npmjs.org/@alt-stack/workers-warpstream/-/workers-warpstream-1.5.1.tgz","fileCount":18,"integrity":"sha512-30o0oIzHRay+DXsm9A7UK3AMxV3oXXQI9G8T73YkKNibKhUhVcrDcm4Bye0Y2hSiZdN9IVkA9iXTargVwgxraQ==","signatures":[{"sig":"MEYCIQDnraWXKzaV6KRCz0ZXVJXciqQb2/KjUHn/mCmAwGfSPAIhAOG1s6GysCvEBa5MYnBr+WEilel49Zlb5gtIjRR4ahVv","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":123896},"main":"./dist/index.js","_from":"file:alt-stack-workers-warpstream-1.5.1.tgz","types":"./dist/index.d.ts","module":"./dist/index.mjs","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.mjs","require":"./dist/index.js"}},"scripts":{"test":"vitest","build":"tsup","check-types":"tsc --noEmit"},"_npmUser":{"name":"aaltieri","email":"anthony@timebyping.com"},"_resolved":"/tmp/980089a892561c8bdbeed96e9a42ef70/alt-stack-workers-warpstream-1.5.1.tgz","_integrity":"sha512-30o0oIzHRay+DXsm9A7UK3AMxV3oXXQI9G8T73YkKNibKhUhVcrDcm4Bye0Y2hSiZdN9IVkA9iXTargVwgxraQ==","_npmVersion":"10.8.2","description":"WarpStream/Kafka integration for @alt-stack/workers-core","directories":{},"_nodeVersion":"20.20.2","dependencies":{"@alt-stack/workers-core":"1.5.1"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.0.0","typescript":"^5.9.2","@types/node":"^22.0.0","@opentelemetry/api":"^1.9.0","@opentelemetry/sdk-trace-base":"^2.0.0","@opentelemetry/sdk-trace-node":"^2.0.0"},"peerDependencies":{"zod":"^3.25.0 || ^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/workers-warpstream_1.5.1_1784059635630_0.5847838845080571","host":"s3://npm-registry-packages-npm-production"}},"1.6.0":{"name":"@alt-stack/workers-warpstream","version":"1.6.0","keywords":["kafka","warpstream","workers","jobs","queue","typescript","zod"],"author":"","license":"MIT","_id":"@alt-stack/workers-warpstream@1.6.0","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"755a7630682cb6fe19c49b9ab47013b4c8eb6c52","tarball":"https://registry.npmjs.org/@alt-stack/workers-warpstream/-/workers-warpstream-1.6.0.tgz","fileCount":18,"integrity":"sha512-ZyId+Ik9hTdUYR/FyNcDpOl5Rmwxbmg/F6o8IVFbFYpgU7sJkgRRvXqqe1x0CkYHc6xPgjFjhzhsexZh+o21hQ==","signatures":[{"sig":"MEQCIClFMXVarh5hPT4yGPWxnVVnklP8e7CEBUENCzJY3npxAiA50hBu4X392c4uSaAjK3itbXZFdTT1PZkgOEtJktDunQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":123956},"main":"./dist/index.js","_from":"file:alt-stack-workers-warpstream-1.6.0.tgz","types":"./dist/index.d.ts","module":"./dist/index.mjs","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.mjs","require":"./dist/index.js"}},"scripts":{"test":"vitest","build":"tsup","check-types":"tsc --noEmit"},"_npmUser":{"name":"aaltieri","email":"anthony@timebyping.com"},"_resolved":"/tmp/32faf6ac5636223a54c71d4c79ab517c/alt-stack-workers-warpstream-1.6.0.tgz","_integrity":"sha512-ZyId+Ik9hTdUYR/FyNcDpOl5Rmwxbmg/F6o8IVFbFYpgU7sJkgRRvXqqe1x0CkYHc6xPgjFjhzhsexZh+o21hQ==","_npmVersion":"10.8.2","description":"WarpStream/Kafka integration for @alt-stack/workers-core","directories":{},"_nodeVersion":"20.20.2","dependencies":{"@alt-stack/workers-core":"1.6.0"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.0.0","typescript":"^5.9.2","@types/node":"^22.0.0","@opentelemetry/api":"^1.9.0","@opentelemetry/sdk-trace-base":"^2.0.0","@opentelemetry/sdk-trace-node":"^2.0.0"},"peerDependencies":{"zod":"^3.25.0 || ^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/workers-warpstream_1.6.0_1784714962339_0.32781689458481367","host":"s3://npm-registry-packages-npm-production"}},"1.6.1":{"name":"@alt-stack/workers-warpstream","version":"1.6.1","keywords":["kafka","warpstream","workers","jobs","queue","typescript","zod"],"author":"","license":"MIT","_id":"@alt-stack/workers-warpstream@1.6.1","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"d83a9b0de6c96863d97e30cd9a88715e93be3e46","tarball":"https://registry.npmjs.org/@alt-stack/workers-warpstream/-/workers-warpstream-1.6.1.tgz","fileCount":18,"integrity":"sha512-Oc8R0fkY9I9tPgJpMiWwCvAdXvAmm7oZX/ncVdGKfNvSTwg+vZECU9f9LqxP0eu+vP/3p+xJORjHLDopnyAb7g==","signatures":[{"sig":"MEUCIQD8cGpHgAoGvXdma+60fEwk6ErXKK4wmlTiaYd+wnGUMQIgFK10yIy914gnGuldvR3Q7avaPdTidZ55LYAxcc4g4cs=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":124020},"main":"./dist/index.js","_from":"file:alt-stack-workers-warpstream-1.6.1.tgz","types":"./dist/index.d.ts","module":"./dist/index.mjs","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.mjs","require":"./dist/index.js"}},"scripts":{"test":"vitest","build":"tsup","check-types":"tsc --noEmit"},"_npmUser":{"name":"aaltieri","email":"anthony@timebyping.com"},"_resolved":"/tmp/51158dd91e53b0a2e80eac3cccfde248/alt-stack-workers-warpstream-1.6.1.tgz","_integrity":"sha512-Oc8R0fkY9I9tPgJpMiWwCvAdXvAmm7oZX/ncVdGKfNvSTwg+vZECU9f9LqxP0eu+vP/3p+xJORjHLDopnyAb7g==","_npmVersion":"10.8.2","description":"WarpStream/Kafka integration for @alt-stack/workers-core","directories":{},"_nodeVersion":"20.20.2","dependencies":{"@alt-stack/workers-core":"1.6.1"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.0.0","typescript":"^5.9.2","@types/node":"^22.0.0","@opentelemetry/api":"^1.9.0","@opentelemetry/sdk-trace-base":"^2.0.0","@opentelemetry/sdk-trace-node":"^2.0.0"},"peerDependencies":{"zod":"^3.25.0 || ^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/workers-warpstream_1.6.1_1785249173108_0.37731303171146546","host":"s3://npm-registry-packages-npm-production"}},"1.6.2":{"name":"@alt-stack/workers-warpstream","version":"1.6.2","description":"WarpStream/Kafka integration for @alt-stack/workers-core","main":"./dist/index.js","module":"./dist/index.mjs","types":"./dist/index.d.ts","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.mjs","require":"./dist/index.js"}},"keywords":["kafka","warpstream","workers","jobs","queue","typescript","zod"],"author":"","license":"MIT","dependencies":{"@alt-stack/workers-core":"1.6.2"},"peerDependencies":{"kafkajs":"^2.0.0","zod":"^3.25.0 || ^4.0.0"},"devDependencies":{"@opentelemetry/api":"^1.9.0","@opentelemetry/sdk-trace-base":"^2.0.0","@opentelemetry/sdk-trace-node":"^2.0.0","@types/node":"^22.0.0","kafkajs":"^2.0.0","oxlint":"^1.24.0","tsup":"^8.0.0","typescript":"^5.9.2","vitest":"^4.0.3","zod":"^4.0.0"},"scripts":{"build":"tsup","test":"vitest","check-types":"tsc --noEmit"},"_id":"@alt-stack/workers-warpstream@1.6.2","_integrity":"sha512-DEunbaE19J1geuMOuOs1X4e/YgDVijvj71t6sZwU5+3ZAeTXG71xLd9C8M8phSHQcj+CMGjnyORGnmjjeBtpZQ==","_resolved":"/tmp/6eb4ed1b0b9e1744e4440ec731138f05/alt-stack-workers-warpstream-1.6.2.tgz","_from":"file:alt-stack-workers-warpstream-1.6.2.tgz","_nodeVersion":"20.20.2","_npmVersion":"10.8.2","dist":{"integrity":"sha512-DEunbaE19J1geuMOuOs1X4e/YgDVijvj71t6sZwU5+3ZAeTXG71xLd9C8M8phSHQcj+CMGjnyORGnmjjeBtpZQ==","shasum":"6551900a078241fe9836b3078a790b948e52b5b9","tarball":"https://registry.npmjs.org/@alt-stack/workers-warpstream/-/workers-warpstream-1.6.2.tgz","fileCount":18,"unpackedSize":124081,"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEUCIQDP/R5KwF1axW5IMlehZv/7hDtBQ4SdKqzINsI8feluMgIgIZw7aNVpOaV/XvzKoQrk4H54gF8J8D0aTXNrzO40DF4="}]},"_npmUser":{"name":"aaltieri","email":"anthony@timebyping.com"},"directories":{},"maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/workers-warpstream_1.6.2_1787164493967_0.534563299321859"},"_hasShrinkwrap":false}},"time":{"created":"2025-11-30T22:35:02.325Z","modified":"2026-08-19T18:34:54.329Z","0.0.1":"2025-11-30T22:35:02.617Z","0.0.2":"2025-12-04T22:19:55.374Z","0.0.3":"2025-12-09T05:07:14.929Z","0.1.0":"2025-12-10T00:21:32.332Z","1.4.0":"2026-07-09T18:28:17.697Z","1.5.0":"2026-07-10T20:00:15.957Z","1.5.1":"2026-07-14T20:07:15.786Z","1.6.0":"2026-07-22T10:09:22.479Z","1.6.1":"2026-07-28T14:32:53.503Z","1.6.2":"2026-08-19T18:34:54.105Z"},"license":"MIT","keywords":["kafka","warpstream","workers","jobs","queue","typescript","zod"],"description":"WarpStream/Kafka integration for @alt-stack/workers-core","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"readme":"# `@alt-stack/workers-warpstream`\n\nKafkaJS/WarpStream server and router-aware producer adapters for `@alt-stack/workers-core`.\n\n- `createWorker(router, options)` runs job procedures from Kafka messages.\n- `createJobClient(router, options)` validates and enqueues jobs using the live router.\n- every `workers-core` export is re-exported.\n\n## Requirements\n\n- Node.js 18+\n- KafkaJS 2.x\n- Zod 3.25+ or Zod 4\n- a reachable Kafka-compatible broker and provisioned job topics\n\n```bash\npnpm add @alt-stack/workers-warpstream kafkajs zod\n```\n\n## Worker and client\n\n```typescript\nimport {\n  createJobClient,\n  createWorker,\n  init,\n  ok,\n} from \"@alt-stack/workers-warpstream\";\nimport { z } from \"zod\";\n\nconst { router, procedure } = init();\n\nconst jobs = router({\n  resize: procedure\n    .input({ payload: z.object({ imageId: z.string() }) })\n    .task(async ({ input }) => {\n      console.info(input.imageId);\n      return ok();\n    }),\n});\n\nconst routing = { type: \"topic-per-job\", topicPrefix: \"jobs.\" } as const;\n\nconst worker = await createWorker(jobs, {\n  kafka: { brokers: [\"localhost:9092\"] },\n  groupId: \"image-workers-v1\",\n  routing,\n});\n\nconst client = await createJobClient(jobs, {\n  kafka: { brokers: [\"localhost:9092\"] },\n  routing,\n});\n\nawait client.enqueue(\"resize\", { imageId: \"img_123\" });\n```\n\nPass the same routing to both sides. Topic-per-job concatenates prefix and job name directly. Single-queue routing publishes `{ jobName, payload }` envelopes to one topic.\n\nThe adapter does not schedule `.cron()` procedures and does not route by `.queue(name)`; all registered procedures are consumed by job-name routing. Returned `Err` values are normal handler returns, so throw to fail processing.\n\n```typescript\nawait client.disconnect();\nawait worker.disconnect();\n```\n\n## Documentation\n\n- [Common patterns](../../apps/docs/docs/workers/common-patterns.md)\n- [Complete WarpStream API](../../apps/docs/docs/workers/api/warpstream.md)\n- [Core API re-exported by this package](../../apps/docs/docs/workers/api/core.md)\n\n## License\n\nMIT\n","readmeFilename":"README.md"}