{"_id":"@anabranch/eventlog-kafka","_rev":"15-77144a318b3cc2503e04424fe9fec50a","name":"@anabranch/eventlog-kafka","dist-tags":{"latest":"0.2.12"},"versions":{"0.1.0":{"name":"@anabranch/eventlog-kafka","version":"0.1.0","license":"MIT","_id":"@anabranch/eventlog-kafka@0.1.0","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"dist":{"shasum":"d76c5c17bd55fc73d8060f4dd85125b7b0d8a9a8","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.1.0.tgz","fileCount":13,"integrity":"sha512-2Ql6L+QzgCG87w0v52g0z28ozE4vcVpJ+BGhh5oZfj6Y0rQ4xiyQozErcBpu3L3ynmHWXyr55WSjHLuCIzhj3Q==","signatures":[{"sig":"MEQCICyrbx7OIkcxMATE6CRfndNoQlGyaaEshJzrb5hBQYwgAiAlLTqKeovvpC7TB2fVCrSHaldErTw/A1oSEkGFWIqjoQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":36714},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"8bbf4c948ab6a0a42a2d6ff622155175a51437f3","scripts":{},"_npmUser":{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.9.0","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","directories":{},"_nodeVersion":"25.6.1","dependencies":{"kafkajs":"^2","@anabranch/eventlog":"^0"},"_hasShrinkwrap":false,"_npmOperationalInternal":{"tmp":"tmp/eventlog-kafka_0.1.0_1773104340146_0.805355825834358","host":"s3://npm-registry-packages-npm-production"}},"0.1.2":{"name":"@anabranch/eventlog-kafka","version":"0.1.2","license":"MIT","_id":"@anabranch/eventlog-kafka@0.1.2","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"dist":{"shasum":"8966011fd445dbc4d46c24b9162242c404143ce4","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.1.2.tgz","fileCount":13,"integrity":"sha512-tmWIY/ruAO3l4UzJOAwgwmQMH8c4hqx1zVnR+VyLM8J2B3dhc/mKScAXex+di0UjjiQuCy8E6kd9qRYOA9aOQg==","signatures":[{"sig":"MEQCIFv6Y8q4e5M9DkQb1IDHoVNQxW3nv/41jWseZygroIJVAiBkXYSKLa7UA7XrDZMm0asNEuPtboAMFnfqkx128SyWYA==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2feventlog-kafka@0.1.2","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":36801},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"444aecf89d5ac006cfb77b3f925051abee3ae516","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:2e6b5cf0-edc0-4790-924a-fd8ffa19ea95"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.0","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","directories":{},"_nodeVersion":"24.14.0","dependencies":{"kafkajs":"^2","@anabranch/eventlog":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/eventlog-kafka_0.1.2_1773104937867_0.052221002491050994","host":"s3://npm-registry-packages-npm-production"}},"0.2.0":{"name":"@anabranch/eventlog-kafka","version":"0.2.0","license":"MIT","_id":"@anabranch/eventlog-kafka@0.2.0","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"dist":{"shasum":"ff06b5905e0d427dad51590afd5b63c27eca534c","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.2.0.tgz","fileCount":13,"integrity":"sha512-l+a1eu5u5cfI+oFoCJPnnhVsFvKj42sgOQeklnzpva968b/Wfz/o7bgrgiZmsOOyzxFzbv0dtYRtPjoMjapnAA==","signatures":[{"sig":"MEUCIFKoebjZDGYMpd6buEHfh22Hf40P1vYcnE8Mo7A68c5RAiEA4oLBMQwSwnbiYtk9+3zueHZ68zsuDvpqqGvvXreUbGM=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2feventlog-kafka@0.2.0","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":36801},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"292d6ce73f799c2937b9eeb9762fd117393eaed8","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:2e6b5cf0-edc0-4790-924a-fd8ffa19ea95"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.0","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","directories":{},"_nodeVersion":"24.14.0","dependencies":{"kafkajs":"^2","@anabranch/eventlog":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/eventlog-kafka_0.2.0_1773155221124_0.3296205353940842","host":"s3://npm-registry-packages-npm-production"}},"0.2.1":{"name":"@anabranch/eventlog-kafka","version":"0.2.1","license":"MIT","_id":"@anabranch/eventlog-kafka@0.2.1","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"dist":{"shasum":"635c454e8b6a76f49afd74893268e1934bfe3b57","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.2.1.tgz","fileCount":13,"integrity":"sha512-AEF/M+xsPevezE16Cjse9vyP/4hweKkOutn5QiJxW6BeqVYg1UjXqWXSLSiBOplEasLoVELoHpCp5HA4Dwd3yQ==","signatures":[{"sig":"MEUCIQCLrkV8fyP+73+kyQsN/dONoYsGILSC/OlSCfdvg1uEJwIgQ/RH3jhtaHSUjveD45HTOn/2ZdmEDj3kzT5XaLMEdYo=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2feventlog-kafka@0.2.1","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":36801},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"e91531d2fcdb2638e284158e04d6a4b4b5f4dd79","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:2e6b5cf0-edc0-4790-924a-fd8ffa19ea95"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","directories":{},"_nodeVersion":"24.14.0","dependencies":{"kafkajs":"^2","@anabranch/eventlog":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/eventlog-kafka_0.2.1_1773349584123_0.7795411136502812","host":"s3://npm-registry-packages-npm-production"}},"0.2.2":{"name":"@anabranch/eventlog-kafka","version":"0.2.2","license":"MIT","_id":"@anabranch/eventlog-kafka@0.2.2","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"dist":{"shasum":"0424eef73aa1eac64a130bcb371f30c09fa0ad89","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.2.2.tgz","fileCount":13,"integrity":"sha512-TkroDnxFEbQNexpybehYS1vz3BXdYRIo5EpMATbv3mNKbHbyKwOvJ4KPWisJsNDGckZJeYw+GbmTPxgN19bxIg==","signatures":[{"sig":"MEUCIDrKPKi9uvI5zvMaylTeosNYY4e9HlNYEESx2M1g8iG3AiEA+rRY0VNzreUKj4f3jDHhV3A8YjxbcYEwoBzp42O9c/w=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2feventlog-kafka@0.2.2","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":35585},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"645d32dee9fff10a3634df30bba3c7839b651ca7","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:2e6b5cf0-edc0-4790-924a-fd8ffa19ea95"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"kafkajs":"^2","@anabranch/eventlog":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/eventlog-kafka_0.2.2_1773587331841_0.8050314207074907","host":"s3://npm-registry-packages-npm-production"}},"0.2.3":{"name":"@anabranch/eventlog-kafka","version":"0.2.3","license":"MIT","_id":"@anabranch/eventlog-kafka@0.2.3","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"dist":{"shasum":"ec84fd9503f080af37a1ddc3598c931ced9bc40c","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.2.3.tgz","fileCount":13,"integrity":"sha512-7YPTButX5n3ySE6KPl7irbyeYCbz9BVLlgVZFP0JrqIHxC6KDlMArj0EDTN9CW8ej3LbiWlvjVt28uEW1kCkLA==","signatures":[{"sig":"MEUCIQDhj7nNEzGPg0jQpiTLklP16sHZuYszIeFBJ7n5HHaLUAIgaSIn9/69DTZhi0yrGA04ITbfZnp9YtpoI0E0tzGpOv0=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2feventlog-kafka@0.2.3","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":35585},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"885e0ca6ec32be52cc2d3cbdfcacc90b518c7005","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:2e6b5cf0-edc0-4790-924a-fd8ffa19ea95"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"kafkajs":"^2","@anabranch/eventlog":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/eventlog-kafka_0.2.3_1773587443274_0.46617808992175225","host":"s3://npm-registry-packages-npm-production"}},"0.2.4":{"name":"@anabranch/eventlog-kafka","version":"0.2.4","license":"MIT","_id":"@anabranch/eventlog-kafka@0.2.4","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"dist":{"shasum":"1fdcad974dcb0f4cecad8a72684523a6794cb4d7","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.2.4.tgz","fileCount":13,"integrity":"sha512-z4xwMOv8w4WkOcBaOczi9cRi3/xZeSMlVgMtTFfMUAvmG+TcRDDD+rwhyRgVFTFf9NwV4/+hUt5Vhweac/vRNA==","signatures":[{"sig":"MEQCIFCuG0IwVotUt3lUZb8Ch/5CzphBcZaq1p45np9LZZLAAiBHL+m168GoLcFOsxXH+6S6t7mjhFKifE7beO+APBZPGA==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2feventlog-kafka@0.2.4","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":35585},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"06e664787aa14d078d2ea7af4de80cda74bbaeca","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:2e6b5cf0-edc0-4790-924a-fd8ffa19ea95"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"kafkajs":"^2","@anabranch/eventlog":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/eventlog-kafka_0.2.4_1773587455034_0.4006172895087836","host":"s3://npm-registry-packages-npm-production"}},"0.2.5":{"name":"@anabranch/eventlog-kafka","version":"0.2.5","license":"MIT","_id":"@anabranch/eventlog-kafka@0.2.5","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"dist":{"shasum":"d42cf237abe8918a14b1955e35e4b4b9a395402d","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.2.5.tgz","fileCount":13,"integrity":"sha512-6v96DVvXtnhR/d4pLpym1jiXpDSLVS2jwnee5j4ywKKH4BCm1qcqGm5PVnrS7t5tqULZSMsep8soBi5idu4J8Q==","signatures":[{"sig":"MEYCIQCWlXqASOLFI1sfZC8/iP87lilvPohOG9V9Xw6rhAVBSwIhAKSS2gciolrpSX+reMZzDLTyuDLBI5KfwRffGkIixDKw","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2feventlog-kafka@0.2.5","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":35585},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"22f5be524e7cb38209fab3e0173e4be1ef4de6a3","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:2e6b5cf0-edc0-4790-924a-fd8ffa19ea95"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"kafkajs":"^2","@anabranch/eventlog":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/eventlog-kafka_0.2.5_1773610138035_0.20804042024917302","host":"s3://npm-registry-packages-npm-production"}},"0.2.6":{"name":"@anabranch/eventlog-kafka","version":"0.2.6","license":"MIT","_id":"@anabranch/eventlog-kafka@0.2.6","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"dist":{"shasum":"4f523b6ccedb2407f8a5c48761e46ca545e5b841","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.2.6.tgz","fileCount":13,"integrity":"sha512-JkEyZ20YN3Dxd0b52rqpPpmUyQ/Sl7SKzlZHYE3Jm4T71y52Gqw23pPvcxHifQVIVKT43Jh9weyoYjvUogH26A==","signatures":[{"sig":"MEUCIQCinPO/an/T5woWUiykwgDG0X4gXc215OR+qAnbrkG5AQIgVCgzaL20e3q5D5Wh8We7o041T8iqBXZkyX1XQg2nS0c=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2feventlog-kafka@0.2.6","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":35585},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"40cbca2a1f28b89a91e2baf37106c68cf78ca60a","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:2e6b5cf0-edc0-4790-924a-fd8ffa19ea95"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"kafkajs":"^2","@anabranch/eventlog":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/eventlog-kafka_0.2.6_1773610174052_0.5832413940503953","host":"s3://npm-registry-packages-npm-production"}},"0.2.7":{"name":"@anabranch/eventlog-kafka","version":"0.2.7","license":"MIT","_id":"@anabranch/eventlog-kafka@0.2.7","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"dist":{"shasum":"7bd0d286ea275250e8f32278f7f27287c5a82a6a","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.2.7.tgz","fileCount":13,"integrity":"sha512-jqDfW5wIBuNLdCc5xjJIg1I2g9SrlvVqvrV+AeH/tN35QPoBUgD9C+EhX1kmjfJ3H4yi9INkFYe+VrXNrdh2Zg==","signatures":[{"sig":"MEQCID15ZN6WqMoyrcMFV0k35TkT6Uwug5lvXSs6eR0WCE3RAiBh2kQa8Skkx2iZLzyy183Ikuv9/vUGtTWBYX8IF+KHnA==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2feventlog-kafka@0.2.7","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":35585},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"8324051181539a3a814c6332cd210a559e1d9352","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:2e6b5cf0-edc0-4790-924a-fd8ffa19ea95"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"kafkajs":"^2","@anabranch/eventlog":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/eventlog-kafka_0.2.7_1773610182982_0.03845394262654067","host":"s3://npm-registry-packages-npm-production"}},"0.2.8":{"name":"@anabranch/eventlog-kafka","version":"0.2.8","license":"MIT","_id":"@anabranch/eventlog-kafka@0.2.8","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"dist":{"shasum":"9e01bcaabf8249d01e4c8567cba0318d766bffed","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.2.8.tgz","fileCount":13,"integrity":"sha512-9il4qTzQ3jJwDHmuc8ZxpbROhNGBpqRFt9fN4udnQb8egBkdnUYzdPRD8kZ4X8ExQVpTyPts3f6BGJjVdvHWdA==","signatures":[{"sig":"MEUCIEAEVyDDTmlX1hTN64IPoc4V+QRyAdmObcsua2HetHnEAiEAhJtj1xudqgQPw7kJmx+D+ZoO9LGFfDm5dyd2LuLpeAE=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2feventlog-kafka@0.2.8","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":35585},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"0aa87cbfbff1c1482a9645806f04a1c08250e86a","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:2e6b5cf0-edc0-4790-924a-fd8ffa19ea95"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"kafkajs":"^2","@anabranch/eventlog":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/eventlog-kafka_0.2.8_1773610229721_0.5317322209705462","host":"s3://npm-registry-packages-npm-production"}},"0.2.9":{"name":"@anabranch/eventlog-kafka","version":"0.2.9","license":"MIT","_id":"@anabranch/eventlog-kafka@0.2.9","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"dist":{"shasum":"23565e9f02f0c0f1e6481f72a53edf82a1df756d","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.2.9.tgz","fileCount":13,"integrity":"sha512-wr3I459p4DJmBWtdpbYhnr2jdQG4GhAu9zr6sebswDOvtyzhroOKLgwzydQy8OZn1LtTS99/eeUecGfxPmvR+A==","signatures":[{"sig":"MEYCIQCLfYu+n56aMDFIxsOYEqv1vlfrDszs/GzCl6D6VDMa1QIhAJlcr11Q29fjWCXZ3uT1bXABn6fdXc0rCveKmGMJ1Q8e","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2feventlog-kafka@0.2.9","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":35585},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"ff2f5fce4ebb3240bc22bab0029965182c4bedad","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:2e6b5cf0-edc0-4790-924a-fd8ffa19ea95"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"kafkajs":"^2","@anabranch/eventlog":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/eventlog-kafka_0.2.9_1773611342426_0.16549801891085103","host":"s3://npm-registry-packages-npm-production"}},"0.2.10":{"name":"@anabranch/eventlog-kafka","version":"0.2.10","license":"MIT","_id":"@anabranch/eventlog-kafka@0.2.10","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"dist":{"shasum":"b7427e378cc237095fbeb40226ff9f79e5d98502","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.2.10.tgz","fileCount":13,"integrity":"sha512-eyklQyV6Fu0J+iM1MciljPpFcv/QWssX9QZkZLw+2IOA4JFiZXDk00v7v+vgtuiIEy0V8ROWIBNbTP+5T46oFQ==","signatures":[{"sig":"MEUCIG4kBIybZyh6ZZ6fnvraKsTnvWnk4t7jZBQNkID6ko4TAiEA/GW1D+p1s7E8dK5YbltSxr6Shif9Y+47YvMkyC6cmDo=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2feventlog-kafka@0.2.10","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":35586},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"c65b2bb9f8d92d77064cec236c3732bd5e0d8c76","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:2e6b5cf0-edc0-4790-924a-fd8ffa19ea95"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"kafkajs":"^2","@anabranch/eventlog":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/eventlog-kafka_0.2.10_1773614121338_0.413621956445978","host":"s3://npm-registry-packages-npm-production"}},"0.2.11":{"name":"@anabranch/eventlog-kafka","version":"0.2.11","license":"MIT","_id":"@anabranch/eventlog-kafka@0.2.11","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"dist":{"shasum":"8097d228d1807266eaed805ece3c52d22bc48e7e","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.2.11.tgz","fileCount":13,"integrity":"sha512-ueaC+TocxYGNQaQj7AoD/dwPP2mtIvkztRK+4AG/1jFhlEJOTnVuwiweXE4nevbs4+YNg1XMH3r3nKBX1Qht5g==","signatures":[{"sig":"MEUCIQC8Kdr4FmLgyGJB9bfDi969zlDC9blQvKjk1sSrrxtP7AIgTyDbwjCqNNB2c27MoYxw447r2Pba7RAA584UeuWOpDA=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2feventlog-kafka@0.2.11","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":35752},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"748f940f5634aa22ce8fd330e10cfdc559949594","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:2e6b5cf0-edc0-4790-924a-fd8ffa19ea95"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"kafkajs":"^2","@anabranch/eventlog":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/eventlog-kafka_0.2.11_1773746468103_0.36551849096384714","host":"s3://npm-registry-packages-npm-production"}},"0.2.12":{"name":"@anabranch/eventlog-kafka","version":"0.2.12","description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","repository":{"type":"git","url":"git+https://github.com/frodi-karlsson/anabranch.git"},"license":"MIT","bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"scripts":{},"sideEffects":false,"dependencies":{"@anabranch/eventlog":"^0","kafkajs":"^2"},"devDependencies":{"@types/node":"^24"},"gitHead":"6fd573e3068a3f60814d0e57a3a7097b16c42381","_id":"@anabranch/eventlog-kafka@0.2.12","homepage":"https://github.com/frodi-karlsson/anabranch#readme","_nodeVersion":"24.18.0","_npmVersion":"11.18.0","dist":{"integrity":"sha512-2y7TFDH8RRZofe0OfBh6JWxRBCFaawUlpnWzGvkgkRby1nUV17It3G8WV3i6FIY6C6gCFDDrxwsAbbn1Mwd2Zg==","shasum":"f6cac0938e1d62bab47f56667fdb7c5d15482956","tarball":"https://registry.npmjs.org/@anabranch/eventlog-kafka/-/eventlog-kafka-0.2.12.tgz","fileCount":13,"unpackedSize":35752,"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2feventlog-kafka@0.2.12","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEQCIDoYjkgQq4pu6GzEA9EW0bKcswqRIGqnrfYGJqGKTTOcAiAOqFcBJh1u1I1DQSyx8SXPJYDe25OctAwjJDm6f2rP5Q=="}]},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:2e6b5cf0-edc0-4790-924a-fd8ffa19ea95"}},"directories":{},"maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/eventlog-kafka_0.2.12_1782955779441_0.12004649379713572"},"_hasShrinkwrap":false}},"time":{"created":"2026-03-10T00:59:00.052Z","modified":"2026-07-02T01:29:39.877Z","0.1.0":"2026-03-10T00:59:00.293Z","0.1.2":"2026-03-10T01:08:58.013Z","0.2.0":"2026-03-10T15:07:01.308Z","0.2.1":"2026-03-12T21:06:24.299Z","0.2.2":"2026-03-15T15:08:52.003Z","0.2.3":"2026-03-15T15:10:43.413Z","0.2.4":"2026-03-15T15:10:55.186Z","0.2.5":"2026-03-15T21:28:58.195Z","0.2.6":"2026-03-15T21:29:34.183Z","0.2.7":"2026-03-15T21:29:43.118Z","0.2.8":"2026-03-15T21:30:29.871Z","0.2.9":"2026-03-15T21:49:02.613Z","0.2.10":"2026-03-15T22:35:21.481Z","0.2.11":"2026-03-17T11:21:08.249Z","0.2.12":"2026-07-02T01:29:39.575Z"},"bugs":{"url":"https://github.com/frodi-karlsson/anabranch.git"},"license":"MIT","homepage":"https://github.com/frodi-karlsson/anabranch#readme","repository":{"type":"git","url":"git+https://github.com/frodi-karlsson/anabranch.git"},"description":"Kafka adapter for eventlog using kafkajs with Task/Stream semantics","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"readme":"# @anabranch/eventlog-kafka\n\nKafka adapter for `@anabranch/eventlog` using [kafkajs](https://kafka.js.org/).\nProvides Task/Stream semantics for event-sourced systems with Apache Kafka,\nConfluent Cloud, Redpanda, and other Kafka-compatible services.\n\n## Usage\n\n```ts\nimport { EventLog } from '@anabranch/eventlog'\nimport { createKafka } from '@anabranch/eventlog-kafka'\n\nconst connector = createKafka({\n  brokers: ['localhost:9092'],\n  clientId: 'my-app',\n  consumer: {\n    maxWaitTimeInMs: 100,\n    sessionTimeout: 6000,\n  },\n})\n\nconst log = await EventLog.connect(connector).run()\n\n// Append events with partition keys\nconst eventId = await log.append('users', {\n  type: 'UserCreated',\n  userId: 'user-123',\n  email: 'alice@example.com',\n}, { partitionKey: 'user-123' }).run()\n\n// Consume events as a stream\nawait log\n  .consume<UserEvent>('users', 'my-processor', {\n    batchSize: 50,\n  })\n  .tap((batch) => {\n    for (const event of batch.events) {\n      console.log(event.data)\n    }\n  })\n  .map(async (batch) => {\n    await batch.commit()\n  })\n  .partition()\n```\n\n## API\n\n### createKafka(options)\n\nCreates a Kafka connector.\n\n```ts\nimport { createKafka } from '@anabranch/eventlog-kafka'\n\nconst connector = createKafka({\n  brokers: ['localhost:9092'],\n  clientId: 'my-app',\n  sasl: {\n    mechanism: 'plain',\n    username: 'admin',\n    password: 'secret',\n  },\n  ssl: true,\n  consumer: {\n    maxWaitTimeInMs: 100,\n    sessionTimeout: 6000,\n  },\n})\n```\n\n#### Options\n\n- `brokers` (required): Array of Kafka broker addresses\n- `clientId`: Client ID for the producer\n- `sasl`: SASL authentication configuration\n- `ssl`: Enable SSL/TLS (default: `false`)\n- `consumer`: Kafka consumer configuration (passed to kafkajs)\n- `producer`: Kafka producer configuration (passed to kafkajs)\n- `admin`: Kafka admin configuration (passed to kafkajs)\n- `onMalformedMessage`: Callback for unparseable messages\n\n### Environment Variables\n\n- `KAFKA_URL`: Comma-separated list of broker addresses (alternative to\n  `brokers`)\n\n## Requirements\n\n- Node.js 24+ or Deno\n- Kafka server (local or remote)\n\n## Installation\n\n**Deno:**\n\n```ts\nimport { createKafka } from '@anabranch/eventlog-kafka'\n```\n\n**Node.js:**\n\n```bash\nnpm install @anabranch/eventlog-kafka @anabranch/eventlog kafkajs\n```\n\nSee [@anabranch/eventlog](https://jsr.io/@anabranch/eventlog) for the core event\nlog abstraction.\n\nSee\n[generated documentation](https://frodi-karlsson.github.io/anabranch/eventlog-kafka)\nfor full API details.\n","readmeFilename":"README.md"}