{"_id":"@bluexlab/kafka-ts","_rev":"3-d31eb126dc2f0d579a687040a740f39f","name":"@bluexlab/kafka-ts","dist-tags":{"latest":"1.0.4"},"versions":{"1.0.1":{"name":"@bluexlab/kafka-ts","version":"1.0.1","keywords":["kafka"],"author":{"url":"jay.liang@bluextrade.com","name":"Jay Liang"},"license":"ISC","_id":"@bluexlab/kafka-ts@1.0.1","maintainers":[{"name":"roackb2","email":"roackb2@gmail.com"},{"name":"kevinjxx","email":"kevin@bluextrade.com"}],"dist":{"shasum":"5a16ad7d71a6b0b44001b60b153551db492ce06a","tarball":"https://registry.npmjs.org/@bluexlab/kafka-ts/-/kafka-ts-1.0.1.tgz","fileCount":6,"integrity":"sha512-VNKk09zmVldEXjnbtDnhEtitsZPK6HrUkYSE4a2gjWFw1oQ4SUh9MFYv1zSafKWsfMX6dJo3vdaS9gCO8yExyw==","signatures":[{"sig":"MEQCIGQlVOdd+Zyy0VFvtMHXVQcwM5lKzVic7tBB9Q8Ee96VAiANmp3yfPEmt3OcVNqeoNQ2iB4d0ufRY1NiQV5n5ybNog==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":12763},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","exports":{".":{"import":"./dist/index.js","require":"./dist/index.cjs"},"./package.json":"./package.json"},"gitHead":"80f456a29dd00f4a862e453e7f6d3c2106b1e5ba","scripts":{"dev":"tsup --watch","build":"tsup","release":"bumpp && npm publish","test:unit":"NODE_ENV=test TEST_TYPE=unit dotenv -e .env.test jest tests/unit/**/*.spec.ts","prepublishOnly":"npm run build","example:consumer":"npx tsx examples/consumer.ts","example:producer":"npx tsx examples/producer.ts","test:integration":"NODE_ENV=test TEST_TYPE=integration dotenv -e .env.test jest tests/integration/**/*.spec.ts"},"_npmUser":{"name":"roackb2","email":"roackb2@gmail.com"},"_npmVersion":"10.2.3","description":"The kafka producer and consumer client","directories":{"test":"tests","example":"examples"},"_nodeVersion":"20.10.0","dependencies":{"dotenv":"^16.4.5","lodash":"^4.17.21","kafkajs":"^2.2.4"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"jest":"^29.7.0","tsup":"^8.2.3","bumpp":"^9.4.1","ts-jest":"^29.2.3","ts-node":"^10.9.2","dotenv-cli":"^7.4.2","@types/jest":"^29.5.12","@types/node":"^20.14.12","@types/lodash":"^4.17.7","@types/kafkajs":"^1.9.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.0.1_1722240435266_0.7485946732872968","host":"s3://npm-registry-packages"}},"1.0.2":{"name":"@bluexlab/kafka-ts","version":"1.0.2","keywords":["kafka"],"author":{"url":"jay.liang@bluextrade.com","name":"Jay Liang"},"license":"ISC","_id":"@bluexlab/kafka-ts@1.0.2","maintainers":[{"name":"roackb2","email":"roackb2@gmail.com"},{"name":"kevinjxx","email":"kevin@bluextrade.com"}],"dist":{"shasum":"31afd67d58ac25377ed6c232ddc596cfd3b880d7","tarball":"https://registry.npmjs.org/@bluexlab/kafka-ts/-/kafka-ts-1.0.2.tgz","fileCount":6,"integrity":"sha512-ZpyCODBBBQjdsoheQCiu5SjE41FX7EqycRPT03XOrbubdiXl8457yfz1s6I4lCi/mAN4LJr4UbB2QJD50P0jMw==","signatures":[{"sig":"MEYCIQCSytsMJKVxv9nUQDeN+IV7YDFsUJQIWRJp9WXIATAb5QIhAIauVXk8nNCttWQcOhVdOMSvsWGXTWkR3/HEyx/VlaVL","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":14644},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","exports":{".":{"import":"./dist/index.js","require":"./dist/index.cjs"},"./package.json":"./package.json"},"gitHead":"48e64bafab4f5cb6797734e64c08d80b0aed4355","scripts":{"dev":"tsup --watch","build":"tsup","release":"bumpp && npm publish","test:unit":"NODE_ENV=test TEST_TYPE=unit dotenv -e .env.test jest tests/unit/**/*.spec.ts","prepublishOnly":"npm run build","example:consumer":"npx tsx examples/consumer.ts","example:producer":"npx tsx examples/producer.ts","test:integration":"NODE_ENV=test TEST_TYPE=integration dotenv -e .env.test jest tests/integration/**/*.spec.ts"},"_npmUser":{"name":"roackb2","email":"roackb2@gmail.com"},"_npmVersion":"10.2.3","description":"The kafka producer and consumer client","directories":{"test":"tests","example":"examples"},"_nodeVersion":"20.10.0","dependencies":{"dotenv":"^16.4.5","lodash":"^4.17.21","kafkajs":"^2.2.4"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"jest":"^29.7.0","tsup":"^8.2.3","bumpp":"^9.4.1","ts-jest":"^29.2.3","ts-node":"^10.9.2","dotenv-cli":"^7.4.2","@types/jest":"^29.5.12","@types/node":"^20.14.12","@types/lodash":"^4.17.7","@types/kafkajs":"^1.9.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.0.2_1722241132370_0.4991354708057516","host":"s3://npm-registry-packages"}},"1.0.3":{"name":"@bluexlab/kafka-ts","version":"1.0.3","keywords":["kafka"],"author":{"url":"jay.liang@bluextrade.com","name":"Jay Liang"},"license":"ISC","_id":"@bluexlab/kafka-ts@1.0.3","maintainers":[{"name":"roackb2","email":"roackb2@gmail.com"},{"name":"kevinjxx","email":"kevin@bluextrade.com"}],"dist":{"shasum":"abbb16e0a8dd711d11ddcf27e6874afbb0f4eefe","tarball":"https://registry.npmjs.org/@bluexlab/kafka-ts/-/kafka-ts-1.0.3.tgz","fileCount":6,"integrity":"sha512-PZDLQKUn37UhGEoDjP+teKO1IhjaHUAmmxMWS8g0X0ry/WmQC70cgQ00xFO5SlN4dgZ5ogKBuTAkwa5ykiMUmg==","signatures":[{"sig":"MEYCIQCwU6bTrHymtyJeQinJPse7MjRBEiCJ1f3t7+BWXQ5v4gIhALoadq9L0mkcbsczgO1FOcYqzbPKZCBfiP0yi8jozMGb","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":14666},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","exports":{".":{"import":"./dist/index.js","require":"./dist/index.cjs"},"./package.json":"./package.json"},"gitHead":"b9a870dcdb3b4dc079408c7bd8ef51a59731550c","scripts":{"dev":"tsup --watch","build":"tsup","release":"bumpp && npm publish","test:unit":"NODE_ENV=test TEST_TYPE=unit dotenv -e .env.test jest tests/unit/**/*.spec.ts","prepublishOnly":"npm run build","example:consumer":"npx tsx examples/consumer.ts","example:producer":"npx tsx examples/producer.ts","test:integration":"NODE_ENV=test TEST_TYPE=integration dotenv -e .env.test jest tests/integration/**/*.spec.ts"},"_npmUser":{"name":"roackb2","email":"roackb2@gmail.com"},"_npmVersion":"10.2.3","description":"The kafka producer and consumer client","directories":{"test":"tests","example":"examples"},"_nodeVersion":"20.10.0","dependencies":{"pino":"^9.3.2","dotenv":"^16.4.5","lodash":"^4.17.21","kafkajs":"^2.2.4"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"jest":"^29.7.0","tsup":"^8.2.3","bumpp":"^9.4.1","ts-jest":"^29.2.3","ts-node":"^10.9.2","dotenv-cli":"^7.4.2","@types/jest":"^29.5.12","@types/node":"^20.14.12","@types/lodash":"^4.17.7","@types/kafkajs":"^1.9.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-ts_1.0.3_1722242017739_0.4426092841254672","host":"s3://npm-registry-packages"}},"1.0.4":{"name":"@bluexlab/kafka-ts","type":"module","version":"1.0.4","description":"The kafka producer and consumer client","exports":{".":{"import":"./dist/index.js","require":"./dist/index.cjs"},"./package.json":"./package.json"},"main":"./dist/index.js","module":"./dist/index.js","types":"./dist/index.d.ts","scripts":{"build":"tsup","dev":"tsup --watch","release":"bumpp && npm publish","prepublishOnly":"npm run build","example:consumer":"npx tsx examples/consumer.ts","example:producer":"npx tsx examples/producer.ts","test:unit":"NODE_ENV=test TEST_TYPE=unit dotenv -e .env.test jest tests/unit/**/*.spec.ts","test:integration":"NODE_ENV=test TEST_TYPE=integration dotenv -e .env.test jest tests/integration/**/*.spec.ts"},"author":{"name":"Jay Liang","url":"jay.liang@bluextrade.com"},"license":"ISC","publishConfig":{"access":"public"},"dependencies":{"dotenv":"^16.4.5","kafkajs":"^2.2.4","lodash":"^4.17.21","pino":"^9.3.2"},"devDependencies":{"@types/jest":"^29.5.12","@types/kafkajs":"^1.9.0","@types/lodash":"^4.17.7","@types/node":"^20.14.12","bumpp":"^9.4.1","dotenv-cli":"^7.4.2","jest":"^29.7.0","ts-jest":"^29.2.3","ts-node":"^10.9.2","tsup":"^8.2.3"},"directories":{"example":"examples","test":"tests"},"keywords":["kafka"],"_id":"@bluexlab/kafka-ts@1.0.4","gitHead":"3bb03cea8b92ddeb0c1c8c18151439fbb0bcdce1","_nodeVersion":"20.10.0","_npmVersion":"10.2.3","dist":{"integrity":"sha512-ZIhZdcFH8aYRyetCMC+gDOuRjt8t3Ednu61MyWK8uxvE1U7g93loLIuyz/uybI/74rpkro2GBxf64TPD5aQk1A==","shasum":"7d8190d0c45b0f183631cd3766483322b5e835d8","tarball":"https://registry.npmjs.org/@bluexlab/kafka-ts/-/kafka-ts-1.0.4.tgz","fileCount":6,"unpackedSize":14764,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCICF0Xuh2ig2nTIyFNhn5L/Y3E+BQ8D2qYtMz7SuXFcvyAiEAsusQ8ta8X2C8ZaJUmsXZv6Z5rQz8Mknw8DcUzTMGHcU="}]},"_npmUser":{"name":"roackb2","email":"roackb2@gmail.com"},"maintainers":[{"name":"roackb2","email":"roackb2@gmail.com"},{"name":"kevinjxx","email":"kevin@bluextrade.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-ts_1.0.4_1722242122531_0.9524377944890006"},"_hasShrinkwrap":false}},"time":{"created":"2024-07-29T08:07:15.141Z","modified":"2024-07-29T08:35:22.903Z","1.0.1":"2024-07-29T08:07:15.405Z","1.0.2":"2024-07-29T08:18:52.527Z","1.0.3":"2024-07-29T08:33:37.900Z","1.0.4":"2024-07-29T08:35:22.700Z"},"author":{"name":"Jay Liang","url":"jay.liang@bluextrade.com"},"license":"ISC","keywords":["kafka"],"description":"The kafka producer and consumer client","maintainers":[{"name":"roackb2","email":"roackb2@gmail.com"},{"name":"kevinjxx","email":"kevin@bluextrade.com"}],"readme":"# BlueX Kafka\n\nCustom Kafka client for internal use at BlueX Trade.\n\n## Quick start\n\nTry running consumer with\n\n```bash\nnpm run example:consumer\n```\n\nAnd the producer\n\n```bash\nnpm run example:producer\n```\n\nThe producer will send a example message, and you should be able to see the consumer receiving it.\n\n## Tests\n\n### Unit tests\n\nThis only tests some utility functions to guarantee their consistent behaviors.\n\n```bash\nnpm run test:unit\n```\n\n### Integration tests\n\nThis tests the entire workflow from starting the producer and the consumer,\nthen produces a message and verify that the consumer did receive the message.\n\n> NOTE: Integration test requires you to have a kafka service running at `localhost:9092`.\n> You could also set the `NOTIFICATION_BROKERS` environment variable in the `.env.test` to point to your kafka server.\n\n```bash\nnpm run test:integration\n```\n","readmeFilename":"README.md"}