{"_id":"@blued-core-oversea/kafka-client","_rev":"3-baf478a907219f3e0b017e39455dfb6b","name":"@blued-core-oversea/kafka-client","dist-tags":{"latest":"1.0.0"},"versions":{"0.0.1":{"name":"@blued-core-oversea/kafka-client","version":"0.0.1","keywords":[],"author":"","license":"ISC","_id":"@blued-core-oversea/kafka-client@0.0.1","maintainers":[{"name":"bluediapp","email":"iappdeveloper@blued.com"}],"dist":{"shasum":"629ab11394f06f715c3e0f415c89f73ead7168fe","tarball":"https://registry.npmjs.org/@blued-core-oversea/kafka-client/-/kafka-client-0.0.1.tgz","fileCount":8,"integrity":"sha512-9u+bPPqEmSrTB93HDgxTVm7VaZu3+em4S5mM++RAyxgMp8COqb5wdML4opDiQ9+bCrnZ/M7ovz1vqlxky0hJ5g==","signatures":[{"sig":"MEUCIQDtyQfTlae73ZRYL8vEmmE8awgcLl/zdyjp5FL+l59t9wIgKksXby8V+Bqu0fazSvhu0zXckGH4iqGxfmsS/fgNBWc=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":17260,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJhIGxUCRA9TVsSAnZWagAAenQP/2xgqOPf5Fyyg95JIWa6\nKA8Boaz08jeq4LeQpHUCXXmZbcyLgJPlwRd+yCVsbkbLrQ5fG4imNVc6n2zc\njS83loM8l6y777OLpewaOsu13aVlGarvl+HmJ6qK0JY1SsfI+gV5W6gx7xV+\neBRcGj3P7ZrYuT0qSOpaUyzqu/i8t9Kybmts2T32+HHRAFOL4ol4RPCj9+vT\ndF4zN4JEPEg1F/7UOKR2G3QcMag1kQpU8LTEYKlqNVDe/CM8F0iznYP1FInA\npQdikunkqdX181rEnJPXL0Q6Qy+k+/+tl5bvK6h9FjFyI26qvW35zupahIPY\nY87UHZ9sUas9lMb/9AkeqRmDyNW5wyoyoVelTGa0liqUaRLymawAWnif3IEc\ndy875vL/J1L5uF5I7fT8r3gExAHxb9ZS+tezWi5LWWshh7KLOS7i5AVRdtOi\nuQDH/5cTbZauxsRc8xCq5fLBNUXC2US4wgD6y7aHR7ccqIXsC2o9NRZ5dobD\nrJCPj3lYA2y0qA/Xp2YLNAs34iuDT9CzhGyv+N5Ohr0br142wBMntrIMVQNP\nqG7TlGmtF/fRFLphPDmPCFa0RMBTCIp0pGNi7IMLCTxLyrnyCaU5geTn01ER\ngwFPdN6OdzfqqHvQ55l3uyRPA2qTyQqFLNUjJUNywBTNZGpzNYJq01l5L6av\nCus+\r\n=IwWy\r\n-----END PGP SIGNATURE-----\r\n"},"main":"dist/index.js","gitHead":"b609a5deea55f46b8f28f5038b16089ed87cf67f","scripts":{"test":"nodemon dist/test_clusterclient","build":"rm -rf dist && tsc","watch":"tsc -w"},"_npmUser":{"name":"bluediapp","email":"iappdeveloper@blued.com"},"_npmVersion":"6.14.6","description":"基于 kafka-node 的一层封装。","directories":{},"_nodeVersion":"12.18.3","dependencies":{"kafka-node":"^5.0.0","node-qconf":"^0.4.2"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.2.0","mocha":"^6.1.4","eslint":"^5.16.0","ts-node":"^8.0.3","commitizen":"^3.0.7","typescript":"^3.4.3","@types/chai":"^4.1.7","@types/node":"^11.13.4","@types/mocha":"^5.2.7","@commitlint/cli":"^7.5.2","eslint-plugin-import":"^2.16.0","eslint-config-blued-typescript":"^1.0.1","@commitlint/config-conventional":"^7.5.0","@typescript-eslint/eslint-plugin":"^1.6.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_0.0.1_1629514836162_0.8764300204407482","host":"s3://npm-registry-packages"}},"0.0.2":{"name":"@blued-core-oversea/kafka-client","version":"0.0.2","keywords":[],"author":"","license":"ISC","_id":"@blued-core-oversea/kafka-client@0.0.2","maintainers":[{"name":"bluediapp","email":"iappdeveloper@blued.com"}],"dist":{"shasum":"e7fddd83859ea490ab839c0bc75ea165c674b2fe","tarball":"https://registry.npmjs.org/@blued-core-oversea/kafka-client/-/kafka-client-0.0.2.tgz","fileCount":8,"integrity":"sha512-5tvVJ6aFACsSLXb+7SPM+wSqxKx4OjVBzm5nljK006uYG8ElXglAeRdOO57FuZUtn0DtN+esh4wFoBPGqjPdQQ==","signatures":[{"sig":"MEUCIG0ehpv+25/WatIv9i2lOI3Ncu40YzuNk9mOS7tQ+LFaAiEA62CHh8ZCpqeHC+uP3vm3PIoDoUbWCckL58Plyo7J4zs=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":19554},"main":"dist/index.js","gitHead":"9f34e1f761930bb926358de584bdbb32e1d0aaa3","scripts":{"test":"nodemon dist/test_clusterclient","build":"rm -rf dist && tsc","watch":"tsc -w"},"_npmUser":{"name":"bluediapp","email":"iappdeveloper@blued.com"},"_npmVersion":"6.14.6","description":"基于 kafka-node 的一层封装。","directories":{},"_nodeVersion":"12.18.3","dependencies":{"kafka-node":"^5.0.0","node-qconf":"^0.4.2"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.2.0","mocha":"^6.1.4","eslint":"^5.16.0","ts-node":"^8.0.3","commitizen":"^3.0.7","typescript":"^3.4.3","@types/chai":"^4.1.7","@types/node":"^11.13.4","@types/mocha":"^5.2.7","@commitlint/cli":"^7.5.2","eslint-plugin-import":"^2.16.0","eslint-config-blued-typescript":"^1.0.1","@commitlint/config-conventional":"^7.5.0","@typescript-eslint/eslint-plugin":"^1.6.0"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_0.0.2_1688696192722_0.023373679110388457","host":"s3://npm-registry-packages"}},"1.0.0":{"name":"@blued-core-oversea/kafka-client","version":"1.0.0","description":"基于 kafka-node 的一层封装。","main":"dist/index.js","scripts":{"build":"rm -rf dist && tsc","watch":"tsc -w","test":"nodemon dist/test_clusterclient"},"keywords":[],"author":"","license":"ISC","dependencies":{"node-rdkafka":"^3.2.1","node-qconf":"^0.4.2"},"devDependencies":{"@types/node":"^22.10.2","typescript":"^5.7.2"},"_id":"@blued-core-oversea/kafka-client@1.0.0","gitHead":"338fdbf92417c8fd7bacd87e56e25ea2656777fb","types":"./dist/index.d.ts","_nodeVersion":"22.12.0","_npmVersion":"10.9.0","dist":{"integrity":"sha512-G0ca3as9sTDecOAyrkrIjr731IQUeD2NRUxzPqGo4aDDRhjEBmAJ4ncXwuQC7zAnW1T8R3VoL/ZgtaOKUdNQbg==","shasum":"d9af30aca2c8d82245b128bbb345a57e8a58f696","tarball":"https://registry.npmjs.org/@blued-core-oversea/kafka-client/-/kafka-client-1.0.0.tgz","fileCount":8,"unpackedSize":14561,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD+D2SLj1qs1m8FxADrKqNkiI7ZqAsgyKqKb62LZwjTVAIgXqY+WPlwyBdj5UGE4esofRdkcMowZ6/PTe3eXS7eEow="}]},"_npmUser":{"name":"bluediapp","email":"iappdeveloper@blued.com"},"directories":{},"maintainers":[{"name":"bluediapp","email":"iappdeveloper@blued.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/kafka-client_1.0.0_1734406713131_0.15960409116154262"},"_hasShrinkwrap":false}},"time":{"created":"2021-08-21T03:00:36.087Z","modified":"2024-12-17T03:38:33.531Z","0.0.1":"2021-08-21T03:00:36.314Z","0.0.2":"2023-07-07T02:16:32.958Z","1.0.0":"2024-12-17T03:38:33.323Z"},"license":"ISC","keywords":[],"description":"基于 kafka-node 的一层封装。","maintainers":[{"name":"bluediapp","email":"iappdeveloper@blued.com"}],"readme":"基于 kafka-node 的一层封装。\n\n```bash\nnpm i @blued-core-oversea/kafka-client\n```\n\n```typescript\nimport { KafkaClient } from '../index'\n\nconst kafka = {\n  oversea: '/blued/backend/ukafka/oversea_app/bootstrap',\n}\n\nconst kafkaClient = new KafkaClient(kafka)\nexport const liveLogKafkaClient = () => kafkaClient.getClient('oversea')\n\nconst testData = { timestamp: 1629460128, data: { uid: 90000024, extra: { event: 15, targetUid: 90000024, liveId: 0, taskLevel: '4', taskId: '8' } }, app: 2 }\n\nexport const sleep = (ms: number) => new Promise(resolve => setTimeout(resolve, ms))\n\nconst main = async () => {\n  await sleep(1000)\n  liveLogKafkaClient().send('xxxxxxx', JSON.stringify(testData))\n  console.log('---------------over')\n}\n\nmain().then(() => {\n  kafkaClient.close()\n  console.log('success')\n}).catch(error => {\n  console.log(error)\n})\n```","readmeFilename":"README.md"}