{"_id":"@alt-stack/kafka-core","_rev":"11-1a2d49cfc81a27b2d3995d21396dd5d2","name":"@alt-stack/kafka-core","dist-tags":{"latest":"1.6.2"},"versions":{"0.0.2":{"name":"@alt-stack/kafka-core","version":"0.0.2","keywords":[],"author":"","license":"MIT","_id":"@alt-stack/kafka-core@0.0.2","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"10174431cf5f3608f5de82623680781ddfe9871c","tarball":"https://registry.npmjs.org/@alt-stack/kafka-core/-/kafka-core-0.0.2.tgz","fileCount":28,"integrity":"sha512-0FSjLshD9+q5S8UNV/J7c1ohmV5xRmxQqa+VPjprU2CycBAGIC2p0ntDDrJgFoOw0CNJX/h4pMEAXzjitpoe1A==","signatures":[{"sig":"MEUCIAGILgPpR5y3Usl8aGacXQ3Z4VJ2IwzrHcMGBowW3D9WAiEA5f6pH0YpmugaChev0IOnSaTxHHCsM6WGGwDZRmeVjos=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":274749},"main":"./dist/index.js","_from":"file:alt-stack-kafka-core-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/97ec2eafb4b52e6b6f97f6deff03795f/alt-stack-kafka-core-0.0.2.tgz","_integrity":"sha512-0FSjLshD9+q5S8UNV/J7c1ohmV5xRmxQqa+VPjprU2CycBAGIC2p0ntDDrJgFoOw0CNJX/h4pMEAXzjitpoe1A==","_npmVersion":"10.8.2","description":"Type-safe Kafka consumer framework with Zod validation","directories":{},"_nodeVersion":"20.19.6","_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.2.4","typescript":"^5.9.2","@testcontainers/kafka":"^10.28.0"},"peerDependencies":{"zod":"^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-core_0.0.2_1764886787748_0.6600387290823386","host":"s3://npm-registry-packages-npm-production"}},"0.0.3":{"name":"@alt-stack/kafka-core","version":"0.0.3","keywords":[],"author":"","license":"MIT","_id":"@alt-stack/kafka-core@0.0.3","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"90b9f348a19ddf52693f0d034e7aa2c6d1bc422e","tarball":"https://registry.npmjs.org/@alt-stack/kafka-core/-/kafka-core-0.0.3.tgz","fileCount":28,"integrity":"sha512-0Uk4WGg/jP3twQ3EHD/Znv3kUPiXcezipqqcxbhbY08DYb6VZCG0cfsrVq3k3NHq1SmFytdtiEgM4SdRONRXIA==","signatures":[{"sig":"MEUCIQDOFOjg9h5xOkp9MesWtr1eVFWh/1yPRWDdv+fm5t70GAIgEw5p1b3k4FcCpMARMPH/qhmh0RDo8bGSHT+fkjErcQM=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":331110},"main":"./dist/index.js","_from":"file:alt-stack-kafka-core-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/0cfb0ba2e019c988fdbf53efcb2756b7/alt-stack-kafka-core-0.0.3.tgz","_integrity":"sha512-0Uk4WGg/jP3twQ3EHD/Znv3kUPiXcezipqqcxbhbY08DYb6VZCG0cfsrVq3k3NHq1SmFytdtiEgM4SdRONRXIA==","_npmVersion":"10.8.2","description":"Type-safe Kafka consumer framework with Zod validation","directories":{},"_nodeVersion":"20.19.6","dependencies":{"@alt-stack/result":"0.1.1"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.2.4","typescript":"^5.9.2","@testcontainers/kafka":"^10.28.0"},"peerDependencies":{"zod":"^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-core_0.0.3_1765256828008_0.4531864981802989","host":"s3://npm-registry-packages-npm-production"}},"0.0.4":{"name":"@alt-stack/kafka-core","version":"0.0.4","keywords":[],"author":"","license":"MIT","_id":"@alt-stack/kafka-core@0.0.4","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"ea66b2c598bbec145f40e3550624c88bd8cd70fa","tarball":"https://registry.npmjs.org/@alt-stack/kafka-core/-/kafka-core-0.0.4.tgz","fileCount":28,"integrity":"sha512-0/QnuypObXdCUJSFfDnGsJB8WM/kJfjCn8aWmQAA0WqTvwSg6ROWTswRwkFT7ElGRQ+Za1GbHpF+XNCRwbg3kg==","signatures":[{"sig":"MEUCIQCeKBXPcAqNa10G5ojk5tMV3IE3QZMC/cDDwEYfyjuEGAIgUiTpXKKFDCBRMdM71V9Kf47CfMX29AmOB7geFM8tUEI=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":331812},"main":"./dist/index.js","_from":"file:alt-stack-kafka-core-0.0.4.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/ba1031d2465e82354804b257912b22c7/alt-stack-kafka-core-0.0.4.tgz","_integrity":"sha512-0/QnuypObXdCUJSFfDnGsJB8WM/kJfjCn8aWmQAA0WqTvwSg6ROWTswRwkFT7ElGRQ+Za1GbHpF+XNCRwbg3kg==","_npmVersion":"10.8.2","description":"Type-safe Kafka consumer framework with Zod validation","directories":{},"_nodeVersion":"20.19.6","dependencies":{"@alt-stack/result":"0.1.4"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.2.4","typescript":"^5.9.2","@testcontainers/kafka":"^10.28.0"},"peerDependencies":{"zod":"^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-core_0.0.4_1765324739913_0.9570542360064596","host":"s3://npm-registry-packages-npm-production"}},"0.1.0":{"name":"@alt-stack/kafka-core","version":"0.1.0","keywords":[],"author":"","license":"MIT","_id":"@alt-stack/kafka-core@0.1.0","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"ae3bd698c0e5e20b0cf6b5f7f43d24f22b00dc48","tarball":"https://registry.npmjs.org/@alt-stack/kafka-core/-/kafka-core-0.1.0.tgz","fileCount":28,"integrity":"sha512-qoooqRMAl1mfQVXKUQVqnUmci2QVyjlCRia/qDDLRqNVWQsAwFQH4jzK9KnzZ9vu2TXq7+y5ReAwDq2qN70wMA==","signatures":[{"sig":"MEUCIDJtWleQcHinEoGvuT0arOv3rqfVeZmVPPDoVTVoachTAiEAzsJqQ9Wu/bGw6R7XmxMV0uPCXknIhCqznqLttVEEVU8=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":331981},"main":"./dist/index.js","_from":"file:alt-stack-kafka-core-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/1b5c462dd43a38ae94338bcc6d44fedc/alt-stack-kafka-core-0.1.0.tgz","_integrity":"sha512-qoooqRMAl1mfQVXKUQVqnUmci2QVyjlCRia/qDDLRqNVWQsAwFQH4jzK9KnzZ9vu2TXq7+y5ReAwDq2qN70wMA==","_npmVersion":"10.8.2","description":"Type-safe Kafka consumer framework with Zod validation","directories":{},"_nodeVersion":"20.19.6","dependencies":{"@alt-stack/result":"0.1.4"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.2.4","typescript":"^5.9.2","@testcontainers/kafka":"^10.28.0"},"peerDependencies":{"zod":"^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-core_0.1.0_1765326093997_0.27977599090827154","host":"s3://npm-registry-packages-npm-production"}},"0.1.1":{"name":"@alt-stack/kafka-core","version":"0.1.1","keywords":[],"author":"","license":"MIT","_id":"@alt-stack/kafka-core@0.1.1","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"fb7e28fa4adc45be9a5b68bfd021d90789a7eb3b","tarball":"https://registry.npmjs.org/@alt-stack/kafka-core/-/kafka-core-0.1.1.tgz","fileCount":28,"integrity":"sha512-1auWrXJWZ+sG40VGqbijMnleQicaKUxbOpJmfclpjdxx7QPs/nfGLh5C7BA8sVaT5YZFRL8GBFzGYF/PyMx4Sg==","signatures":[{"sig":"MEUCIG5+B+ZgaL8rrP0cImDBlfd2s/rkU21+BurA4YcDflcvAiEA4Qj431DE0yJFZ7a7LHsglAwdJ/dLCVfBr5TI78DVmjE=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":331981},"main":"./dist/index.js","_from":"file:alt-stack-kafka-core-0.1.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/440e8c13a6ce8bb4d021b77f4bd49c2f/alt-stack-kafka-core-0.1.1.tgz","_integrity":"sha512-1auWrXJWZ+sG40VGqbijMnleQicaKUxbOpJmfclpjdxx7QPs/nfGLh5C7BA8sVaT5YZFRL8GBFzGYF/PyMx4Sg==","_npmVersion":"10.8.2","description":"Type-safe Kafka consumer framework with Zod validation","directories":{},"_nodeVersion":"20.19.6","dependencies":{"@alt-stack/result":"0.1.4"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.2.4","typescript":"^5.9.2","@testcontainers/kafka":"^10.28.0"},"peerDependencies":{"zod":"^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-core_0.1.1_1765395363948_0.6226562557552895","host":"s3://npm-registry-packages-npm-production"}},"1.4.0":{"name":"@alt-stack/kafka-core","version":"1.4.0","keywords":[],"author":"","license":"MIT","_id":"@alt-stack/kafka-core@1.4.0","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"45630d8a2c018e0503678e2ee23b93b1efe848be","tarball":"https://registry.npmjs.org/@alt-stack/kafka-core/-/kafka-core-1.4.0.tgz","fileCount":29,"integrity":"sha512-n7/pTD0KBRVwaEu7fZv5tSj9nbyuVl7TBkBrNYFe9/cOrTuP3NsWpXcfNoS0T5v6Nop1qbPvLWQPD4kqT+hX3g==","signatures":[{"sig":"MEUCIA+CGq/cryXAbUpkFkBrb4P/zzPT0b6Mr8XZM8mECoyJAiEAsKM4WsX7iiJq5uTpixT4N2215sBySnwY5yis0y4Qtb4=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":332064},"main":"./dist/index.js","_from":"file:alt-stack-kafka-core-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/6f9b8b8c2f36e09811f5b2aa70c42a12/alt-stack-kafka-core-1.4.0.tgz","_integrity":"sha512-n7/pTD0KBRVwaEu7fZv5tSj9nbyuVl7TBkBrNYFe9/cOrTuP3NsWpXcfNoS0T5v6Nop1qbPvLWQPD4kqT+hX3g==","_npmVersion":"10.8.2","description":"Type-safe Kafka consumer framework with Zod validation","directories":{},"_nodeVersion":"20.20.2","dependencies":{"@alt-stack/result":"1.4.0"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.2.4","typescript":"^5.9.2","@testcontainers/kafka":"^10.28.0"},"peerDependencies":{"zod":"^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-core_1.4.0_1783621689323_0.16510851867401333","host":"s3://npm-registry-packages-npm-production"}},"1.5.0":{"name":"@alt-stack/kafka-core","version":"1.5.0","keywords":[],"author":"","license":"MIT","_id":"@alt-stack/kafka-core@1.5.0","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"cc86836ea234b799840134380332a51fcbd89250","tarball":"https://registry.npmjs.org/@alt-stack/kafka-core/-/kafka-core-1.5.0.tgz","fileCount":30,"integrity":"sha512-S+z8C2BxsNYsk6wTeMSvOVTJBHs2Np/txBGuXW/e35r9u1e5oAUeaNxS0zSnqk7oQuWn2J3qNbMT3SK+fmHNzw==","signatures":[{"sig":"MEUCIQCW9ouMbTzQpk/nTtiPDuqy+hmWWKDX8RSnyQLFRsvB+AIgJrIFukM5XSjGyVgwiuc/DpAgEccxpHiX+974ou7DnKw=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":334622},"main":"./dist/index.js","_from":"file:alt-stack-kafka-core-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/7ab8ad2b6ca2b11df28e7dd9f9a1f817/alt-stack-kafka-core-1.5.0.tgz","_integrity":"sha512-S+z8C2BxsNYsk6wTeMSvOVTJBHs2Np/txBGuXW/e35r9u1e5oAUeaNxS0zSnqk7oQuWn2J3qNbMT3SK+fmHNzw==","_npmVersion":"10.8.2","description":"Type-safe Kafka consumer framework with Zod validation","directories":{},"_nodeVersion":"20.20.2","dependencies":{"@alt-stack/result":"1.5.0"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.2.4","typescript":"^5.9.2","@testcontainers/kafka":"^10.28.0"},"peerDependencies":{"zod":"^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-core_1.5.0_1783713607525_0.7096962323188882","host":"s3://npm-registry-packages-npm-production"}},"1.5.1":{"name":"@alt-stack/kafka-core","version":"1.5.1","keywords":[],"author":"","license":"MIT","_id":"@alt-stack/kafka-core@1.5.1","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"e4f1b6efbd3e601d9a77cc32923ad78bb1278c90","tarball":"https://registry.npmjs.org/@alt-stack/kafka-core/-/kafka-core-1.5.1.tgz","fileCount":30,"integrity":"sha512-emMIvqyXKTjzZcsOYundC9teljrUMDN1gNepOkb+oVggbwdO83jNOvKqYHPvofMrtrWgwSOb8yCFqGjl0MMBjQ==","signatures":[{"sig":"MEUCICUgXjYUI2lZx1hxeKQJgy/O/kOt+kqZXLDyS/ZNUho3AiEA5XkLigbJxn511flL7Y20koeZQf75QojEkfRhm7AxwHI=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":334678},"main":"./dist/index.js","_from":"file:alt-stack-kafka-core-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/d9f6f57abd45df1620985010bb55e07c/alt-stack-kafka-core-1.5.1.tgz","_integrity":"sha512-emMIvqyXKTjzZcsOYundC9teljrUMDN1gNepOkb+oVggbwdO83jNOvKqYHPvofMrtrWgwSOb8yCFqGjl0MMBjQ==","_npmVersion":"10.8.2","description":"Type-safe Kafka consumer framework with Zod validation","directories":{},"_nodeVersion":"20.20.2","dependencies":{"@alt-stack/result":"1.5.1"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.2.4","typescript":"^5.9.2","@testcontainers/kafka":"^10.28.0"},"peerDependencies":{"zod":"^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-core_1.5.1_1784059626161_0.6153391125385637","host":"s3://npm-registry-packages-npm-production"}},"1.6.0":{"name":"@alt-stack/kafka-core","version":"1.6.0","keywords":[],"author":"","license":"MIT","_id":"@alt-stack/kafka-core@1.6.0","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"aa1865147c5c4c1530a50c385c135d05fb6285e9","tarball":"https://registry.npmjs.org/@alt-stack/kafka-core/-/kafka-core-1.6.0.tgz","fileCount":30,"integrity":"sha512-D59bU+YJ+0ERYWPMn5Gs4Pp5I8nWtCOvRNjXwgJPBZMieE4DmbYSpxQG7uTLM3Qob/XAVSOH6mVaoXIGGqNxJw==","signatures":[{"sig":"MEYCIQDGfDxDlfTZnKSajA+xg/c8kXYRPTMECExQro096f3hQQIhAORy4Kn/JiEnKG749zhgTKiQlZnS5buQ8Xu1z3HexkYs","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":334734},"main":"./dist/index.js","_from":"file:alt-stack-kafka-core-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/b287b619f3d0e9173df4db04c4704958/alt-stack-kafka-core-1.6.0.tgz","_integrity":"sha512-D59bU+YJ+0ERYWPMn5Gs4Pp5I8nWtCOvRNjXwgJPBZMieE4DmbYSpxQG7uTLM3Qob/XAVSOH6mVaoXIGGqNxJw==","_npmVersion":"10.8.2","description":"Type-safe Kafka consumer framework with Zod validation","directories":{},"_nodeVersion":"20.20.2","dependencies":{"@alt-stack/result":"1.6.0"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.2.4","typescript":"^5.9.2","@testcontainers/kafka":"^10.28.0"},"peerDependencies":{"zod":"^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-core_1.6.0_1784714953786_0.30056135532980144","host":"s3://npm-registry-packages-npm-production"}},"1.6.1":{"name":"@alt-stack/kafka-core","version":"1.6.1","keywords":[],"author":"","license":"MIT","_id":"@alt-stack/kafka-core@1.6.1","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"dist":{"shasum":"d365deee53726bc5d933d42a211d8374ec98c332","tarball":"https://registry.npmjs.org/@alt-stack/kafka-core/-/kafka-core-1.6.1.tgz","fileCount":30,"integrity":"sha512-VYipEodpDAnWW5xgDsjIJTKpNXe/40BarMmR7R4b1d3k4PsQXmvaePHevjyGEPUHXrAS0UPCeh7IUAr/b5CJCw==","signatures":[{"sig":"MEUCIQCLKaOjEN4z1TqjSS7/dVm8m0VktVdv4dKV7p73THCagwIgdfMVfOMXJls4CDsHI3SLGFzh/Oc5nrm7/MUK0byxrjs=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":334790},"main":"./dist/index.js","_from":"file:alt-stack-kafka-core-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/dcc0a17dd48e8e11a236ea83dd55202e/alt-stack-kafka-core-1.6.1.tgz","_integrity":"sha512-VYipEodpDAnWW5xgDsjIJTKpNXe/40BarMmR7R4b1d3k4PsQXmvaePHevjyGEPUHXrAS0UPCeh7IUAr/b5CJCw==","_npmVersion":"10.8.2","description":"Type-safe Kafka consumer framework with Zod validation","directories":{},"_nodeVersion":"20.20.2","dependencies":{"@alt-stack/result":"1.6.1"},"_hasShrinkwrap":false,"devDependencies":{"zod":"^4.0.0","tsup":"^8.0.0","oxlint":"^1.24.0","vitest":"^4.0.3","kafkajs":"^2.2.4","typescript":"^5.9.2","@testcontainers/kafka":"^10.28.0"},"peerDependencies":{"zod":"^4.0.0","kafkajs":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-core_1.6.1_1785249163589_0.8803362995831627","host":"s3://npm-registry-packages-npm-production"}},"1.6.2":{"name":"@alt-stack/kafka-core","version":"1.6.2","description":"Type-safe Kafka consumer framework with Zod validation","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":[],"author":"","license":"MIT","dependencies":{"@alt-stack/result":"1.6.2"},"peerDependencies":{"kafkajs":"^2.0.0","zod":"^4.0.0"},"devDependencies":{"@testcontainers/kafka":"^10.28.0","kafkajs":"^2.2.4","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/kafka-core@1.6.2","_integrity":"sha512-45o7+vUHbUnhBQe51cmuVBqndu7BwJfzUJI6SBQFkKxYGxBRC7W/8Mhn9P0D/4SLrMfUhHqtZ+YSVcOSnJS2BA==","_resolved":"/tmp/0f9acef9af6438d1da808d5096bd9205/alt-stack-kafka-core-1.6.2.tgz","_from":"file:alt-stack-kafka-core-1.6.2.tgz","_nodeVersion":"20.20.2","_npmVersion":"10.8.2","dist":{"integrity":"sha512-45o7+vUHbUnhBQe51cmuVBqndu7BwJfzUJI6SBQFkKxYGxBRC7W/8Mhn9P0D/4SLrMfUhHqtZ+YSVcOSnJS2BA==","shasum":"510dcdefad332953f632406b746529b6c6da6335","tarball":"https://registry.npmjs.org/@alt-stack/kafka-core/-/kafka-core-1.6.2.tgz","fileCount":30,"unpackedSize":334846,"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEUCIQCsFMJksTLSIsYsh5JZVp5dCq86Y4H1d/PZTSEfaKS/JAIgcgLNl/F72wekdTzzdRXgtteAqSBE19Ck/JGUGoantz4="}]},"_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/kafka-core_1.6.2_1787164483747_0.41245695170906616"},"_hasShrinkwrap":false}},"time":{"created":"2025-12-04T22:19:47.655Z","modified":"2026-08-19T18:34:44.138Z","0.0.2":"2025-12-04T22:19:47.898Z","0.0.3":"2025-12-09T05:07:08.152Z","0.0.4":"2025-12-09T23:59:00.039Z","0.1.0":"2025-12-10T00:21:34.181Z","0.1.1":"2025-12-10T19:36:04.104Z","1.4.0":"2026-07-09T18:28:09.483Z","1.5.0":"2026-07-10T20:00:07.660Z","1.5.1":"2026-07-14T20:07:06.298Z","1.6.0":"2026-07-22T10:09:14.005Z","1.6.1":"2026-07-28T14:32:43.773Z","1.6.2":"2026-08-19T18:34:43.913Z"},"license":"MIT","keywords":[],"description":"Type-safe Kafka consumer framework with Zod validation","maintainers":[{"name":"aaltieri","email":"anthony@timebyping.com"}],"readme":"# `@alt-stack/kafka-core`\n\nTyped Kafka event procedures, consumers, router-derived producers, middleware, and AsyncAPI 3.0 generation.\n\nUse this package when a service owns Kafka topic handlers or shares the live router with a producer. A producer-only application that consumes a generated contract should use `@alt-stack/kafka-client-kafkajs` or `@alt-stack/kafka-client-warpstream` instead. For named background jobs rather than domain events, use the Workers family.\n\n## Requirements\n\n- Node.js 18+\n- KafkaJS 2.x\n- Zod 4\n- a reachable Kafka-compatible broker and provisioned topics\n\n```bash\npnpm add @alt-stack/kafka-core kafkajs zod\n```\n\n## Define and consume an event\n\n```typescript\nimport { createConsumer, kafkaRouter, ok, publicProcedure } from \"@alt-stack/kafka-core\";\nimport { z } from \"zod\";\n\nconst events = kafkaRouter({\n  \"user-events\": publicProcedure\n    .input({\n      message: z.object({\n        userId: z.string(),\n        kind: z.enum([\"created\", \"renamed\"]),\n      }),\n    })\n    .subscribe(({ input, ctx }) => {\n      console.info(ctx.topic, `${input.kind}:${input.userId}`);\n      return ok();\n    }),\n});\n\nconst consumer = await createConsumer(events, {\n  kafka: { clientId: \"accounts\", brokers: [\"localhost:9092\"] },\n  groupId: \"accounts-v1\",\n});\n\nprocess.once(\"SIGTERM\", () => consumer.disconnect());\n```\n\n`createConsumer` connects, subscribes to every unique router topic from the latest offset for the group, starts KafkaJS `consumer.run`, and returns the KafkaJS `Consumer`.\n\n## Produce from the router\n\n```typescript\nimport { createProducer } from \"@alt-stack/kafka-core\";\n\nconst producer = await createProducer(events, {\n  kafka: { clientId: \"publisher\", brokers: [\"localhost:9092\"] },\n});\n\nawait producer.send(\"user-events\", {\n  userId: \"u_123\",\n  kind: \"created\",\n});\n\nawait producer.disconnect();\n```\n\nThe topic and payload are inferred from the router and validated before JSON encoding.\n\n## Important current behavior\n\nHandlers return Altstack `Result` objects, but the consumer does not currently treat `Err` as a Kafka failure. Throw when KafkaJS must observe a failed record. `.output(schema)` currently parses the entire Result envelope, and result-based middleware from `createMiddlewareWithErrors` is not unwrapped by the consumer.\n\n## Documentation\n\n- [Kafka quickstart](../../apps/docs/docs/kafka/quickstart.md)\n- [Common patterns](../../apps/docs/docs/kafka/common-patterns.md)\n- [Complete core API](../../apps/docs/docs/kafka/api/core.md)\n\n## License\n\nMIT\n","readmeFilename":"README.md"}