{"_id":"@sensejs/kafkajs-standalone","_rev":"55-8506a4fb27489c285a5924a70593b917","name":"@sensejs/kafkajs-standalone","dist-tags":{"beta":"0.7.0","latest":"0.11.0","pnpm-temp":"0.6.1","stage":"0.2.0","alpha":"0.11.0-alpha.0","rc":"0.3.1","staging":"0.4.2"},"versions":{"0.2.0-0":{"name":"@sensejs/kafkajs-standalone","version":"0.2.0-0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","cleanup":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"tslib":"^1.10.0","rxjs":"^6.5.4","long":"^4.0.0","@sensejs/utility":"0.2.0-0"},"peerDependencies":{"kafkajs":"^1.11.0"},"devDependencies":{"kafkajs":"^1.11.0","@sensejs/core":"0.1.1","@types/long":"^4.0.0","@sensejs/testing-utility":"0.0.8"},"_id":"@sensejs/kafkajs-standalone@0.2.0-0","_nodeVersion":"12.13.1","_npmVersion":"6.12.1","dist":{"integrity":"sha512-Uw4S0aZfqMDUAvpwYSzUP/ioXS9CoF3/2HcDpfCsgiodwdjvKd8EsnqW50o0g260XL0ueQPzyT4YnopC/DjibA==","shasum":"dc23085bfd69d879fa73c01bb28e6468a1949c98","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.2.0-0.tgz","fileCount":20,"unpackedSize":31629,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeIGOLCRA9TVsSAnZWagAAcBoP/2EBlZAtz6ZEsWkRKSKi\nFZLnfzYhv49eRYA2grws5nCSKC/JBYEw3IsLJwbk3In/3hSWKefS/KUI0oQh\nnGHMXm89XU4hCsTRTddi64Q2QxswMmS/tPn3dAJASJqD/5SGcvuHXUtpMc/O\nELQ91i536vJgfv9aI3BpAotlADvXnSdmBcKGlJMa8khOEF+TryqTpJIlxBl/\nOAtP7rQ4RdsSKYsVrbVwPyGOflCa1JaZkLp0v+P4xI27aLnsUaq8zzR7cn13\nU6gGgiF8zd1v2aGrzrNSm1slHdJ5sPiPzT+kZMaYWE3g15hOitcgEDBu0fOi\nsA5tv3dceHKpkSqKvpQecqYnc78nqWCC2Mod2MXmACFomWIlkJnBeyJm4vWe\nn3cZS5ZJsxYkwhIsK0dSB3g1OXJyDShBn+GzjGRCGwZaoCOAjWIdUOKZ6epD\nCq5DQwiRF02qkuOkQ7Q/+7OzV4mxRSLk63OGtITom3aQBYvNeVeG3BVrE2af\nBoqrT52ZGRuunSonltvV9EVEiprMRT78+DjiQ82+4+9rOfThJ7/Ow/zbpOFi\nBHdweoX1DsYfDKA1ymgIvEEtESMnie1ztxcuCKUillsUZ4wOfePzZIbHSIMg\nTMM3m9Zqnc3/Nz1cYpZdX9GTFKZRNbmeu/Yho7O3yKPzmAUjUizYvuPybmUy\nSKKp\r\n=2NVN\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCh6dDGnJLhxofM1MT+6OjBNsUSr4N8u40LpHfgYtyBIgIgPhM9HaEVNXsl0vplUOPDKrvLfqiVI6gx924VAFryM4o="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.2.0-0_1579180939365_0.055937295151015975"},"_hasShrinkwrap":false},"0.2.0":{"name":"@sensejs/kafkajs-standalone","version":"0.2.0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","cleanup":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"0.2.0","long":"^4.0.0","rxjs":"^6.5.4","tslib":"^1.10.0"},"peerDependencies":{"kafkajs":"^1.11.0"},"devDependencies":{"@sensejs/core":"0.2.0","@sensejs/testing-utility":"0.0.8","@types/long":"^4.0.0","kafkajs":"^1.11.0"},"readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.2.0","_nodeVersion":"12.13.1","_npmVersion":"6.12.1","dist":{"integrity":"sha512-//dGirsj/+6jkD9STuNKrQQNlJi1wykkeTZsTi9j6tgCZZPVJbL60waTUKfiy2BVZAjXVCzbL20AYWD9Stzl/Q==","shasum":"d0325081e7a118b336c42811d84da5426c50ff6f","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.2.0.tgz","fileCount":20,"unpackedSize":31625,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeIG1rCRA9TVsSAnZWagAA70MP/RrNVnYYhy7jBVrI6fqR\nwH5oAYTBGgbbSHDpgQQz5a7ZQBgtnaAzNM6LLZqRvo3BqH5qqBH1ObRW47W+\nuDqPJRUCriMHW+AWKdabJLbTiWtUXkDZRgRJgep3x3Zz+FJgEAbcqbwoT++2\nVEx+ynsGd7iMRMN3up4WkGtYhEHVJQ9PRSOF08H5VxvN/6lprWK/70wuO2em\nutUXxR2Skbckv1+R6DJDsjO8LaN3rtzS6uhdf5cqePYj2PYJtxE+uLIArhh3\ncRt3mPO7F/mU6E93pKdCNDFZdCRl4hxiDpW+nBHgj3Q+eFicBvrhNgEV1hsv\njSZZ4NHMuKP9iN2mslC9HNeWLTxt0KDaQGST1g51yqllhEEH1ZI1J/iz62Ra\n8/UcX2EJoNZ5BXAgBe6DDSa1AYv1MrsZDVO9woN+zDOvke8kCRvi+hgpdFt+\nYR87LOHVKIkiyj7eQpNH6EeQ67Ekdm/5onPWHC1qIizBAtSqdYXFkyEkbgNC\n1RnwqVjckueEla0mi++Jlgx5aytOJz8k3gElOXEYFCPFasimsqVsRG+IWTAt\nuadB7pnQgRua/U8mXU5ovinaIkZoTAihnSKdKPY4naRggctaC9raHsCE9OTS\n8ZrHX3g5cfMWvcY20UH3gs7Z4gtTQ1DL0wr2bBIyHI/U4q9tp8m8bL2An4In\nhBVn\r\n=KlFs\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIBrxeHOTT/ymSaMX8XOFTilYRwf1nEGb6Tdc5rSVkkcGAiEAlVmmZ4cImVvCGz5CRz2/bF6kOPDLmISxTRWDXMJfYFw="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.2.0_1579183466953_0.5258227630824657"},"_hasShrinkwrap":false},"0.2.1":{"name":"@sensejs/kafkajs-standalone","version":"0.2.1","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","cleanup":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"0.2.1","long":"^4.0.0","rxjs":"^6.5.4","tslib":"^1.11.0"},"peerDependencies":{"kafkajs":"^1.11.0"},"devDependencies":{"@sensejs/core":"0.2.1","@sensejs/testing-utility":"0.0.8","@types/long":"^4.0.1","kafkajs":"^1.12.0"},"_id":"@sensejs/kafkajs-standalone@0.2.1","_nodeVersion":"12.13.1","_npmVersion":"6.12.1","dist":{"integrity":"sha512-/2317JVDbl1X9VEDLOHDLssedhgybzclJ82oKQZ2VPctLzDnHKSQ8fw98JHb+q18Fn5R0JDKrmCBkzq/z4lLNQ==","shasum":"354838fb7fbd4080ce28b4d514a876870d43257b","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.2.1.tgz","fileCount":20,"unpackedSize":31433,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeWLy1CRA9TVsSAnZWagAAZkcP/i+PgVrS0RL++tEe2P5J\nh8clIpvyHUumrhX68qP/iY6L+nKjW++k72PWegL06Q+2X/8DkDMIQmKgYZ75\nzUxXhYaGlEMUu/vCZtlKZMQYWYaGeGcninyigZY1Sy6LcAJcM2k4VMvF2ymp\ns+GjuizrR0dMo3tDSe1myYKS/eXdhW/5PUoF6j3OYwVZCMgE8dVwfeVQueCD\nBdn9Qcfa8mYE+gYhlk+pQqsDz1tr1qKgTdJ4KoT2unLmqFTWBmIEnx2iQmPK\n4lKdq11tDenx7am3iNFcC+qjgdr2g4PzVbNxSkrgGG/RSN6Pbk+PWMxL+hWg\nSU8o0gcYD/xQ4+AuiiMdiyvuAV6dEjv7Os2iPUpzLpHAITKZGzwyJtMOEhNl\nhTxg1+djKWAmck3NZ/D8GsUpMO4aE8BGcUVzMnyvjhsLAy2L41C4Nxe6XvrP\nbJJfVjDLkOX7/p6SWuIbnunV0tku3oL3o5Kxfy5nO0nz9EpPPTZeCxSRI4he\nBZLeJ7Si3hJVlcKG5MVdGINjrCvYiz1tWTuYWeKPL7a0P0OKefYo9cD4cStZ\n/klUq3bDglnjZoTA/eh4V8macZNhi5zGzgGal91NjNyZBKhn2A6Y4GBqqRka\nQzzs/LAhowBuMEHm7t9fyPXTNCNm3MaxaVoAOag7SlKZ7Bb1Zdcc9Cb4qp8I\nnDST\r\n=mAq7\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIEO99U9JihVrxs/7B5WU81CNH6jbfiGIVX8b+4a7dml6AiBwaWVhOkw4Pd73u0i4t1A+5jDVAasewozbtgJzxb9nJA=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.2.1_1582873781162_0.6530273095700716"},"_hasShrinkwrap":false},"0.3.0-0":{"name":"@sensejs/kafkajs-standalone","version":"0.3.0-0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","cleanup":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"0.3.0-0","long":"^4.0.0","rxjs":"^6.5.4","tslib":"^1.11.1"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.3.0-0","@sensejs/testing-utility":"0.0.8","@types/long":"^4.0.1","ts-jest":"^25.2.1","kafkajs":"^1.12.0"},"readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.3.0-0","_nodeVersion":"12.13.1","_npmVersion":"6.12.1","dist":{"integrity":"sha512-BYCFN2hf+Upo55KY8TcreLLMDs/CE9CfTUv2TUeLm2mIKU8AZRIg0csPeRFJyQGTbiqlFm1y0LpfvaoCRvS/Dg==","shasum":"4b440bf4ce01932483663c3f1c4d51de94fc5c82","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.3.0-0.tgz","fileCount":20,"unpackedSize":30929,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeYUXUCRA9TVsSAnZWagAAzbwP/14+xnmpGOTx8EJB6uu4\nbrdDSB0L985brGqgapUFuqNbhGEnDUY6yDrz+cLvAhP2DbnDwsN9CfswZCaJ\n8/RF2bWsclq+XBossi84pyM6CUljM5ax3IYkBpeUZVXXEdRoamYBttN/O12J\n2QmEJfqP/N24g6TA0dQAeahLsW0sQHSs5GL3+rL5fTzwwoZ+i1xe4pr9KDU4\nGyfV8qi2C/M8MAMgD6ckQdPlEg2wb4Mapn0soqtmnONDYPNc49gsm/tm+dV9\n2BONGWh9F1aRIvqsLaDnj2Hzys2By8B3NBDvRBVnBvieA5C44fjXX/L9BUbh\n/zsl4dj/7OFIHCDmXTqOWc89kcbreNYe8bkkx1ueA+EjfI2th2v4yvCOPYEF\nHZmTe4nbBMeQCfq6Elv+zJ66WAf01sNHI8bZscpIT7XqUCOXexEZUHN1UQBf\nkDA3h1uEGu7dh7OWCZKHHXemqr0vRgKJoySJkX8rlBiXn3om+YWA3SFP8Eht\nQFpddzN5zUIV59DxJFRzFCjhm8t6voCldnWLXJT3wZeK69w1hgt8giYaISow\nwKWzgK5NGzXTNWtErnMpvazFFYvjHls9MWuHlXH6LqjyRDxFHqLxUOkyfvk0\ntm1WwZ0sY1aEJ81fk9I5Rr1fx2Q33fKGlhcLODfC9mEk2HbSOfOlWFYm/5XC\n6XgQ\r\n=BCzX\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD0GzZoWDxiJ6UNK9S1cSCn6NCg3WZWhTGKDvavaoom3QIgLyXAbWieZQesk03HNOa/e2NrP00rEH9NbsdASn/0bjU="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.3.0-0_1583433171507_0.03768158064240357"},"_hasShrinkwrap":false},"0.3.0":{"name":"@sensejs/kafkajs-standalone","version":"0.3.0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","cleanup":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"0.3.0","long":"^4.0.0","rxjs":"^6.5.4","tslib":"^1.11.1"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.3.0","@sensejs/testing-utility":"0.0.8","@types/long":"^4.0.1","kafkajs":"^1.12.0","ts-jest":"^25.2.1"},"readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.3.0","_nodeVersion":"12.13.1","_npmVersion":"6.12.1","dist":{"integrity":"sha512-Lbi/ehPcYTk4GxRt5LHZDmQLM1ESZIOHF2yZj2/awm1gxJE26R1Zh5AEWQ2sQfRXlzbZzM9FYlbUxn29ulbE3Q==","shasum":"95deffad772063c88b1a96193aa04748aedace7b","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.3.0.tgz","fileCount":20,"unpackedSize":30923,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeYoNiCRA9TVsSAnZWagAALBcP/A9riQ9mdckXecP4au8T\nDvhURh2fTeqM/pYy/3lmXsW883JS3H1ik010f5idV1jUvrkBlsWE+kfp6dc9\n9SmcDhlJ7WqW6DwhJY6Yay+1XSyaLR1IRhFE3QIdyJUMIzq6TgMqwB40atud\nskUqsP14txNFebRjRbSKqLuUd+emqDWPrJ2N1QPao5a4+OB3aCc6mTAPfGrR\nx2bhBJ/WULM1ScXjNK4FcKeIyIfBzbcnJCDgxfv8x9WTQTBi4VX9VlERnv5P\n2wgnyTl0OKNedNV0IsGFw55hMYsEoKwrLioogiDjkWAQu72a7f0ko5pAsfU3\nNSNRn9RjqwTqyOnDghyJhnZaTO4q78pjZ+W9Pr2YIB+GmBAH1cvoEh3bNVum\n8nr9JsPD0Z5dh53hZtchf91nP1BgXayGKvEbNRz2vC+3PMd/4uLcPCAis4dA\nExP2df9qNh95hw7Qo4qdFBzJuiuaMy5fAl5AbdJnmqZzpgj4GO6AtvwXL8fn\n8ClKE2Pg40TvWsbaPkU4TDtPt4R3XVc0PX6I3jw2A9XptnOsSqMJAOBfwaCx\nPrfc123oJRI+cDZ2g1ZgLPkTB0DDAICQ75kAvGjjPMFLc7nfPG4mCU4aNJ21\n1ZiXd1G5B7Llr36OGRxJYbDx9JNL+4iPRXmrxDhzEIw8a9vqLve1r57GRhEX\ntol9\r\n=UKWb\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCHelUPiSrcsHiCITxZroCiyngkZTnjJGNC36eIfUFCtwIgN09mqL/ZwRrMs8fZT188LaF+UzqtIDpZFs5VI4QJRaM="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.3.0_1583514466401_0.835678355607381"},"_hasShrinkwrap":false},"0.3.1":{"name":"@sensejs/kafkajs-standalone","version":"0.3.1","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","cleanup":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"0.3.1","long":"^4.0.0","rxjs":"^6.5.4","tslib":"^1.11.1"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.3.1","@sensejs/testing-utility":"0.0.8","@types/long":"^4.0.1","kafkajs":"^1.12.0","ts-jest":"^25.2.1"},"readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.3.1","_nodeVersion":"12.13.1","_npmVersion":"6.12.1","dist":{"integrity":"sha512-c5dJl9WsSjC9d82W8aJEJjy9yr0qDPIO0F5IpXMp38YgJbeIgfChGMKE/2m6vAbSG1yyc+Hn5vXIOQsG+xSFNw==","shasum":"f9d61d706f5888e18f29414bc34986b552265bb6","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.3.1.tgz","fileCount":20,"unpackedSize":30923,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeY9tgCRA9TVsSAnZWagAAgoMP/3KyS7u8NubbvhyKwXpZ\naMqKp3jjWm+OVcM6s6c++67dgJeih3vpO9nwKzNYnll9fjDtv43Eg0TOCoGs\n8vW6Nyc0mpXQ9XkAtTT5j92hZxEQNKBTgr3HKdmoEsC3jnruAbKXaZ6lDaAo\n0l0AZrBqq4P87qB04hgAfyKNdKEG6Fk3iPT2mWxUuTvU8eCRRMBlah5wnruj\nGWg2WOwg2wh5Pt59JqQKaL0NVpj/6wME5ZaMgdH+sF/vev/BuPlFUAD0gfD6\nRs5s/mn8vslXAz3UwzBAuHoWe8eoe+tH8lLutilLQJ5DNaqiIbmFPu5+J49T\nPj/BRdUChfss4SdvlOiYePsZWZZ5FXesrHj6naGZQlPDqDhZPRYzlCCUmQQ7\nwd+7PcvBd2XyPST33omBdwPWBDjWqjj9/+6RJb9E8z+oHyXn2Ur9VH0900wD\nczwZZFRhodW4Gi5sQ46lO6QKdfjufniETAe0BQ1VVFigjaj84vdt/gqgNFvo\nLUXBjiRweymAqgfivplHQSBFoSomHQQxIvreNLlDBkBz+Eb1ah+4AZP8KCBx\nO7m3mC4iNeukJvJyfdSlnFMefVb6yPE5Am5i17CZhT2K+ofiYZD99utTlQ11\ntod3xQMn33j2rp4KNZik9xnXoMGOaFXn0YcGZPAJw5CaKuxqkY7A7egOIDvE\nM6yA\r\n=m3yG\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCCVJmpw5EoRYz1b48Z64e6EeizXCmIlP6WdrUDU2SRoQIgLtbNzh8djKzjH5YfSrRHXnjYSwZF4ps256hmOaAuYqg="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.3.1_1583602527773_0.9429932734833595"},"_hasShrinkwrap":false},"0.3.3":{"name":"@sensejs/kafkajs-standalone","version":"0.3.3","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","cleanup":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"0.3.3","long":"^4.0.0","rxjs":"^6.5.4","tslib":"^1.11.1"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.3.3","@sensejs/testing-utility":"0.0.8","@types/long":"^4.0.1","kafkajs":"^1.12.0","ts-jest":"^25.2.1"},"_id":"@sensejs/kafkajs-standalone@0.3.3","_nodeVersion":"12.13.1","_npmVersion":"6.12.1","dist":{"integrity":"sha512-Xx8LzVTJhinwCYy05E+p7kx68EFdhBPAZcWWjApO3AZjfRNTZtkH1LeYoWvPQISqfVnlXEs9BPjtJnoj3MDrsw==","shasum":"bd4018dcba49264229e944249230137d2076558f","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.3.3.tgz","fileCount":20,"unpackedSize":30923,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeaIsACRA9TVsSAnZWagAAhgYP/Aj3HnBA9vKqLBlRFyMV\nlAq10BXeMmVGmz6kI2huHkpgxcLekNhChZLE2oULhClu++w1CIxNdaNaCuZO\nQFmzHwBvmsgYmE5wHV75rFZraIfMKRT6VTr3Sf/7UKWp2Qbuzf1eOuKeGm3A\nBVU4uEft2LIGgd3vlQRvvg+9wbyrjBf29S5lcKfwxHLzUXHi18rR6aqV+uYZ\nDJX8DqrjtqyNsJnTLrkgvh5RjyiHYI71nYcf3cvJ5ZsRlEnIzgMF296YSuax\nNzj5rBqFAw26EvDmpo8bXcdfkDRH4l0LkMGy9FIesOHQzhZzT9I/JhFJvv1C\nt/4TC2PpSNf4uz8hs6mkpoMhK/G41r1uwhYEOcmNZYsBR2MCPW2NtL0C7bt4\nVRerqvs4IPQ8xW80U/RRM0LaHtWpVi3mekEEPihtkw4kLHd9LMyf9SNKyEnT\nb3Gc3+VGLX2SR1llDfG0gZ8JSjBL6UYqJpv5TPqzAcEZaxahhPDeZA3TuRfF\nNm8eSAOTc5+fVxCPA56BtqPZbGVm2AObxTqvPxBUnWO+NnGFkVLp9haKEw9X\nccIpHFfEQK5dTFGNWEAvHuSvwk3XPxQVaHuXHBUuxAFAG2cTN+RjRY10vLAf\n5R7pCJhbHdkceWtbLbHlhdOyQOyJXM82OLecKKeknm+UOsD3NffYPclg2AGY\nnrxE\r\n=5CEU\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIAWdmJyG+R68FsCNfOLhwSgEuzCFAQLdQaqAgmeRpM+iAiBH3qWrkzKWCeShbucy0k5QAXdRMnnkyjbG/CaIwQwWUw=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.3.3_1583909631600_0.3683792430663979"},"_hasShrinkwrap":false},"0.3.4":{"name":"@sensejs/kafkajs-standalone","version":"0.3.4","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","cleanup":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"0.3.4","long":"^4.0.0","rxjs":"^6.5.4","tslib":"^1.11.1"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.3.4","@sensejs/testing-utility":"0.0.8","@types/long":"^4.0.1","kafkajs":"^1.12.0","ts-jest":"^25.2.1"},"_id":"@sensejs/kafkajs-standalone@0.3.4","_nodeVersion":"12.13.1","_npmVersion":"6.12.1","dist":{"integrity":"sha512-5lNGha98ujjJynjUXIvtY7eR7YZSSfqAjSzRxnwZ2SI4Q/RPZr0epknQVV3/oqnkyl6MdIStHZwGQijdQojb/A==","shasum":"fdf2f589af75207be6b15ebe7b08400d31c69489","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.3.4.tgz","fileCount":20,"unpackedSize":30923,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJea0QiCRA9TVsSAnZWagAAibUP/0IxVCpSvcGE4Ko6R6mM\niPqeA/YCV6Hvx+R1tZSEjCabgHdaxYe4mZyuT5V9Nk7Y8hHe2q6yxuylCioL\nCyqqHsqhyrSpLpuaUguJnsdPDrGf7rrH5ODJ7EpDdc9dTX9sIjoTWU8HYKno\ngR0hwHewe1wIoT2llj29qbJUoJ5BAaqhDIHo6vfzurGSQ5TegNaJDbX8eREI\n7lWpn63sYuVOy9oUnjlQuPwgUAkY1N9Uv1vJkDrzDnhT+NA5OtTPMJi7jRrf\nf2Q8cD2QCpGkZ10OPgaVdCG78yUkhn/qcNdZDZvj2dCsqA0xrr95moP7nxBU\nEggCcWecGVoulmpnoMwdwbgA0P/QQC2nDp1E0vDVwWMpBVq0AQX9JKAH3IDB\nSL3JlrgDWSDRXiuFhj1JoZyG0yybPwiON0uye1lOfY0TY2VqOkvU61ye0ky2\n9HOo3DZYmgndsvKdYRtHJIIUSIZXpsuwmhCFFmluui0vYz4FJNd1zevDhq0P\nOLT3sMAOi4M3ov1Z1fYc1tu6DIJFNNbhAAClfe5clVRFYN6wXAeO4PiJ3puy\nwTWRTenvRxWNYjRznXqjsSGerv5gRvUdeAln7+9gspd3wvrZn3nJTxli1d++\n6SjtbI3EKof0usiQkttXBGN/1nYbBavuabl+uqZ64OqLm/2Go2Szntw9TMEB\nngXO\r\n=WFJ6\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIEJDOk3+5qE8NNFbDUJHihELJEDDNGiuklfFeAcaS94nAiAx2L/NzRIINpun0DnGHIAkyaQrbgVoegseoC6gZUK+bQ=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.3.4_1584088098417_0.07669817048974648"},"_hasShrinkwrap":false},"0.3.5":{"name":"@sensejs/kafkajs-standalone","version":"0.3.5","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","cleanup":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"0.3.5","long":"^4.0.0","rxjs":"^6.5.4","tslib":"^1.11.1"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.3.5","@sensejs/testing-utility":"0.0.8","@types/long":"^4.0.1","kafkajs":"^1.12.0","ts-jest":"^25.2.1"},"_id":"@sensejs/kafkajs-standalone@0.3.5","_nodeVersion":"12.13.1","_npmVersion":"6.12.1","dist":{"integrity":"sha512-NqguXZ7MtXh69Iymqd3/IacQB2u8jOsmzbMsmOZ3JCa34Csi4J9f98sx05/ovaxRliWu+gfCmYGJEhlnHrkLPw==","shasum":"b97a47a8f7f8441b87c25031a7a44c3ee45ff632","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.3.5.tgz","fileCount":20,"unpackedSize":30923,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJea1FpCRA9TVsSAnZWagAAIc8QAJGpZff8ZtuxBsAQWOjb\niOhhwC7AzaxRNss0r0uZRVcAnPdpvVQChbr0W8nte7rL6EM5nvBsWWIit6D3\nH8sMBP5KcrTUwcL7/BQFLVVzW7K0j0nkVQDQSRb2Z3q7UTu0HdOJpaASnoNx\n79IXRSizk+xPWuY5dGqOhpXx4pFb+awGp6XmBoY1ilhE2aVRUBIoXU2BbaSx\n5HXKJA+rAfCEz7LoL6mcn6efCVr87R6dtNIrx9PMnLs9OjCZQggfg/Pzdyfu\n8AyfDmmAPK06kInEkAmCZPshebc/uvX9a3Vt4GscImYwCuYYNxQHEnIrgRbe\nqN/sxPmUASfZ+XsRjqLkDnDr06Et38yEKIBms6qXccPO+SGpw2+QZecBDg8J\nsmFciUdhMo8YFopqgwIt1K56q1ppmdPPDnH+35aaiYQkUCazwq/96G5FaxI0\nwLO6MOGbBBdp3DKnbCIUxk4T2VZMxsrUihcn+4H60z804prJ9APLs1omdMnd\nWe0zocqRXSh0yAKqYXSYV9o3UeJjSfOXKxRpcBSYpBdEwHC/Gam3wLmLnsTi\nG4dg4oHDPmj3XcO9v2vx/r+cEOkV/BaFN8hpw7CbbtzVaOLtvBjZR0LlRmK+\nxS6afpuU0S/Vmu/Q9nwTESikayPRb3zahm6XsByCOmZWjboxpPbjnUOR/t5F\npTY9\r\n=Jhi0\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIEjkBTt4rsdrBLRCUwKRr7dwV+8fuHaZsOCbOb6Cm/U9AiAJu4f7d108u1ZMb1TtHBp/uYU+DGErGQA7rgOUefTNjQ=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.3.5_1584091497021_0.8020857176654452"},"_hasShrinkwrap":false},"0.3.6":{"name":"@sensejs/kafkajs-standalone","version":"0.3.6","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","cleanup":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"0.3.6","long":"^4.0.0","rxjs":"^6.5.4","tslib":"^1.11.1"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.3.6","@sensejs/testing-utility":"0.0.8","@types/long":"^4.0.1","kafkajs":"^1.12.0","ts-jest":"^25.2.1"},"_id":"@sensejs/kafkajs-standalone@0.3.6","_nodeVersion":"12.16.1","_npmVersion":"6.13.4","dist":{"integrity":"sha512-KhRRhyFUZRO8yx0MiAu9CaGowBJYvs3JeCB6lyDuzH3BnGTq8IhXfUFlCHJsAezvY7UBVfLOBb9Qy2I43vpceg==","shasum":"2b0e1071364d563acdba7af8545a2f70ef605052","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.3.6.tgz","fileCount":20,"unpackedSize":30916,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJebQ48CRA9TVsSAnZWagAAbVAP/2/dUY3Vf12bWj8vVRTl\nrUQe9WbOJPOBU/XODHJrzyx4oXkTlBvhGxB5v9zIYNhwzQ+sBIIjt2eo56VM\n/rYxCHlUoPoTUqHpCCtBjiMNQeZuA9iQWAGXwMAU1QpQbY671tw2jP9x1iVg\noeBZZAJAcr9encnuIYEDkDTWgHM67f5vmH3nlevfDyvOziTCHafn2NM3C+Cn\n2Fs7/TbgNAqksrDPfs8idpqHQwUEUfFypc0nXQGQDWSrgf8Oa+NjTsNsljqh\nevfGRrN2bM9vwD0Phubr2tVpOQfxlk68QrEp7g4Qqvu1AqJfuwisoYfYEhJL\nUEFAWnm1APBFmNC8bN560B95HAHZOiBshN6vPCR2fzPbLGGNmeAl3G3WjNGm\nzug4xawUdFtcePzVl/kJAfKXxWKlyM8VE6M1vV/OjKiarwCQXQgyYKbej2/K\nOQAOyUfuJAqQdFqfR9kdLf4zylRhZjGf2lg7qzMAJBcP7x9L2e5SwL7ihtzb\nHceZVnoQK7J7lIpYpRKm9AHOmTJzzemqFkPb6ibybZE/QuoNVF/Yp75ZUBOx\nK9ok23Rgw18lowbJHgZGrSL40PXEdSyOxFgsLdD/Utw26O/wOKsrFTBrm6ap\nq2nNET9kAW/43dTe9jtKeuG+j8eELcB2bt0xNhIv+x8l+7Ocv5Vox3d4qULh\nuxhP\r\n=MtYs\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD726pft8AJRgBPk9qfCWpXX5mzKJGZ/J4nnpk/wUGLcwIgJyNGATahZTd26enK9395F9d4r0tSJZ0Tkw8J3dBekQ8="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.3.6_1584205372340_0.17845254843425806"},"_hasShrinkwrap":false},"0.4.0":{"name":"@sensejs/kafkajs-standalone","version":"0.4.0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","cleanup":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"0.4.0","long":"^4.0.0","rxjs":"^6.5.4","tslib":"^1.11.1"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.4.0","@sensejs/testing-utility":"0.0.8","@types/long":"^4.0.1","kafkajs":"^1.12.0","ts-jest":"^25.3.0"},"_id":"@sensejs/kafkajs-standalone@0.4.0","_nodeVersion":"12.16.1","_npmVersion":"6.13.4","dist":{"integrity":"sha512-KdEFESxg4Niw7U/0OpcuKIvbbAl4vXFQqrSaIOabA6WGGmkJqmCTyavcTVSCA2L3SQBFmpxwRNgdIYrBG4+9Qw==","shasum":"9ee2f6a2b1566c07fd3d9b8ee3494e1cf600cb40","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.4.0.tgz","fileCount":20,"unpackedSize":30916,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJehrtECRA9TVsSAnZWagAAQ04P/0TmEhM9DSBJk3Zb9jU+\nkbxdjReCWtzW/TAJCHHwasCB/IaWdVtoQN1PvuoLD0LozKtoqp/uj9C0W4vS\n78UbM5jx7z0KFIrNc0VD5lYmjYT+Qhmnac4HYMiwOiOeMugSJFtPd9A2ElX6\nFyAh3nuhVvuTtTZ1FoMmMmpwRs20/LbetU4tXUv26ErECQCcVHe53SJCkWV2\nqgpBtTkQtL5wHxTPlUt4bfjiYwQruryJwbGnCUxEMoeKCZjQxNg7JvW6wyjd\nFqKmllp/9m0gIj1NhOJUas6BoL0bxxhbArCGODNdWrzHsK60GV4jd8nRlA82\ntAiseXPVPmlNNt8s0aXcwjSJSJ0WmjaO3UCch1CWXv8ep879JJEyljo+xVL7\nwUJLehj2KWhsPQtLBuItL7w1wSJ2sh3KPLTH7jrAwf9RBE8OFyJAp5MkO2ml\n9TQ1Brh3AfAYqf1jpF4o/oaRvg8fyklOounO/cZKuCdh+61zPBKkeZqjwgwu\n64a3NqEhB2L97IDkq1kZwxDaL8K9sUEGpP3ynptzi71iGUd0M2UCLhSPOQRc\n2+RcBb8tBlg/9E2WiSXd9jiuP44N+m5iypRH1dsRseDsc8Zt7+JekppYVdtT\nRhd7ImUauKWY9MFTVUbgrt+e9wWhLO5CeXBkd1EI+Khghh+0yMGNyEVq8eBW\nieWn\r\n=ZcFR\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIDCb6CPSLCVHugnsDxfKwH97jblMKlt7THN9DPz+X11FAiAgtJnoVCskFgZzL5r00WkKD2A6hqARXhHspmjJT76bEQ=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.4.0_1585888068057_0.1559958034700375"},"_hasShrinkwrap":false},"0.4.1":{"name":"@sensejs/kafkajs-standalone","version":"0.4.1","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","cleanup":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"0.4.1","long":"^4.0.0","rxjs":"^6.5.4","tslib":"^1.11.1"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.4.1","@sensejs/testing-utility":"0.0.8","@types/long":"^4.0.1","kafkajs":"^1.12.0","ts-jest":"^25.3.0"},"_id":"@sensejs/kafkajs-standalone@0.4.1","_nodeVersion":"12.16.1","_npmVersion":"6.13.4","dist":{"integrity":"sha512-NoaGGeLzamA+rbC4u3AJZLiKdoiQO3WNka5HbheGsG7d3Dv04y1nwkzxB4GOM/rY3ziF//vx4X4PMzxCR3irXw==","shasum":"6b098e2979d9d93342876f6b562c63a0beb0cda3","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.4.1.tgz","fileCount":20,"unpackedSize":30916,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJejECaCRA9TVsSAnZWagAAxd0QAI6LT3cS9Trct5Iir6U/\nOTM4NhbRoDVULJzv0sd1jJjGdJp1NFEn9nfsrl4ypMGNAO5G5KE1+AxwFUo7\nSZObrRgZvaFsiYn5RpmOc3dzex1t08njqA2PPFz0amZcXfDpvkoFHzDjrfz1\n2QLkMFgjroZk+zU+XgZv0hEpXP90IZesQbLXkACvtigB6XNxHMD/qzLyZMfQ\neu7FU9uHYyrlT2aLYB/KPEmoboaVOUyhVcnQYqzTTY7LtWLG7FHyfSE5arEu\nJYuJJCGqpQ4LT6tis9IObPtvq+rQeCfWv4CC8L5YpDB/j/7KzEl/rRzHISdJ\nzKd7gUgMIgvtfcKbbF/2eAhZQNXqJvxBObZIOVjvIfw77DWojM+2xcR286pu\naeVZHvnGLZPn+jyKbINVss73lHtPXiB3ooeetV7T1lyQ36N9hPf/0HZLbcwh\nfDkNUBVwTHd2WBfAkFI4+GZWQB8GgDo2o4ztR5BadctuSxEBN6Oe7hOCfig5\nYm+Nm6AFaiPxq22NZ2puKYq4HxyTAlzuC3GqZnbd9O3P4Y51ruWzUx0MchnA\nm1SMSJn/RNZBk9d+FQ+Rc5w9YDFJtvNyGl2AYWN2v/7f7NNYbsRnW33ggPS0\nq902/869a0V4nnKjw1bYKQPhoXFzs1+EuL9DHK+x8TRQOZIWwfGItiYvoXcX\nREdy\r\n=Fsgv\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIBQZ8qrFsLQBh3lXQm/GxMUKL7RgUf7fRU+YSJZLlLdhAiEA8TuS11UGXpNv3t4sMmOcHslZvCSUdtKvdktVp1+8A5A="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.4.1_1586249882276_0.8773580688611076"},"_hasShrinkwrap":false},"0.4.2":{"name":"@sensejs/kafkajs-standalone","version":"0.4.2","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","cleanup":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"0.4.2","long":"^4.0.0","rxjs":"^6.5.4","tslib":"^1.11.1"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.4.2","@sensejs/testing-utility":"0.0.8","@types/long":"^4.0.1","kafkajs":"^1.12.0","ts-jest":"^25.3.0"},"readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.4.2","_nodeVersion":"12.16.1","_npmVersion":"6.13.4","dist":{"integrity":"sha512-aOubm+k/PbCjm3ITUvgJSwMonwS7A/czbsS9VoKVnn1FDxLPjSTlNtYHWkdNbA8ensma1q6RHsAvbnEtrUYc3w==","shasum":"c62b14f9a97480c72a443a61cdcf9094d24fed4f","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.4.2.tgz","fileCount":20,"unpackedSize":30916,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJejEVpCRA9TVsSAnZWagAAvQcP+wZGORu3ZocnXMlWN2mj\nfw+XRlp76BXz6vklG5ZfcGTfbtDclqur45UK8nDA+WkoTmxC6/Rwr/0JT0rJ\nLs71xKTNsTg35mRCw/9TMpysJSwGBwHRvyh17NODt3BXSihAkHkWxyWa8sIh\nye6f+jBu+gihfmcI3+8UO64H0hpzSfkUiV7fTzWPIGuYMYSmGQd+VXukrliZ\nznkkKwOETAGnFeHGnOesFmEofgMLBMtCsKYlDutIxaeViizXJclLUwndgvQL\nt1oAXYv9UCXRRhYzOro49aD7XNnTqm4onxBDAr+qPDFSNOXtjvGRGG20w55W\ndGq04STsuK8XJA1WPwRa9nW8yATbo2u6hrNc8VDYvBpdQ8fQk949VOXiRcq3\nZc8nVw8GBN0Kp21tBHk9OkqhIfxlPmZ7b+Eht3bl3yhoZtK86IV6dArkNYre\nnpJflfnB0Lqd400KO3Sp7iyKCeLEGwHSMeqnDp8ArZ/Is5TA7Cp1p5qdXVid\nwcuwICxeSuB5xLahYumVbwB97xV/XCo2BTXD3jDsMT0Vm6IcN+0swJ775tUK\n0FgjvV0IXb4sBpPkd5hxD+Odcri+IYoJ0a7Zn3rI7xfe1ZE1PUimRD2EYJMa\nms6JpJZ99ZjNv7fmU88Bwy5cOblBZ8Bo62OIOtKE83k1yU+ZB+7gTrq0/nhz\nqaW5\r\n=1O87\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCFOzjKcZimO+zaGIL1UYNBO9oFH2C8ygJ3aydMqPjETQIhALTy31Q9txyq5yt9RiAwH+/TcQNK6oJr/d0SAc/WYM2M"}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.4.2_1586251112683_0.12008011932102236"},"_hasShrinkwrap":false},"0.5.0":{"name":"@sensejs/kafkajs-standalone","version":"0.5.0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","clean":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.5.0","long":"^4.0.0","rxjs":"^6.5.4","tslib":"^1.11.1"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.5.0","@sensejs/testing-utility":"0.0.8","@types/long":"^4.0.1","kafkajs":"^1.12.0","ts-jest":"^25.3.0"},"_id":"@sensejs/kafkajs-standalone@0.5.0","_nodeVersion":"12.16.1","_npmVersion":"6.13.4","dist":{"integrity":"sha512-IRa8kiChw4mAQ3+35Yo9hHujtJMdRAQRtjoN0//PmJYZwd0IUmZnLMZmk8TRUlCXv2+STh0/SOaRMfVtI15sfw==","shasum":"9b228362bf14d25965ea7bf3fa8e96d4e5db18c1","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.5.0.tgz","fileCount":20,"unpackedSize":30915,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJejLtCCRA9TVsSAnZWagAAP+wP/345rUAopJlvrUZ2Pk0G\nvfTG2H1ZQMiJA05SYyRAVnGj6i6KHAekFygMdU4rXjztXTqTOhaPKW+iTrdR\nkAy7pACHhfqMFKl9E2oqBaV5VvJrTqZvi6rWY2H1O7MT5tbeR6vTQWD/LuPB\nxV2rZdTfx0QpA9LSrxCYX4iOlLGqcYZIgmT3fPo7ShKmLkdd5zSgtbY6Dr4j\n6dTrixvVelhIlr91wrMTvbvPhHcwgfps7KR+M/X7WvJ0ym7uuSH3lj81KYZ9\nq+TI1ocCsNnRNY8i+aIn4cQ4cRbRuYJigKSCl6MEru22IFsHS1yTpt59YaSl\nu5EXLjzCfxP6twLbTBhE01vA3wRLFAWLq/wI2jJ7M7e6BMYLYbHjHNN0EV/Y\nL7oS/Vz6k4P6LWHvAtqpJ4jNoZqmxcaOE7ANWzL+EL5+PoV4mK1zRiij2hb7\nSTwKvZepzF+3ZgD/z7iE3l8iX5FzIcGfAg1k08wQtreWsmDPgxBwlDrtVDqe\n9dnymtimSY6F7L9tgqZ8sgIz2LWkxgB7yNJ42G0SIbudwSkc+pi6D1+QMSau\nEMKOfnTbj+ZMfVr0N/ehpsreHZ7oCIDPbxvwlN/WjYctlwdSNXDKJNF0amhn\nrgVHQjHAGVxKvTWJv1X4bESTenJ8O4j3CkLLEgqc6d94YWcYQZfnvAOAx220\nm3nf\r\n=RvE6\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIAHevqMXjIt2VYkmZwiBhsFjWYon4EOZMlIcoTlGyBa0AiEAm9mZmx60hmkunctP2BPpDukQ0/AODtGh1tqa9jezxHw="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.5.0_1586281281668_0.7758952791843408"},"_hasShrinkwrap":false},"0.5.1":{"name":"@sensejs/kafkajs-standalone","version":"0.5.1","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","clean":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.5.0","long":"^4.0.0","rxjs":"^6.5.5","tslib":"^1.13.0"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.5.4","@sensejs/testing-utility":"0.0.8"},"_id":"@sensejs/kafkajs-standalone@0.5.1","_nodeVersion":"12.16.1","_npmVersion":"6.13.4","dist":{"integrity":"sha512-KFSgXDDZr/v+Rge4rmQ9bJM7o4/DM/mw0HrxE5/sTJhPqNgozUeoYGwWkouc/9e1yjVuHr0dfWOy6oYZXG+Alw==","shasum":"84a75777ea824f540b10be2e4fa8f636506180dc","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.5.1.tgz","fileCount":26,"unpackedSize":45788,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJewVLsCRA9TVsSAnZWagAAhq4QAIeU9JyoZrYJZeT9/wp2\n9szr2iLiNIhckfNM1q9CNs4tD16k7hIpI1+f3rcNXdBGoy3p7Nh03LxnsOUg\nEPXie7p+tuWlO8Wa0bgvmjWsEds6vdcyAgZ1Aosy4WNBGl/cZ7AwN++OaXhH\np+pT5d3l9sy0YynVY/x84Y8ERtNuYc8GlBoZ2MgH7nQb7K98LQU6JLkfpr0V\n8M5xLhCRlKycQXNohqhFB0bR90IRm8UNdUZL7UE1KF78m/E3m+1Nie+iZ+RV\nXAL9XjwKGvSnkVc5RZ8PSlwe7qQNkO33i9zPvNXDeMcdNFN2W1xBSP8mIKIW\nPMldpF/cQnosbk9X0AZkKs70VPrx82XrzEAI8EsSYUryHqc/h4Xihldk+O00\nxY3jkb4oU3qKxVReiCY+18KHwM0wx4bNNIEHHGVRxfCwRgCxbPwylGatHm0U\nZW62RaGdiOWoSUgd5uy6mQYqqU6jz0WE2W6lZFJD4FiKEM4hXqDOg3SsnZE2\nIa4e84ZLzimtPnJb9I/Dh029IwsKbZZBe93LXlUNi19le9tMtro/8BeCJo1r\ncmb5R//Qy/giYeAV/Zyk+401ifCPlyEk4dDeW6ZzirhZFf5jG9AyOTHmcCCe\nPX7p0NTPOAUbIoygA7QScbVWC0+23hX7wmjW6EUIsCagb6kr2I187B3QVJSC\nQ6VM\r\n=vbIx\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIHVHIAKi2bVJtxEikBxQEljzQ4dnCAH5q2wBymLC+mZHAiAQ7GC+V4U506HE0yN8lrkzkGoMdkq2ZBEFTjhiRnFDww=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.5.1_1589727979982_0.006996905188801028"},"_hasShrinkwrap":false},"0.5.2":{"name":"@sensejs/kafkajs-standalone","version":"0.5.2","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","clean":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.5.0","long":"^4.0.0","rxjs":"^6.5.5","tslib":"^1.13.0"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.5.4","@sensejs/testing-utility":"0.0.8"},"_id":"@sensejs/kafkajs-standalone@0.5.2","_nodeVersion":"12.16.1","_npmVersion":"6.13.4","dist":{"integrity":"sha512-jRc3+z1IDHaDYq7ScCU/7/QOfCcK5jLDrq5cJNKebCile1nfxuaVm4dhO9njh8/1m+JPAWotNh9+4/WSz7uIdA==","shasum":"c4c356b1e8c1ccecf75c68eac4df376ea8fd026e","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.5.2.tgz","fileCount":26,"unpackedSize":46417,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJexWquCRA9TVsSAnZWagAA2lYP/iMrh7QW7JX1L7pG1U2x\nfSqtPGwCCzqhZsZobLR+rS2MexS977eMquTL2/fRoMcE2HbQZ86VNEswv35f\nxpKcGsU1DRutrhkwAlKYaaLIRKHokTX9m89ZUnNPxZ8SmYq3Hwab6MSD4clk\nEzNUG20k/ObIKMZ9SeOC0OQYD16/kJFMu9ioiI4x11M09I5162VdcyxrE9na\n1bHwUGfNp4BK6+BeMHage0p1ZH1wAULP62EqF4nI7VhiQ8uQ482NtWF6NA91\nt85WH6ATn5Tv25NasLnITePVfP/AhNvHrJFJ2EQMoaXOnk9X3EkUiXnjW6tz\nY6WMSBGp6pWG4HdpuluIwxz7BGbSRKYo4RJmI1h4ME8rGzwHo3fQWtieUE27\noOwSlvhhlGWMtYcH1DuP1TVIPo5oPcGYznt+cMz6FW7UtoqbNJJVvMTxP3N5\nZijKQYAfUevP12DGoqY1NhUfs1gfrOXFNB1SK5ST/122VVUlI1jEB/ytRHbc\nJpIf/hbu/iD5h9zLIibGZpB+0xgndvUV2d1UfVHb/LqNCWndredG65nsX1NB\ni68ltinz4m83k+ucJ+Aasjn/wU89SaQ9w3PrzbkqHQ2UlSSWQNi/5JoXrJk+\ns2cf1Q3eMKwx2nCWtZzIWPFD/ni4Mkm/wzjXTWtSBPzRB9+nLlOqmPfAaq9i\nuAsv\r\n=vvm1\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCICJ3XRoCrLE5Fge2EdhcKcbXckQxhFh6lfp7Ot4xED2CAiBzx7Aazai9RHRDgtlswrNFIJWs3+6HC/Y8e4XWYgtJHQ=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.5.2_1589996203179_0.6848899827513264"},"_hasShrinkwrap":false},"0.6.0":{"name":"@sensejs/kafkajs-standalone","version":"0.6.0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","clean":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.6.0","long":"^4.0.0","rxjs":"^6.5.5","tslib":"2.0.0"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.5.7","@sensejs/testing-utility":"0.0.8"},"readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.6.0","_nodeVersion":"12.18.2","_npmVersion":"6.14.5","dist":{"integrity":"sha512-5nUXQ1BGbmN2+y8nH4pjmotGoPgpcGfEQJQHgKjpqsYjdSrq6Wmqjn5su9bXqSRM6RaBBFCiBqqwkzYFDFqeLg==","shasum":"ca249591cf7bbfebea623a39ba381ed724aecd45","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.6.0.tgz","fileCount":26,"unpackedSize":46415,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfKi0WCRA9TVsSAnZWagAAbFwP/2xE+1lsgyPYNw5ggUFt\nfFW5GF18YUrb3yB/TjH0192/0+2YuQCQojlpmM1R2Pq/nUvs8vOEDRUVOak9\n1PJRepXW6nLGurahekReDFBLOwdP/h4fWepACWEsXuoVlBJMh84XvL3sHAfJ\nYKptaYss2rw54Yp0dsh1lgSTGQpIjBATwhdIHxXyJg1uwNXrBf4AHnV2JvuZ\nGphCvYOft9F2Mlmg+nTq7KQieW6cAZn2cqXw2gxOxWeDJ7aBPdqecVBEuUxD\nPe5/XvUEk3ePXql8+kDjYcSC7/SqWGlxG0QNkRCdWz6Q8fx8KhEZmgfishLG\n5M7mTSsrM7vQ1AL7oaZiJSk/JOXNV0DFIo28wRLCvU8lVSGjnpvyHkw5Y2ql\n8CGSxyOxf/98uaplTdf2naqgaFfB63N6HSfPLJ9FgvfEurqa3fV0i201vogr\nrarfwJ5Bth9JP3415tHzYzpT6Gh3jFpDzqcHlvoTrC2BRbxslYmUbpvX5OQB\nNuOz4CZHhOARkQMH6x01BfI9Yqcn1RXhdPcxLko8P+1SxauRMskJboZkAOUr\nYFuGvsXJedjIDMNrRogoPh2kolJcvEsuLt1NGA95XGM0a99V3VAkKVY2YOzV\nb9hs17t6zRUO+thMfBGo75XVx3/V/OxRmjmPuE5ffkRFEKybwxTiQyFjcIH7\nxmaW\r\n=w7Qe\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQC+n7Qc9Dqq7SakrmfAzSwW27idx3CGv3PpSKb5vn5bHQIhAPy5jcfARj+OxoT/bYOuWBhkkSqiOOnZ39NDReaJ8E3m"}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.6.0_1596599573745_0.7879825057317904"},"_hasShrinkwrap":false},"0.6.1":{"name":"@sensejs/kafkajs-standalone","version":"0.6.1","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc","clean":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.6.0","long":"^4.0.0","rxjs":"^6.6.2","tslib":"2.0.0"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/core":"0.6.1","@sensejs/testing-utility":"0.0.8"},"_id":"@sensejs/kafkajs-standalone@0.6.1","_nodeVersion":"12.18.3","_npmVersion":"6.14.6","dist":{"integrity":"sha512-QiXT5CbNBGJIkzX7FcFlYJEtINJh8N/TdEsQZhkd6hViC768b0b/C43hSv4qQ4fJnJJoTYXc/8zDlWSUx5RCTA==","shasum":"02e09e44659607dea2eb555efd9196044ba5c384","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.6.1.tgz","fileCount":26,"unpackedSize":46700,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfNl5oCRA9TVsSAnZWagAAgHIQAJR9jAZAQzJVgk0XKC7D\nm2imm1oXglgz19bH1w4/foeKtcYPkI10fUOAH4NZIDi7rhTKY5X835zNiQRr\nx5xsEVm9WpAK8G29gppGXfK0yO1F3rL6GO/uU+IAOV66zLAQxlZ0p8363zEw\nmjby9n6uBcOA/lCPotviJAF8Vilask1MuNOaVVqqs10lCwg1WusCgZpzMLTp\nYRUroiaJDzGKhtvl1IxfqEtoNyvFOULLccqXC0lhJuJiVPCU4i110GXY01rb\n3RZaWtGHCnOaGVffMXOM/nkH16YHe6TxoMzVvjTNSg3CaQq9MWI38oMylKPs\nTp25p4JTnxytQJoWs7Avr7nc0ilcTRJ+iEv0ASgjfAAPg7ADn5Xe6uRIWhB/\napjr9H95ZMMMIoVlJSXXshxV7tSAbFsnU2ZxeioRfdGZSVD6rvx1izTvveE0\njpshJr1tuDKmyhjwEDm0EmsjPAVxYR3c6M6S0cONYQoaKYRI4dFahuVYApFn\nB9+01OddnVOYVf2PymVvmE68ayEF/2/PPPFZ+1QXb1fcXSCr43dCGHOOeiTk\nyEvk+Ba2H5J/S5twE9oFHOtKRimY/Zed/dCkZ/CLLHjBm2k5xdCsYHBTEErx\nJ+5FOlAjFu6lHFEf4NqsLw+P23MK/XUZP+jiM62SajIM4J1BgOHjkqqRX10G\n8qHb\r\n=Sdfx\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIGJxaCoWvt5Ttw5ERCM9uWY1VeFS3VYZzbdUk0Aa6PZ2AiEA8pFfUG9EyOeVYAZASU/5NuvUKtB39nfO3Z4MaMSEofU="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.6.1_1597398632366_0.6098572600457695"},"_hasShrinkwrap":false},"0.7.0":{"name":"@sensejs/kafkajs-standalone","version":"0.7.0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc -p tsconfig.build.json","clean":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"long":"^4.0.0","rxjs":"^6.6.3","tslib":"2.0.0"},"peerDependencies":{"kafkajs":"^1.12.0"},"devDependencies":{"@sensejs/testing-utility":"0.0.8"},"_id":"@sensejs/kafkajs-standalone@0.7.0","_nodeVersion":"12.18.3","_npmVersion":"6.14.6","dist":{"integrity":"sha512-yGgpU7NIW21cSMRJ9ZmN1gp/uhGDAqqdX47wj9yZZ9kUbKy0HhX7AM7so6nk7K6/Lm9iO1GcWatTdmyYxfca6A==","shasum":"9bd63abfd1a1476142490ff99d3b41532956d1bc","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.7.0.tgz","fileCount":26,"unpackedSize":41403,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfXSNLCRA9TVsSAnZWagAA8AkQAIKX4AXK19VLShw6VRoJ\nSmg3zE4+OOBHC52L/o16ugUvexpQOx4ipBriwlkfwxVBp5zgG8L2TCXRmvMN\n6hopueP3kCdL9aSbk3paaFknqNm3QlVmwX8Gizs02fiezDB8KWQZ6mBQg0EU\n5Wom/Hcnv0gV0jhqw0fOTYkr8zOMHyvsz5qUmcmfo3RR7Y+fIvkQR4vHTMTi\n90jHWVMlkm01jb98s7Pbg0jkAcjVk2OPyyNj3tocVYpgC1UZP1vWYnFM+jQp\nhpw3IXSbjaR4DhhBPJ5psqVe9ngphRbKBIGiB9sDZatITi/dDs0/2sLlUQWY\ngW0Iotm6948PwHXFRWxIRszYQvuf42OHVSzBCyeWuEw7cPZztVHyB9QbJMe1\npi5Og/3Z/XaY0cfKsByHw8mtn1s2OfqNw9DIjvK3kXG6vl1BM2jsoPqe7sdw\nohjOtBQx2tvSf+admHBDArxvM5ReiAnvfqkuz2V1TOuma09Ydm8axY3FvChs\nIIUIPiUsmBsyOiWwgi8yrF3LeDG0wz173chxfk1IAaHHHN23biw92P2dbyq4\n4CllYIOIoybNe8cRAX79MlCAmEDLtdapHucrxtTaF8WwdNEbNOKqnnvIN726\nwuMPvszhUPPrve8J5of7mM2ZDbexOd1jko1CjGwmsoUa0JzbfZg9WtQCbnvU\n/kWx\r\n=HfSj\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIHtILTv/4Jxj4j9CQkQ1xDBJxTgnrGm14maZ0PusI152AiAaHMYkaAL30G0I2jbQMgWf4NPn1o0vejTmTQDGw5edFg=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.7.0_1599939403285_0.5795967104680737"},"_hasShrinkwrap":false},"0.8.0-alpha.1":{"name":"@sensejs/kafkajs-standalone","version":"0.8.0-alpha.1","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc -p tsconfig.build.json","clean":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"long":"^4.0.0","rxjs":"^6.6.3","tslib":"2.0.0"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.0.8"},"readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.8.0-alpha.1","_nodeVersion":"12.21.0","_npmVersion":"6.14.11","dist":{"integrity":"sha512-nK2WfMBbCxab5KnAE21F3gjI8B6zzHxUDZBmqa/PfWlvrlpvModMFvdOcJ9gAuxOvvcv2OUu7283IKgkUDAb4w==","shasum":"98f748e9c18de93ce14becbb7cba415f0b0b65dc","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.8.0-alpha.1.tgz","fileCount":26,"unpackedSize":47938,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgXQ1jCRA9TVsSAnZWagAAoOIP/1zv0YIpa0TZIQfmM/aY\n4WtHv7DGfc10cpBx6f8PSUE3ZxT7UamalrnnByhCcGGm59qEWsFPW1qv1k7Q\nHkEnVOW5s9RDyhzZhUinTez93wJxqwDewMtZnqINP2mUxxvo0BIXRBbyVbH2\nB43QHNo9r0KyNTNgp23+GHsG9uo95KbtbtwhJK9iVxXFouR9eJEVaQ5s9QOv\nrLeanTJSGQg1FX6lMK0PPmK0eYZH5Dt+mQH7HLFVvNHj0Sc+gG3f+Eb6twlV\n1YB8kgXB0kHloX+WxbcLC+LGj5sRC+7865XNlqpzsbFK3+XqzNMNgcfT6pOY\ncW/ftbh+uDojbCvpMze2xZYtpIVpnbDQqFbi4ZGT5aUnFMJFH41WvbDaLwJZ\nTLtPM0ckSSf0IUVZUyIUmd4RmUuCk8Z0B6FDRV53Spib5uShbJaO3HGMGlvo\n/5MqQwpsZLxqq3+J1ZPzwMukaIo0ZS83MhQTWevYkiba6etIiMwKu9B/aF5i\n704bZJ7PDghFlqif7fJGaGYbtQj2qX1P6bG47axqq56gRjphCUWjkgf7Ercx\nZzY/v1r2sD2gev8dr1lzbM5aUi/D/Uo8Kllx7yS/P5ZXzBQVcPMCw7NzbfCU\ntu3TkpTggXODuUo464aGJOdKlhSKz9DsYlGbbmcTEcYw6Rd/rbNfO1exSEzK\nFxGJ\r\n=CvYs\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIBRXjXA7U5AXOg2Zdrbe4jwiA3i9IahT42sZDQOG1/UDAiEAlIaysu7cuSYhd/EPwloa+gwOjX2FzoG7pAQlhLuWcCQ="}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.8.0-alpha.1_1616711011007_0.20419277245042533"},"_hasShrinkwrap":false},"0.8.0-alpha.2":{"name":"@sensejs/kafkajs-standalone","version":"0.8.0-alpha.2","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc -p tsconfig.build.json","clean":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"long":"^4.0.0","rxjs":"^6.6.7","tslib":"^2.1.0"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.0.8"},"readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.8.0-alpha.2","_nodeVersion":"12.21.0","_npmVersion":"6.14.11","dist":{"integrity":"sha512-bnRUsF/8qHqynOpam7Dz1f58Lkz+G3xjtZ7mxs9iUpl/5zIiqNCYN/JDNPTLvC92QDvq8COoaTP5rRUc8BdCIg==","shasum":"d5ef6cf3df3012bbab74a893be7abc7a251a85b4","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.8.0-alpha.2.tgz","fileCount":26,"unpackedSize":47939,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgYdTYCRA9TVsSAnZWagAAN3AP/2DHHwSe4GrOYHQTXdWW\nxQtEPW3kM5d4JUGflldpYYgt9ExmY6zt8ehdeMyKez+eHFrQB4rdOtmh5GGH\nWtzrPs93XKkMCdwGaZa7CYrN/OuxfO5xGbt1de7YBGWYGFpiXzp3QgWMi45a\nFq0IK4PtJ78gtJqgcHqwMmuvlyfZAt7P121GDyxVtGbSeEHB0QbYCCJ/TuIx\nAr9j9N2k1qx7cZgdqxUu9k/stVc8zNtqL4CR3hVOIzYHsuxAGkWSReR4y6IB\nQeuy+gT8DR6WaloRzmuzs6hn3Wqr0xz4i/sUsIrSgOG2wbWyWafVeIFc8CEe\n2elU8OHF7ePLiCFYuCGo0Vu3dPUSxD3PHXnI6BxS2fJIxY0REiuSRvoblui1\nB98hS4+HKBsMBH7m35/5f27m/QmA2g5W+uJ9ILvnqIhfK4F7hWHmvvdKSaxp\nVGHhEPgdJJdj0pc84qiqcFL/NUsGpj8uXR2hKu8ddBq4cQOJw22Q40iIpj62\nlvHb4lGcxV8kPwneMjRGwaOBK+om1aPiiEPVnJc0VSJj2fiDysBlCCvdEAI2\nI6vyqT8zH0XKOAsLs8UAezF2r038OhD/oarOtqigTI9EiD619OQBgwVJZxQ5\nr0kAiT97HwV3EWD5+JyT/QqIPkzkOqOoACLfuvkUVuOYfTX/420I41Wafehd\n1oe2\r\n=Zl1I\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDMPSywuHp090lIwDz/j3POy2wafaeXQ2oz4hvp3njsoAIgar+iYhtf3OffkPYQEMOuHJiKR3Fzhtp+oy+BUxg/Br0="}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.8.0-alpha.2_1617024215728_0.3692229363708408"},"_hasShrinkwrap":false},"0.8.0-alpha.3":{"name":"@sensejs/kafkajs-standalone","version":"0.8.0-alpha.3","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc -p tsconfig.build.json","clean":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"0.8.0-alpha.2","lightning-pool":"^3.1.1","long":"^4.0.0","rxjs":"^6.6.7","tslib":"^2.1.0"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.0.8","config":"^3.3.6"},"readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.8.0-alpha.3","_nodeVersion":"12.22.1","_npmVersion":"6.14.12","dist":{"integrity":"sha512-aIVN4Mmd+wkjvYKLnHa9/P2t72qKoBEv1htdTU3zL/pcZkgGOv5qwhTHx+J7VTptcrFT4hZzeZPgSaGuQKsoFg==","shasum":"3f32a1de59448c927f6d6e9b76f9434d6d478e95","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.8.0-alpha.3.tgz","fileCount":50,"unpackedSize":96311,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgdLHKCRA9TVsSAnZWagAAsb8P/17Iir23UDNI+0HNxTE5\n+ROIyRryZoBqGOAs5Y8ytboeUq9obc5muFvT16Mo27S7QTYWtSzkaOcg7XqH\nMrOsSHZU3qA8TkrG4TM4zykEnrt3D57Hwn7uCYl4O8PaaJijdak7a5yIb54o\nXqSsyAFtHORhttO8AaOHYZCUqoWMsHazL8hn2ji7maHfdr1f+CrIxBTXgecs\nMQTzHUleZCLbRSlS8bfIOyDR4+A+LhZXxHQlliNEidi/szUCLg+dvu7suICf\nErbzMSYx+A1n2KLF9AynSOOQs9uTP60f54oZxx0//YVDyqDn/5hxMHVLe2OS\nsGevtn4/A2pF+MmT0vClbtAKoMGfc0kp8/pHBpVYsSX7w1fodSfeCN7TP2YJ\njwhd56JCJXpWdCSSDKnpzgknIo0ME3alv+WLnXy5fRux9CFxFGIC7EnUDg64\nFHeTgVczZpm0Bnx5mmPtPcTZMPZ8lnbrWnLnH2sK0QK0Wmu4iGvS7fAm9BG7\nrzhnMspM4ydK99lNHKKRXvIpydg/5E0ScfKwgnjOjlJzvCLF1EVsCa+5eMMA\nC8bX5DNEvUyRMB5Qp6OnBlP589gjBVlbmh6hv1efbc+3Ny6omuG4V+pNH6Uz\nAAPNXwgUBVwtJAqxiUh3/AWPunDnrLUEI8+8EEgsiRuqM74QcuKtrUSCpVha\nHWEL\r\n=fanw\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCICxfWcQyESqnI8b30PglsU3ncPnGmP53vP5HaxUgQeXAAiEA6FlsP2Ul1MiRDCMYu6bvTVVzL/XyQxl/8XrM3zs7AhI="}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.8.0-alpha.3_1618260426389_0.250967362943197"},"_hasShrinkwrap":false},"0.7.1":{"name":"@sensejs/kafkajs-standalone","version":"0.7.1","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc -p tsconfig.build.json","clean":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"long":"^4.0.0","rxjs":"^6.6.3","tslib":"2.0.0"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.0.8"},"_id":"@sensejs/kafkajs-standalone@0.7.1","_nodeVersion":"14.16.1","_npmVersion":"6.14.12","dist":{"integrity":"sha512-qyjsnvUQfIOY0/m+3i2GvkqScjkaNDKarUcNo6gnuadljWZxKanH5yoIGeAeNsJCl4uFCyiCEXS5MU2fLFnaFg==","shasum":"43b6f9d9c7b135a0c60a9ae2c2557e62718ab396","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.7.1.tgz","fileCount":26,"unpackedSize":42956,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgdWDrCRA9TVsSAnZWagAAlqkP/0Li7qgc+AO0QuPLqF1V\n4WZUaBZI+H9MZawlilT6gGRV9qBZfaj8vA7etWnbyw0FmTbsY1WjqO2i09ZQ\nMYIeXfLMldtKOtx+EKKcy7BaGtHsXcBeI7+uhxTyAOL2IqNu+hXjJ/MEkOJE\ngGr6NeYK7I6Ftb0cjJW3x9BDL+gODEE2awXdig3Tp2aExadliyCq/yTzgDhT\nEo+GwsF8sTteRCYu3tJvLMRaJydscWd7t00/Zu9Eko9x7/AaqE46waLCTnbv\n4yc8IeiyZH4xf88kr54CemXStkJEf4uDJq34nPRoE8E3FSa626ZndVuPrIqq\nSzPYS6OJ53LH+4DvA194gAsBtpayyeyMyI48crgRr0SetrEdRgLm4qphWaa/\n2i1GHp0vrn/zzAvPo4Jv+bBnpawXbvtZCrWfiv4c56LMq4evWt2C+A9hNoy2\n7Hwbtg9zArrq+8yfAuA5JGQeC0KpOEAEhYrNOiYFOpmdJcRhy0XTOKw/koIv\nphy1lfvczgr7wzOBWtloY3CFCASifk+oGayVPazU9VEJInR3I62/WmbjuTED\nUOq/Jv1V9TU3dpCPfoHZjzkX3GW52oYC7e5KQ542gHqa0MHSj4HqFXnOobBC\nN3tqi3mnvcaB4LLgma1hIJ/FhPsDHgU2RdgIh+xMWgH+SIQmrAFFpYH2R3oL\nFp98\r\n=ht7H\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDRkwe+O9KJOq4bir/DiC0yT5t6P91KjqekGNOviSf+7AIgbpNBWQptbvm5NbNqiWdMnqXrHZnqaSgawKA/UNXdMoo="}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.7.1_1618305259297_0.05779939152000857"},"_hasShrinkwrap":false},"0.8.0-alpha.4":{"name":"@sensejs/kafkajs-standalone","version":"0.8.0-alpha.4","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","scripts":{"prepare":"tsc -p tsconfig.build.json","clean":"rm -rf ./lib"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"0.8.0-alpha.2","lightning-pool":"^3.1.1","long":"^4.0.0","rxjs":"^6.6.7","tslib":"^2.1.0"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.0.8","config":"^3.3.6"},"readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.8.0-alpha.4","_nodeVersion":"14.16.1","_npmVersion":"6.14.12","dist":{"integrity":"sha512-FD+PDtKljO7Lo6Qo4F12eEriBWnKgUlRHIqB/O90qmg71wLpRhkc5F013fbmEwv4pDaF0JGSFUys0WFXVa3hfA==","shasum":"4a9d3a3befa64a5d705febe4ff05949404d47c8e","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.8.0-alpha.4.tgz","fileCount":50,"unpackedSize":96706,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgdYsCCRA9TVsSAnZWagAAgR0P/iD02i48r8Kdap4yXayL\n2LVfIuuVFrYOvzzWzJvogJyDjggv7QQ8zdwzvx4M4usrOYMwa/uv0UcFvP+C\nPTe5bFx2SAQLwb9MODS+XXbG8yKJkTSYsdphCJds1AxC/mEuF16qZPPp64lH\n/OSxvoIFEA0BZDUDZoYawV0cz8FaQRYOf0gr0lFQyyBDOlqOb9YgQtpclE48\n/afURK4MOByj8qnYvOcoKL6nUF+Bx9aF2UE18Rp1o2ybg9e7KCfKnqEgZiE/\nsDKYQgUWMKX4pcBhln6VLrmJy0t/nuBApDpc4PoZipL/vwoBxqRMcESU7yoN\n8q0tI/kSpXZcdQkPffGQt62re4Tu0MdHd9OOQfa995lMbzWOtEH3bdrOO7ek\n2oE94ieRweQOEX/7wXhUvmC3tns/IHT0SakFCnLYIChvgAC41Jr+qXNtX2ni\nnFGEF+rCwJFcdjB1fZyOi4BL5jRGmkLyrLsVeUwFVyGe9YIFt7PU8lLlhfjw\nT/VOIku7qJlnKyQePtm89MhL6J2srg/4o89rdRGTgPQUCWSDeeMIPn+ffxuz\nXF9hS2ZLE54XLy8ApQgf+dMPXDhcPZqk2rLdUeMxB/gG8gKYwIYCT1ejqtHk\n7owg0tGBkIVyzDf06pMVhoEW5Fy1jiopKiZH7d/6aOczWLGEHhUdw63e1Ak6\nRxmu\r\n=UMb2\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIDqxqeSaPjgXdx+J3DWR+8k8AQ0sKZIRqNAtgVaFy8C0AiAQRYhuHrUGVnqGCNuhklBhn4l/Cb2fJIfG7YNxC2ddjA=="}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.8.0-alpha.4_1618316033463_0.4122676264088878"},"_hasShrinkwrap":false},"0.8.0":{"name":"@sensejs/kafkajs-standalone","version":"0.8.0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":">=0.8.0 <0.9.0","lightning-pool":"^3.1.1","long":"^4.0.0","rxjs":"^6.6.7","tslib":"^2.2.0"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.0.8","config":"^3.3.6"},"scripts":{"clean":"rm -rf ./lib"},"_id":"@sensejs/kafkajs-standalone@0.8.0","_nodeVersion":"12.22.1","_npmVersion":"6.14.12","dist":{"integrity":"sha512-B+XlXF81+tWdwO6R3QySE44maBngHfDr/PnTN4wbuZYVa53MlQEmZ3/+jBilUt8l92VjUe4Ww4OKpSPotg90aw==","shasum":"a9bc65f7505eed13cbdcde0086ab19eaf80b880c","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.8.0.tgz","fileCount":50,"unpackedSize":97013,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJggMs7CRA9TVsSAnZWagAATR4P/08pPVgmSEiYPlOAoU73\nRt20MPNz7XNU7egREXYasumgAEUphAOuokFZH+zai5mg8BK6BAHPYfdYTcEl\natlYckcW3M9O7gFwIRb8lgWfkhqRu6NdX8fq6NYcQk9qs7wAIOUAhm0uEOG/\nzuzYht6aNQyPIhZSaF3ymMzDNUA03GhnaDAeqBr5xi1nIs9ao+dT50WKI+5d\nBiSDfcyxadwcaGD2g7wi3IjNoHo+yfm45FxbX5FEG+y5UtN6p62Z1LboT1ex\nYYL/juwSwzF3rsCj6S9soIgvJTLvhr9/BEUEmuzPEJ36zVqyixd3j7P029Ks\nUthjK5nCH9N4nt431AznQpBizDVe+J8ZbOIbJ1FKFgZx+sFvq+49E7SNUugl\nGFfJp9HylEPb/t//CkElmhTWGEAvIn+ymNwiYmqTpUO1+soWmvBNnPc0dVgp\nXnKNuf3e8jWR/f+vrMmANdRK93XAuPEr6pFucPTREWGAd9P0/X5w8Z9XWvXB\nMwf6IKPcWZmjzKgqFLFhgjB/XU48naNO5tOKt7J6zAcaqtd1r9WwHgQ6sWmn\nlbh8rwT2QMfZDiTKTznGHSbpCUX9v0QWpWwbJR9pPKE4DeXQHcS24UqtyURU\nwNRUo/fr2C7GBdyPJ87fSkS2XA+44nvj7GeqTb5T4NaQekBye8HHOt4cboIH\noaJC\r\n=dasU\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQC3zcc1c8BBhmD7Of2aKpY+tkx061zRm0OVSWI5ElT/QAIhALm+ig+J1dovdnUE3B+t7/WsZKpIQX+HB/08ZcPgiuH5"}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.8.0_1619053371429_0.5796784923590361"},"_hasShrinkwrap":false},"0.8.1":{"name":"@sensejs/kafkajs-standalone","version":"0.8.1","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":">=0.8.0 <0.9.0","lightning-pool":"^3.1.1","long":"^4.0.0","rxjs":"^6.6.7","tslib":"^2.2.0"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.0.8","config":"^3.3.6"},"scripts":{"clean":"rm -rf ./lib"},"_id":"@sensejs/kafkajs-standalone@0.8.1","_nodeVersion":"12.22.1","_npmVersion":"6.14.12","dist":{"integrity":"sha512-csLNZ8Fzbzb/HU3WRdbzwVTAcZSBqexsnN9ohhrVIV3hfAVK8JanbS3nY/nAaDMUqABvdfMb+l1lhV54bJZP5A==","shasum":"5920255c304c3801f724b8b0c13f428887db0a49","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.8.1.tgz","fileCount":50,"unpackedSize":97151,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJghYpCCRA9TVsSAnZWagAAd48P/2NKC76VUjzDpUPz7FXR\n01e3TzUNGtG8MDvblb284zZRtCVFYn9Q1owQiamybumDjoNYSfP9PjmDRFK2\nkxn/pnIN5CHC6GqJ84z1/VH0O2H5SE9gtnmrIMz7I9O+daACSA9vT2ZKhwpc\nmrXPL5zY85mUguofdGCOI5qVY6pld6trt26AktBTBWP6qM3dCVMBTJnoUwGq\ndPxqSnAvJ6LJb8RL7bhz6rbC4z6XEh8+MDIKB6rmQeBU3IiaGvd6jnTI1ivg\nfSyJjNZQHezlq9KuZySrafpofEKPAvOfz9zBk2v7ySRwWUJLo0Lc9wO56XEj\nOuFnFxU50ZwIr1HwCvU5NQh0GltkRxpvz7W1hoGHYRTz6Vt5pv5CuDFIAsoz\nWntmqK17aXLgk3n0hYzuivZWzqMCwd9uEoOkpp9xJHdAZgDseoQgiw3/Anl3\nNHqmq5hDX7bjPp10Bg8oc9GmP/a8OlZbZYun2h8KGfs1N1Dd6kY3ITzdkInY\ndPo2QiPy0RORHd7HIiiGfVzv6OClRA5mhOmxM4tOO/HPB5qpj3faNpFdaijI\nSmSSyHvXEgNpGGX+8tipmZilH26ct8WPOQUNIvuO5tTiAvcoSaOnTonhszhS\nIqke1qmlVEauHipWj4rVEdkKxnswPnAlKlKDH3DuBWkyO2GRdRETYggo32Sv\nUH0K\r\n=wF4q\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIDT0jctjaaFX7svBej9+tRyvJ3cBkrSJ0YJwfdo3bEPLAiEAy3n61fJPMrpZJ6B3ZIXK8FNS054+EJ9+cn3uwU6zLyI="}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.8.1_1619364417948_0.08529598061285326"},"_hasShrinkwrap":false},"0.8.2":{"name":"@sensejs/kafkajs-standalone","version":"0.8.2","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":">=0.8.0 <0.9.0","lightning-pool":"^3.1.1","long":"^4.0.0","rxjs":"^6.6.7","tslib":"^2.2.0"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.0.8","config":"^3.3.6"},"scripts":{"clean":"rm -rf ./lib"},"_id":"@sensejs/kafkajs-standalone@0.8.2","_nodeVersion":"12.22.1","_npmVersion":"6.14.12","dist":{"integrity":"sha512-0VZ9BywAqYou8Tqge2jo/0bSJhgnjSrwGq8py9VRALolH2fZ3yEhQgkgV/x+gyCoghWeOS4qo+sari3xYPwcng==","shasum":"b1d204cc0838bec312a37ab6397dce8cd0cc33c1","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.8.2.tgz","fileCount":50,"unpackedSize":97433,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgh1h5CRA9TVsSAnZWagAAQzAQAI2Z+WTMrgwbYA7OEZAd\nMbOsOOULkXEe9hJBAcgqkyzIS2TqRBqokShjsmr7M+bDhxROS1ZRPWWohhld\nu6rIC9zsMWCRVoJEu8wGTE/doVDBxUvwXyQeK5DsGH2kI0nSLrH+pgXsL67U\nQ+eEcFb09b2fYDWsmonT0UECdWKarTPLfK5m5jCIbGAXhXzYvJ9cqE75y2j5\nhBopFMi/CIJj0Iz5cRq7ATOlzsXHuTjK7PcuK1FGLInwXFL9H1tgh+X13un1\nNSWUSuBa1OJBoeKTG3+yjMjwr6dvtJkwFZQ6KbS5mQJTwb7f2I10JblyyP17\nju1SWD5kp+KrXvGYmHqxgRh1OCT9Nsqo42t6bQt2oFPe69nmc+pYhy7zp7X1\nZ+cZ+TESfwmOSS9K+tiUbXfogrGNDdpPtJ+i5y7R5teZGeOpj1gISsZCWtIk\nWHC16BaGIG19d+UrnwcAfgoTAkMqtSeW1cs29aNXuHGIYlpG3s2baTTZFzvf\n3i6VqIjDSjCRxHwj9otpnZVU/ROUfp1qmhYSOAkK8rYoUEJqCe+QTiAssjPO\niGOT0nqlea/vAF7E2AE/fp+jH0cN6eMuMJ+m770gPpw68eEe89pUi+qaXTTT\nqMjYYDOJl8BNI8PI9JUI43lqn3eelnmeYenH4AnqEZHHvCVgehO+Q0g4qGHo\n2c+P\r\n=oCt+\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIGXeJ74pz8pomCeYajg2jvjsVREoykE04EFH/irbJ9rQAiEAtTgGe4KDNJvjSOaesLsqY05/lmo4ZyQcJyLZw44oI2s="}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.8.2_1619482744981_0.6577774168390433"},"_hasShrinkwrap":false},"0.8.3":{"name":"@sensejs/kafkajs-standalone","version":"0.8.3","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":">=0.8.0 <0.9.0","lightning-pool":"^3.1.1","long":"^4.0.0","rxjs":"^7.0.0","tslib":"^2.2.0"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.0.8","config":"^3.3.6"},"scripts":{"clean":"rm -rf ./lib"},"_id":"@sensejs/kafkajs-standalone@0.8.3","_nodeVersion":"14.16.1","_npmVersion":"6.14.12","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-6iMZxtzd8k4udUmjvWybF5D7QuvfwuwBhhG5LzhZMhFClaOrggDXq6x96GSF6lBJtk+OLn3Lde/m6k4lIImnBg==","shasum":"fffb112264b589c6f5d254019c2d4209da474258","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.8.3.tgz","fileCount":53,"unpackedSize":101874,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgmBiYCRA9TVsSAnZWagAALAkP/39gi8bnuKApcQIyV69Z\nCHndBvbuZckG0PM11kkMkgF7ChMMeZuJLC51t171nT+rXDuwKvudPVftHcp7\nl60EMRv33qr0egMoGFZs5uc3zaGa7l8a20dVsOl0ZRPmt5s+DpDCEIdAlHfK\nefem6gV8r49qbOR9QM+9ViSXVDI8l+36Uv6tSgCldmRh8EMlsGYPkaw60zDt\n0m3c82/jFo/X3qRlZmQPqDd09FFSZ6adeQcTY0LTClm2ADtc+ukqngsbv7iZ\nqihWcjsZnVUr5LE3ZLjmpbwTr9PDECy1KnUt1fLfq3cM7RHYYnT5oqeLRMpa\nn2DWtZlAr6lYcuHOjR26UWvA/36hdcz/Nodh8KAwMIoOm5/pmX7v8dQw1gG5\n8cPFUBfKQtuCZMCO/NZcVkwdoKaXnLJdWtrTdf7D2sqFiTH/MA3izycqhga8\nMhpaqb277ta180Sx+UiDcw9ihPxjIpftUvB9rdZVBB72S9X7AVkzB3HBmbVp\nqTW0Xh278fT2mue1xWCftOvvm5xRRJSV5uO7LVoaZTnZ1U/cdoJHIhGFMBYJ\nsb/BLMEeLi8gK2LRdpn5wIg4j7Br00rx+bL5MyF2kWQ5HIpAofOpNkNEVaU9\ndbKft/48cZUZtvvyh/99kUzlQkVk8QRwljXQ0En9s0Pl+4O4SHhmx5c1oL/L\nZ/KB\r\n=t/uw\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCnBdQHQHVDglhJZlze4skh46mlXsC2djRx5oZTDvzVaAIgBavUB0UZCpfDUsn1Ez+aIM69WmzCluJIzU7K01XDvhY="}]},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.8.3_1620580503713_0.10752322654931579"},"_hasShrinkwrap":false},"0.9.0-alpha.0":{"name":"@sensejs/kafkajs-standalone","version":"0.9.0-alpha.0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.9.0-alpha.0","lightning-pool":"^3.1.3","long":"^4.0.0","rxjs":"^7.2.0","tslib":"^2.3.0"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.9.0-alpha.0","config":"^3.3.6"},"scripts":{"clean":"rm -rf ./lib"},"readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.9.0-alpha.0","_nodeVersion":"14.17.1","_npmVersion":"6.14.13","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-R5rxG8MWemRVDCYH9c/r09Ik9FHruzKZHRhLpjZDvVSRpnSBVCrARETIsbMzwfyObQss4JEWkQFjuVrCIB7TDQ==","shasum":"46be8b322fda5618f3a832f144a91fa844570d11","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.9.0-alpha.0.tgz","fileCount":53,"unpackedSize":97660,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJg5qnVCRA9TVsSAnZWagAA6J4QAJ65g4N1iu7hNpmmqld8\n1rR6vReUKJPM9mW1oP65pKaS7jsLClOfjJjF1Rm4x2AAg4sm7ak15V2jf2DP\nW6iTn3Xqgpy3IhnHTSZAobflvYq7PTGhHboBWb3yjZ57A2Ta28wW7yleslAY\nd6ld9viIfStwZOlGtuBGJPJ90ayMlc43YsSiKvECPt5mYymML/uaTCJnt0GE\naw7RX8cg8pqbA0Q0WsMMmmNnsaHk3WZgbP6GnzA2yQ7ZPrAee4TBFbSSkYAf\nuk1No+Yavg5oRT+5mCYTnqzdJplP933AF1DFqivb0/ey7GVCtlHuPGhefk1N\n/FgkoDYvT6ok5KBfgQ4DAXegcsqkrI+2cQkd3Y0N/u2SWb1zIvSAC8oBz9wh\n+IFxEkiAb5oeOB97cLBLrcrqxOJ7st/3qqbXcmX4FiGflVp0BFg5tpP12DuZ\nnw/K2cENquaJkby6q4N5HM6t9aqDelzOzwzoYfTeqqRWBzvtoTa/oDoiyciN\nJ63FkeYC7ay9UgYbdEJcui9Uk5iWP72RX5s5sGPoBloguWyYUYQAkWRwrIAz\nxUX/qJsjKgSps9oFtqn3EEWwljWQM/k/HVT7wNWJOIj1/gtlDYCZzBLTq/zS\nAcZ1NBupJr8XI+PfXUVie6lNjHaz1rBKvYGc7fmUnO31GoH/UdXN8qN1blpS\n0zEG\r\n=V2Vr\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIG+VJAsEV31Gf/SyseUVJJ49cEjfG/1339MEySO8MvNMAiARgJfPzVfHDRm8xCUT7ZjziwkxM09JuyqYgUNyvMmzQQ=="}]},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.9.0-alpha.0_1625729493248_0.628948914866365"},"_hasShrinkwrap":false},"0.9.0-alpha.1":{"name":"@sensejs/kafkajs-standalone","version":"0.9.0-alpha.1","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","types":"lib/index.d.ts","main":"lib/index.js","publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.9.0-alpha.0","lightning-pool":"^3.1.3","long":"^4.0.0","rxjs":"^7.2.0","tslib":"^2.3.0"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.9.0-alpha.0","config":"^3.3.6"},"scripts":{"clean":"rm -rf ./lib"},"readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.9.0-alpha.1","_nodeVersion":"12.22.1","_npmVersion":"6.14.12","dist":{"integrity":"sha512-527HyPBSOzXlZrwEkjlIexEXoyME4Gz1kGh26FAp7bd9CSCMuKEhEmxb+EFrB6EyGLNAi6DrIiACGM24qgyNCw==","shasum":"bf60df43787a672d4076752b3870c4375b4cb9c1","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.9.0-alpha.1.tgz","fileCount":47,"unpackedSize":82925,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJg9q8vCRA9TVsSAnZWagAA3N0QAKLEJynsVE2QounJzGDY\nBKD19HpTXo4/klDcIiJYH1nly+43KPHz5OBE3jC6BZTVcPflkOgtVHbK2DaT\nkUmVwT/n0j1qs4I4R2DUAU6AgBBj8c4NG1wjmIcyCuusExAXUJAGem0u/TlU\n18Yjenb/VXfOBmd1TCbcaibgFyCjGASaRm+yN1SZzIUIKczveBFouryw2FVP\npSyf0C1SRYgIdDOSIHFybziM2mSj1AjekEKEPufpgwI4Ebe7/D5d1cVJwIOp\nJZuWMk6/+H9yW0UChL03ifiRjcTrZaw3GpAA74OOOXPlAW0eF7x4140cIBsg\njDX/yKTaHvgP3ylfh1KbOrY9LVQeS2Qvc5TsQynlpk7ilQxgsGQHzlugeMl2\ngHpAI2g/K6AsGzJFwu0lnrJh3VXzjk7UumdS+lvO7pfXSxI+DiDsYV+AxS9G\n//GllLgXPUUy2F/uDwLB0wRHHz4lh8wIXTNzOs7rAJ5rZwdL77KjRKF2mzsA\nK4aFOtXUbCZLSdnrpSJZyHSOuoyiLJuybhSma44LbbnbkQ7PcjCLAr0paKOI\nqQDs7suzsLyB2kjSUdzUapvE05MdHlf9soRcADVZJY4vb00uhFbQK/OVjo36\nSpvrzIRKLTPEwCttzsBvNkUNC2s8XhUfH/0tl+hz10hqnXPgqP2kGkmKL9/v\nvVLA\r\n=QtQY\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD4+Q14wadpCsf7zHI9lY/bkj3UkTd+43JAQDcCuJ4ecQIgHf/uttDH/KJlbHgSJDQbhFrs154uv/0gm1Bd77vunBs="}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.9.0-alpha.1_1626779439354_0.6180728411898551"},"_hasShrinkwrap":false},"0.9.0-alpha.2":{"name":"@sensejs/kafkajs-standalone","version":"0.9.0-alpha.2","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","type":"module","types":"./dist-esm/lib/index.js","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.9.0-alpha.1","lightning-pool":"^3.1.3","long":"^4.0.0","rxjs":"^7.3.0","tslib":"^2.3.1"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.9.0-alpha.0","config":"^3.3.6"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json","clean":"rm -rf ./lib"},"_resolved":"","_integrity":"","_from":"file:sensejs-kafkajs-standalone-0.9.0-alpha.2.tgz","readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.9.0-alpha.2","_nodeVersion":"14.17.6","_npmVersion":"6.14.15","dist":{"integrity":"sha512-AUBaoSKsWjJRLpC+05ibwQpPOAvWfZtS+l5QRinF/yXs6sQkQ8rvzlzGWNKBjrN7/v9nKysn9StukC1D0DyOWw==","shasum":"5a4ebca213f4bb15dbe4f32fdadd230c19706e17","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.9.0-alpha.2.tgz","fileCount":60,"unpackedSize":149695,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQD25vBNqDz9k8P9pTh960b8HhrlzAZ3m4COcZKPl4u44AIhAPk8YwjYY6hF6udW9PIYeVoYkmfF6CLAdeXzSt3LTzAX"}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.9.0-alpha.2_1632370453613_0.4148801058405296"},"_hasShrinkwrap":false},"0.9.0-alpha.3":{"name":"@sensejs/kafkajs-standalone","version":"0.9.0-alpha.3","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","type":"module","types":"./dist-esm/lib/index.js","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.9.0-alpha.1","lightning-pool":"^3.1.3","long":"^4.0.0","rxjs":"^7.3.0","tslib":"^2.3.1"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.9.0-alpha.0","config":"^3.3.6"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json","clean":"rm -rf ./lib"},"_resolved":"","_integrity":"","_from":"file:sensejs-kafkajs-standalone-0.9.0-alpha.3.tgz","readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.9.0-alpha.3","_nodeVersion":"14.17.6","_npmVersion":"6.14.15","dist":{"integrity":"sha512-sNszuXxHr1P4Mc6x1LOClFzIg2GX3zLEWtmXYSPF5XjlTiUTRJ4ZKmoTJSTB7gEicY6pkaZcRBQBXWTX3EraiA==","shasum":"c769d89ce64ca549f7c47166907b4cd6d310b52d","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.9.0-alpha.3.tgz","fileCount":106,"unpackedSize":270049,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQC0aeGo/LHCIUsZUvJ13kBcZWmqn5ZeIrunfSlJnL1Q8AIhAJCjKcOINbQyCIXf05SQWSHNpeT70EI4JRuiob3uwAKd"}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.9.0-alpha.3_1632370702892_0.4208987455156228"},"_hasShrinkwrap":false},"0.9.0-alpha.4":{"name":"@sensejs/kafkajs-standalone","version":"0.9.0-alpha.4","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","type":"module","types":"./dist-esm/lib/index.js","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.9.0-alpha.1","lightning-pool":"^3.1.3","long":"^4.0.0","rxjs":"^7.3.0","tslib":"^2.3.1"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.9.0-alpha.0","config":"^3.3.6"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json","clean":"rm -rf ./dist-esm/lib dist-cjs/lib"},"_resolved":"","_integrity":"","_from":"file:sensejs-kafkajs-standalone-0.9.0-alpha.4.tgz","readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.9.0-alpha.4","_nodeVersion":"14.17.6","_npmVersion":"6.14.15","dist":{"integrity":"sha512-WYyIJ2hZf6nyCwXME8fmYFxXkgIy+BAz0m8t1E3PojkDWVA47ZBQk1TUXujzh0FCIofLUwBfVz++iV5Bv5U4tw==","shasum":"825a04ac1e9afc1e6678f6a9e7c448a571152459","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.9.0-alpha.4.tgz","fileCount":106,"unpackedSize":267069,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDLhLSFOeV6Jb9B14Lt2UfILb3n0NEDKVAKDaeoRz/IHwIgRUoADLW2rK+vwj9+T653nLcRkGkW2TeGghKFwjcR68Q="}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.9.0-alpha.4_1632705320957_0.8066590514325944"},"_hasShrinkwrap":false},"0.9.0-alpha.5":{"name":"@sensejs/kafkajs-standalone","version":"0.9.0-alpha.5","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","type":"module","types":"./dist-esm/lib/index.d.ts","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.9.0-alpha.1","lightning-pool":"^3.1.3","long":"^4.0.0","rxjs":"^7.3.0","tslib":"^2.3.1"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.9.0-alpha.0","config":"^3.3.6"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json","clean":"rm -rf ./dist-esm/lib dist-cjs/lib"},"_resolved":"","_integrity":"","_from":"file:sensejs-kafkajs-standalone-0.9.0-alpha.5.tgz","readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.9.0-alpha.5","_nodeVersion":"14.17.6","_npmVersion":"6.14.15","dist":{"integrity":"sha512-ny8Kzu0uKSBmWb3Ga/kMkfCilvrppAzR+XWFJcHqPEOgoi/LGDYOQ+uB7GCApT4Q9lOycs6y3KpDbVp7x7PuPA==","shasum":"fd7c007b38105a306dabe859bb00b50449645d1a","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.9.0-alpha.5.tgz","fileCount":106,"unpackedSize":267071,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCJzLOSPwRhFt6ed+EhQNVtWcFVbVfxGE7Y6Jv/zUZ29QIhALQIwIR5Aarq0itmHpJZ5j/yDIj0aoY5Z4KVlVSTUrUz"}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.9.0-alpha.5_1635428916831_0.8819062730007714"},"_hasShrinkwrap":false},"0.9.0-alpha.6":{"name":"@sensejs/kafkajs-standalone","version":"0.9.0-alpha.6","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","type":"module","types":"./dist-esm/lib/index.d.ts","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.9.0-alpha.1","lightning-pool":"^3.1.3","long":"^4.0.0","rxjs":"^7.3.0","tslib":"^2.3.1"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.9.0-alpha.0","config":"^3.3.6"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json","clean":"rm -rf ./dist-esm/lib dist-cjs/lib"},"_resolved":"","_integrity":"","_from":"file:sensejs-kafkajs-standalone-0.9.0-alpha.6.tgz","readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.9.0-alpha.6","_nodeVersion":"14.17.6","_npmVersion":"6.14.15","dist":{"integrity":"sha512-+cXhV9A4cHto8UZEW3HOQNwlUlvc2NNP1mbLVy9xBR6nbeLA0EYP+qElyMwmCI2ACbrXbqQM1EAApaRpPzUMgA==","shasum":"8cc2302faad1d51510eb575be987dffbdaa8ac1e","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.9.0-alpha.6.tgz","fileCount":106,"unpackedSize":267071,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIE8WouJekyqoP/QPVxu0GJrzd5xKPcsJw/bct7T5aFamAiA8nqpQ8znq1T1Co7gWUPvMLJnkvFiZjcroQshys80kQg=="}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.9.0-alpha.6_1635699271942_0.27978742185599925"},"_hasShrinkwrap":false},"0.9.0":{"name":"@sensejs/kafkajs-standalone","version":"0.9.0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","type":"module","types":"./dist-esm/lib/index.d.ts","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.9.0-alpha.6","lightning-pool":"^3.1.3","long":"^4.0.0","rxjs":"^7.4.0","tslib":"^2.3.1"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.9.0-alpha.0","config":"^3.3.6"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json","clean":"rm -rf ./dist-esm/lib dist-cjs/lib"},"_resolved":"","_integrity":"","_from":"file:sensejs-kafkajs-standalone-0.9.0.tgz","_id":"@sensejs/kafkajs-standalone@0.9.0","_nodeVersion":"14.18.1","_npmVersion":"6.14.15","dist":{"integrity":"sha512-XqVgHk7Dho4+V+lEU6euCpMyU01pTqEKBHBUqzks5M1IgHFgTYoZcLZkHcyz9WL7+nC830Y7RbsC8pNmuz3ZPQ==","shasum":"e4a7a63e98443033df01c17de2435613e8e2bc9b","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.9.0.tgz","fileCount":106,"unpackedSize":267063,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDcFf36sOk1HaQL+hiFIkAuXzZLQMr6Ubaqor6mnAtIyQIgTBehLxR3QZHYfxegOQWpOvKNZr87Y7sIN4G6W4UIrxw="}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.9.0_1636363557971_0.6939219435659041"},"_hasShrinkwrap":false},"0.9.1":{"name":"@sensejs/kafkajs-standalone","version":"0.9.1","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","type":"module","types":"./dist-esm/lib/index.d.ts","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.9.0","lightning-pool":"^3.1.3","long":"^4.0.0","rxjs":"^7.4.0","tslib":"^2.3.1"},"peerDependencies":{"kafkajs":"^1.14.0"},"devDependencies":{"@sensejs/testing-utility":"0.9.0-alpha.0","config":"^3.3.6"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json","clean":"rm -rf ./dist-esm/lib dist-cjs/lib"},"_resolved":"","_integrity":"","_from":"file:sensejs-kafkajs-standalone-0.9.1.tgz","_id":"@sensejs/kafkajs-standalone@0.9.1","_nodeVersion":"14.18.1","_npmVersion":"6.14.15","dist":{"integrity":"sha512-98LSfEqrXui5UKk3nbYYahO37nEB4ueEY9t7KE54AAITC+utAzUe3iQhHjHXkj0TGcopALrCgigx3GlLaHAdmw==","shasum":"b83bc54777184b7cd4af7228bbbfe2e9c29784c9","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.9.1.tgz","fileCount":106,"unpackedSize":267055,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJh2aJhCRA9TVsSAnZWagAAGdcP/A7XI6LwZi6huAUdrhDm\ne0SgtVY3Ay5l/OFptHaJE57hxWURpuF/lnjbnnRxkBqFyyX5SLbCdEYLJw01\nvYx6m6AZrX1Kzz1H+Osk+mLVAqSnMv8oykVUVpnR64aRVS/EVk84rPk7QdGY\na9gHylizm+dwcrwwAiFKTT583gkYpTjnfpEurSjbpAKr6rTt7m7Y7pVf2C7M\n9H+7nVfWih8sqxa0OvwRC0YlJmlVrVEJEyemUyfCsew/o1qYqMmAkXEt0YMo\nWqoQHcGOMJx3qmE7mGYZDWjw0tfnFbCbgGz2MgIPNvjm6VUhVjvt4DNAaHa0\nsqMEAXt3j1Zy9nU2wtwYoEuTTSi2QG6r20bavca/JymCm7n/9g5ms7EkFMrp\n9GeiQNUDBIUacPFCpcs7JdWYWJfjzQ7g7YSxFmrzBVReqUUNDMqa+wCgrHdz\nLwSSiiwlPD6L2kwFkMh3qP4sgMvexio/WFjaKzNyVsmBWST64rSo+kRHeSXf\n3Z76SAc2w7TSQ/LXUcWSwHSomf2WICS1RuwCOMIk9KUD/Hig3i4YZSN5g2v6\nLAWfCHSjdyF21qRNb9y3yk6bufg7nF5E3215WEKqo3y/ZZhLHT4ADC1zj70q\n0Pcvz2wfB1kpS7O4vmT5+gyefQXU3Wnhi7QiMCTFyI35SxZCrbzCVPB7QAJ6\nK+Cw\r\n=fbfQ\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDA+ExqjkhpYXS0m/SjuPZTGwbTv0owikkEhOtPkJmbPAIhALpQ1xbBRxRjw5reAm/V8OceZD1coc+tmfIGlrmxWo99"}]},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.9.1_1636364450332_0.8125719241353633"},"_hasShrinkwrap":false},"0.9.2":{"name":"@sensejs/kafkajs-standalone","version":"0.9.2","description":"","type":"module","types":"./dist-esm/lib/index.d.ts","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":"LAN Xingcan","license":"ISC","dependencies":{"@sensejs/utility":"^0.9.0","lightning-pool":"^3.1.3","long":"^4.0.0","rxjs":"^7.4.0","tslib":"^2.3.1"},"peerDependencies":{"kafkajs":"^1.16.0 || ^2.0.2"},"devDependencies":{"@sensejs/testing-utility":"0.9.0-alpha.0","config":"^3.3.6"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json","clean":"rm -rf ./dist-esm/lib dist-cjs/lib"},"_id":"@sensejs/kafkajs-standalone@0.9.2","_integrity":"sha512-tMYtBLn2KjHP6X3EspDVfKq+e/9YO+PdZVjLp4oSPp0mGgifPGKjfoxAbzpThm/JEiXay2ngBpDg1qu+VMmj6w==","_resolved":"/private/var/folders/vm/gz75zcmj2tvcgj7crtrv80rr0000gp/T/318c96bf6a61850a35a235bd3bbc2ffe/sensejs-kafkajs-standalone-0.9.2.tgz","_from":"file:sensejs-kafkajs-standalone-0.9.2.tgz","_nodeVersion":"16.14.2","_npmVersion":"8.5.0","dist":{"integrity":"sha512-tMYtBLn2KjHP6X3EspDVfKq+e/9YO+PdZVjLp4oSPp0mGgifPGKjfoxAbzpThm/JEiXay2ngBpDg1qu+VMmj6w==","shasum":"6961f816eb29550e17bcc0dd804299e9b4be209d","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.9.2.tgz","fileCount":106,"unpackedSize":270299,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIGGWXievqR1ZtStlGphM+Y0l9speOnVDDmnlcLWj6dpFAiEAxsqUL27dqfyTR4km5e9PRIHMRWOdoIbWvenL03x3fls="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJinw4JACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2VmpxMg/+IzZcI9OReWnhuMWao61ANxQatKlUYpXP+srI1RgUCuRK8xP+\r\nBQm4Rk0dvPgtvjNUY0y/8EP3+5VzYDN94loGTWNw/ZOd8VvFSbEIZoGLH3uo\r\n+7Jkh3MnaJhCo1NYsOGT0hoUVwuYY5cxTZo4qDYimMPKm+HcqVuWhZnFaLTe\r\n+r2UZPmTljQ6K26nw01l/FMTBjwO4+neHDVZ/GMGHhgZ1e1w66yTMMP5sD8+\r\nfkU2cqLzAn0Q7JIvjI9v+RakxbP0gGoUd13QHJb0NunqWKG8gZMC1ejYMe8R\r\n0UiMOepxJNufnfDVkPQCVHBWnxwW0tqV1d/ZJ2+Ik7pN6a4b+B7hbzn8cM3f\r\ntxnLBihUwIusshsOM2SiRmM4uDNF57Ls+0gvqNWSjihKlJQlY5rLhLMQCavZ\r\n7M8XyyEFT/6u9yh0aYl8PZIDRIQGA4gLKGUSONgI4t2B4kbH5K9vin716WpB\r\ntvgBn2PArvG7OhNVF5H0HGIy14VvO4oynB8if4tPMVLJEEGxXfzRjzuGgqTe\r\nWwpylPSyWrurO2Y2oCbHX/xKxznPLV86uRsdLRXyUeGTxh47oBRtEzmJFvMQ\r\nypzzB534wU9gA9Vit3VcGKt8WzevHqbeZXFud3X2SIRd7NQ4+rc462mZym3W\r\nCrG1VjefRhiXWaZnNJt3019dz/VpFKNYOsI=\r\n=2xLc\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.9.2_1654590985358_0.6101451030441405"},"_hasShrinkwrap":false},"0.9.3":{"name":"@sensejs/kafkajs-standalone","version":"0.9.3","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","type":"module","types":"./dist-esm/lib/index.d.ts","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.9.0","lightning-pool":"^3.1.3","long":"^4.0.0","rxjs":"^7.4.0","tslib":"^2.3.1"},"peerDependencies":{"kafkajs":"^1.16.0 || ^2.0.2"},"devDependencies":{"@sensejs/testing-utility":"0.9.0-alpha.0","config":"^3.3.6"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json","clean":"rm -rf ./dist-esm/lib dist-cjs/lib"},"_id":"@sensejs/kafkajs-standalone@0.9.3","_integrity":"sha512-XYS1jITjxU3KqOvQnBUEhaCoEUw4FKlEdvcmTF9xqW+yKBG8/fCBdZy6eaI8cThBk91j9Ix+TeS2WqxH8bE8RA==","_resolved":"/private/var/folders/vm/gz75zcmj2tvcgj7crtrv80rr0000gp/T/c2c3841861c96769294dcc65514f7f29/sensejs-kafkajs-standalone-0.9.3.tgz","_from":"file:sensejs-kafkajs-standalone-0.9.3.tgz","_nodeVersion":"16.15.1","_npmVersion":"8.11.0","dist":{"integrity":"sha512-XYS1jITjxU3KqOvQnBUEhaCoEUw4FKlEdvcmTF9xqW+yKBG8/fCBdZy6eaI8cThBk91j9Ix+TeS2WqxH8bE8RA==","shasum":"3cb8734472f956420ef21b5226d9814177770d65","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.9.3.tgz","fileCount":106,"unpackedSize":270692,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIAFsrRrr05v5L8O0OS/LH7FSRhxvCevheaFrzUoBUe1DAiABNXHJcMj8DyrX0BYXsYi6yTQy2tFA+iMQgM+3vH7K5w=="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJisXY9ACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2Vmox7w/9GxvRrMI1yzZ2LfZZZm48LL4SjAtgWUCnA9vCpxJ3uZyTwAG6\r\noGLhppUlHu1ckFenk8hvfb/kh2iS0+Qu6+T0AwWZpxpnov5nxzZ5hj6Mn+ED\r\nHeJi0TK2mJmz9fstFdsAiAO3cU2DRQp/9zvxK3ckhiMTBShGzXO9e0LLD4Hq\r\nxap/AtkwQKiSA03DJX/iHvBz8vIvFizFrXd79mUl2DAtMCWeKqhVMbRQJkMw\r\nQEm7LZY5F7djKWGVQgJEsVsM+LgO4EykgNINRiPMQVv9kuNWQv9AIQhhTsNi\r\ns93vcDfSlF+Z85oezPzm1/VXFbAMRpLkiLNFDzsAQqp28w9bk5CanDLSB616\r\n0UMyD9l3MHiZEvTtkuQ6sy9jBf7LCpMPITtnegrCQXeJ8lu2Pgbi5Wkr4rsI\r\ngSUDv16DpTfEgwVbSgf+s9t2aoILJUr6ZMv4/8luXdblXTa4yDQHoxTWaLua\r\nNCK0FFK4jYW5ODR9xqUcnwRTATuHILxiGmxxo3oxS6Vqb1jRggvLxIJtyEMv\r\nu1w2PCNWy3YzPHFUl70mY9qab27BSQqfpBgHfww2IoXnf314Ibv+aXnsKJD7\r\nsPz71GCNzg1zsGjVWm5UD874VllwFwYHKVxQJlm3qVVituanTqRBDSOxpP2k\r\nXH/wwZesFOV72NPL+tHhI8HID+A4yBAy9PQ=\r\n=swSS\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.9.3_1655797309197_0.5678166712555202"},"_hasShrinkwrap":false},"0.10.0-alpha.0":{"name":"@sensejs/kafkajs-standalone","version":"0.10.0-alpha.0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","type":"module","types":"./dist-esm/lib/index.d.ts","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.10.0-alpha.0","lightning-pool":"^4.2.0","long":"^4.0.0","rxjs":"^7.5.7","tslib":"^2.4.1"},"peerDependencies":{"kafkajs":"^2.0.2"},"devDependencies":{"@sensejs/testing-utility":"^0.10.0-alpha.0","config":"^3.3.8"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json","clean":"rm -rf ./dist-esm/lib dist-cjs/lib"},"readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.10.0-alpha.0","_integrity":"sha512-0C7MgYi0PKoYXmJVacBv1KJDXqpX01vB5ZiMUhcrCGoTGv7mGeBzOMsAV3kH3TcrNA41b67o/BSfCp3RQ9VLQw==","_resolved":"/private/var/folders/vm/gz75zcmj2tvcgj7crtrv80rr0000gp/T/c279bb1bf6cd8c94918bb7963ca7bfae/sensejs-kafkajs-standalone-0.10.0-alpha.0.tgz","_from":"file:sensejs-kafkajs-standalone-0.10.0-alpha.0.tgz","_nodeVersion":"16.15.1","_npmVersion":"8.11.0","dist":{"integrity":"sha512-0C7MgYi0PKoYXmJVacBv1KJDXqpX01vB5ZiMUhcrCGoTGv7mGeBzOMsAV3kH3TcrNA41b67o/BSfCp3RQ9VLQw==","shasum":"ccc7a0a849fe33ca98ea248f1a3160c51e455664","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.10.0-alpha.0.tgz","fileCount":106,"unpackedSize":271223,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDvhpDUF/oyyLkgQrhcpzyW2buzKCVBf4cUx9dPr+PXHAIgVnLj1RxcWS5GfFXpd+wD93Py2AX3QJcPgNI8l2q2z/Y="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJjdyR5ACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2VmrUvA/9Hu4mRjHnZaMM1tthQk5EIT5pKe/nrXzG9pj9/xqDpmXKp3ae\r\no6CPqBsmhtoyvOZnSm7wamwYM2/d06210d80FoNHGNmNbVksy5iHEh4cDrwC\r\nkJshgYfWrALCxJW2BbEKsjWizwJsLhc50cFe1AqPmu3uLJj4LPi/fNv3A3On\r\n6/Xe4BT9A5tXJXRh/sL78oOXi7zmFeRVAEkZTOL8IqoUW+mGBhc2BYpzcZOA\r\n/Ue5yBsytU6sEWp9dyqjyLawpSr+UAYcCu4yFNdQbGfOli9TEVvAOyS7+ruX\r\nF6ZODPU+jIlcimsXfuw1+xCBkVrDAOmKnJ93dcSVOezzxq+Oaj9ROdm1Md92\r\n0Nq3dK9jc1iSjfnGSDWY+Yi9t5Jhye3E1516+o/RDR4l06Pr98Xnx1xkf/EW\r\n85K05kV6JzMd7wL84slrtIP6C7NHaWhcrbLd5i1NIUzLeXw8sQiaTDena6lu\r\nDH/vAG6ZK3+GF3ctmai6y/mIVHhZLE8zloYCKmlSuSqG3bmN3y/+HSHrYtWT\r\ntQ2BDVcQMuZWC8cnWsOuFFPTFe4w7onyXkB6sR5o2ZvGgkiC3rkDdXGqvkPB\r\nTmoGRDpwsSBnzuNoiij8Q8i64N21FDHy1kUmAI9csCoXnU7FdC3jeHyL3aUc\r\nJ35N5HM0plO2Tt5NRVE9fcUfVIqkxNUGFQ0=\r\n=vB/D\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.10.0-alpha.0_1668752504791_0.3997544600095746"},"_hasShrinkwrap":false},"0.10.0":{"name":"@sensejs/kafkajs-standalone","version":"0.10.0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","type":"module","types":"./dist-esm/lib/index.d.ts","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.10.0","lightning-pool":"^4.2.1","long":"^4.0.0","rxjs":"^7.8.0","tslib":"^2.5.0"},"peerDependencies":{"kafkajs":"^2.0.2"},"devDependencies":{"config":"^3.3.9","@sensejs/testing-utility":"0.10.0-alpha.0"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json","clean":"rm -rf ./dist-esm/lib dist-cjs/lib"},"_id":"@sensejs/kafkajs-standalone@0.10.0","_integrity":"sha512-cHjtEui+0NXR0H10IcoHSoLpJNKMLVvNRKMn5IJeFzgwVQmyuWl8MjewyCW3C2vzLEDpnB59hLrAb4ItlAGdWg==","_resolved":"/private/var/folders/7w/2kt_k8wd08z17584vncn7zsh0000gn/T/0f82103b6b0776ecc9bf836b25f4c835/sensejs-kafkajs-standalone-0.10.0.tgz","_from":"file:sensejs-kafkajs-standalone-0.10.0.tgz","_nodeVersion":"18.15.0","_npmVersion":"9.5.0","dist":{"integrity":"sha512-cHjtEui+0NXR0H10IcoHSoLpJNKMLVvNRKMn5IJeFzgwVQmyuWl8MjewyCW3C2vzLEDpnB59hLrAb4ItlAGdWg==","shasum":"9fe2e1027418e3b874ce40985432f5c48f888309","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.10.0.tgz","fileCount":107,"unpackedSize":287701,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD2Xd/mA7voiyi2RmV+S8Q/2Ue4O70DWZ6czowfDUOxgQIgXq1c1VZixrMyL0+tpINkkYo4dJgwfsWUIgcDMLKMkio="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJkFrJNACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2VmpPnw//aCOf93lkVLm+P/4LBYFLpBQm5eIf4Ngy6bkBXxsC5RY0/RMw\r\nOfUHQ8ycmDFFKP9zTx248vxaGnV3X8LGqybmev5k9N2eRb1z/c2Zko1Gf62s\r\nVclWJffkFcpvQ3m35jovfiLWjWG7QdopPmEOxbxyYwdbRrD8KXg9DIoHWuUt\r\nCXcjYRKq/WkDJ0p0x5nDbzxNSWwPOlP6JlHSTRT3TGTDc04etkJetRJJmXve\r\ntGWS7peMvkEMkVGzLPKL6pkbtqzhYTAuKZ5XXlto0WKFPMDB01zNu9+fLDBp\r\n9eJlE/sXXoDjSYgK1viKOU7wsa3BDxqNjKwUmJTPCekhSJb/7YTSfXblFsDl\r\n/79S8B7zQ2G+MGsGZDUTVcTDLu3G9v/68UnXUn1mx4l6xbbijHbsBia0XBmE\r\nHsbjqYMAtTqNndBoon8/1O7TfOUzJpWKIV2jBfzXFzP1y9+WSzg7atZb27tW\r\ngJ3m2jk8tz9wJw0FjOI7Zh8ooSWOXw8jL5lifLx92uBGYvZ+7A7ey04VJXgP\r\nwexg389eikkSp6LZNdCr1Eb8sdBtKsiMa1964mvLPN/LuFjWrTHNG2DyXLkd\r\nKHusFWpR67DA31CaWSJn9xrfpjmUR2Rvb/vpA10Ahp3F1HxzRgwrj+D13Cgi\r\ncNegrQpfBxdD/iuDD/t4DsVS4u0Kj6Xs1+Q=\r\n=tYl3\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.10.0_1679209037473_0.3282580279798617"},"_hasShrinkwrap":false},"0.10.1":{"name":"@sensejs/kafkajs-standalone","version":"0.10.1","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","type":"module","types":"./dist-esm/lib/index.d.ts","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.10.0","lightning-pool":"^4.2.1","long":"^4.0.0","rxjs":"^7.8.0","tslib":"^2.5.0"},"peerDependencies":{"kafkajs":"^2.0.2"},"devDependencies":{"config":"^3.3.9","@sensejs/testing-utility":"0.10.0-alpha.0"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json","clean":"rm -rf ./dist-esm/lib dist-cjs/lib"},"_id":"@sensejs/kafkajs-standalone@0.10.1","_integrity":"sha512-0OtJMuVlb+FU7gAJOUosI7gBCf/2InAO7AszOiUpyNGZ5cn4RvXb4LzK2PJiD/HRxYxJhlusWVqf+4mDmC8ctQ==","_resolved":"/private/var/folders/7w/2kt_k8wd08z17584vncn7zsh0000gn/T/dcdbc1294cb91b121c038b5b58690222/sensejs-kafkajs-standalone-0.10.1.tgz","_from":"file:sensejs-kafkajs-standalone-0.10.1.tgz","_nodeVersion":"18.15.0","_npmVersion":"9.5.0","dist":{"integrity":"sha512-0OtJMuVlb+FU7gAJOUosI7gBCf/2InAO7AszOiUpyNGZ5cn4RvXb4LzK2PJiD/HRxYxJhlusWVqf+4mDmC8ctQ==","shasum":"e542c7009e679ae27ab398c5de36826973fe5b95","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.10.1.tgz","fileCount":107,"unpackedSize":287700,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQC1wDYR1kn5pSvGqYMQoVXUerPkGiHy0L3f3zMv13iyAgIhAL9Pt2lhGn8O0E9AJWtUCoAH9d98mPoIo0cWHLqUobTl"}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJkLHFXACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2Vmq0TA//d/vCnjIfGzh2Nicpnsjk0ATBN0mhSODa8pDGkYAkelNAcJfi\r\nJQAH9XPsCODRWlkRfFbu5CVe1gTHSWMnTS701XJqjeT3sBEOnWDYJCIeUjdI\r\nk4FM+MDUsD2zSJEr66RqlMEXfnWj7BnV4bJ2hOjiZhG7ejpA1/1mikEIVmPN\r\nTmXmVRVGMcN7ZOnngWJoRs/FDqy0PWrq/WfpC2uOny5ZEXP4r+2pTF8LiA+h\r\n+8aUAeVl6QHnBnmymWBnDwoOZ7p4yZmfdAGj+QtUJvdL7nxO3JSpqrFa7AUh\r\n62ZzIifywaAK22fbtZeaLWs0932rh62YsxeI+0F3JRM6B25KY8GezHfst5f/\r\nx7REn+HxsGalLTomG/XMBGXSLqht/a98moJMIUauqpwOtcydX1hvM5xzXw57\r\nrfLPWKJtMLpDoFRopl8iheuAg6o8LmIdYpVdVTXBg74nwTdYEGAS9CpVw6cq\r\nYUcYzfkpJLnznVgJ/TqSCvUoqwBKMXSuGj6OMEtc/ZXcH5FRtMb9j9N1nH78\r\nfhIBdnjAvvUPjPRZA7EySyFoQV5osmVr9+zDMMCZq6ovQnVCXRMj9OTutyKj\r\nDmY4+7Idn0xL4x/sRRIvhf4Pmsx8/3yuLz7TzLvfop1jGTs/NCzpKTJhuMAZ\r\nlnyiZi+vRXKNGtVlH4LdU8+DeiXdXeuIM4U=\r\n=h6L6\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.10.1_1680634198988_0.8031526760048742"},"_hasShrinkwrap":false},"0.11.0-alpha.0":{"name":"@sensejs/kafkajs-standalone","version":"0.11.0-alpha.0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","type":"module","types":"./dist-dts/lib/index.d.ts","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"types":"./dist-dts/index.d.ts","import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.11.0-alpha.0","lightning-pool":"^4.2.1","long":"^4.0.0","rxjs":"^7.8.0","tslib":"^2.5.0"},"peerDependencies":{"kafkajs":"^2.0.2"},"devDependencies":{"config":"^3.3.9","@sensejs/testing-utility":"0.10.1-alpha.0"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json && tsc -p tsconfig.build-dts.json","clean":"rm -rf ./dist-esm/lib dist-cjs/lib dist-dts"},"readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","_id":"@sensejs/kafkajs-standalone@0.11.0-alpha.0","_integrity":"sha512-6mfa6gmcvnQVCT7Wpgktz21DoEMhu1l7azr4EJUAkD/0elyKIfOrUAugsnW7DPZvoPvDk+oEIdJfFtU8+tcoKw==","_resolved":"/private/var/folders/7w/2kt_k8wd08z17584vncn7zsh0000gn/T/b76c42fc19940768bab31b773008fb2b/sensejs-kafkajs-standalone-0.11.0-alpha.0.tgz","_from":"file:sensejs-kafkajs-standalone-0.11.0-alpha.0.tgz","_nodeVersion":"18.15.0","_npmVersion":"9.5.0","dist":{"integrity":"sha512-6mfa6gmcvnQVCT7Wpgktz21DoEMhu1l7azr4EJUAkD/0elyKIfOrUAugsnW7DPZvoPvDk+oEIdJfFtU8+tcoKw==","shasum":"3c86fd92a7bbc358f39a265e1c381c7413520703","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.11.0-alpha.0.tgz","fileCount":85,"unpackedSize":267061,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCICthorjgNcayN9SrFagq0r2bvgq+bGdGwYSZwY5ATt9+AiEAp8qKg5pPqazhsZ9j/vBNMpl8JapcnPxvvlkeuPPBXXg="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJkMa+FACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2VmrS0g/+ONNIL/UFS5k9HcJ6XZsgLIsX5iUrOT7mAH3tXTdYMEoLYtR+\r\n2xT7wGDWi/ZYcWv83YBbhKWZCZ49h+QnLiDVl/g8dFB3PZz4bMSt86KVr77e\r\nl5KVCl/kXkbR1ZKt33cKteP8JU9R8IgcZ/TnAOVHTuw16ZF63/IRrgalNAYE\r\nJnxM3vVabZmsKnfjbX7ngPtLv+hw76JltBq0U3S8yU1iK+c8zuifgi2WZOVf\r\nzWu9QY3mL+gBFEGEtrmuQfqB4tLdabKZoXnQsZ19GIaEVlpobII4jvXXPBNa\r\nU7pM5B/JQGbSB0XsQP34Rhjygjw4UCc6ALsZYLD3ld1p3Vv//WnLbw7mNvWz\r\nnEhMnnE8ChUWK66bUR31dL10PTFsOOh8zW5aHGsu0L+qqQwnE0Ws8kW22HXs\r\n4pzZscU5hlFG5BUFUwH01M+oqvIZ0xHbIHVOv9McDdgm66h8BWRc/g1rP9/J\r\n0RVFUVRmW23OR7m7ptYHVnrxVcYmH6KX046xaqZfquvO/RibIE9xBCHYOeV3\r\nrN95g0G64tAMMl6WkRDxEYiusfXfE2GtOlTRcQWx8jpJ+gRCtWdfrQGKJnkv\r\nndrzNQlAAe8d3O0cJfMDfWhxpD9W9oDzqf15fOIvaz/7iSpNwosQ20CwHSE0\r\n4K0+FUvYAIUsy4/BYRtzxoiUpwdNZs2TjCg=\r\n=iizf\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.11.0-alpha.0_1680977797182_0.9547702766394488"},"_hasShrinkwrap":false},"0.11.0-alpha.1":{"name":"@sensejs/kafkajs-standalone","version":"0.11.0-alpha.1","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","type":"module","types":"./dist-dts/lib/index.d.ts","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"types":"./dist-dts/index.d.ts","import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.11.0-alpha.1","lightning-pool":"^4.2.1","long":"^4.0.0","rxjs":"^7.8.0","tslib":"^2.5.0"},"peerDependencies":{"kafkajs":"^2.0.2"},"devDependencies":{"config":"^3.3.9","@sensejs/testing-utility":"0.10.1-alpha.1"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json && tsc -p tsconfig.build-dts.json","clean":"rm -rf ./dist-esm/lib dist-cjs/lib dist-dts"},"_id":"@sensejs/kafkajs-standalone@0.11.0-alpha.1","_integrity":"sha512-FPeQiayY76ifon4AmjoRHL1teRFpMBzUblBECHmDsWfdyD3pXKov+Lta2Rx5VNnmQayYTqXk2QzVkrF9mC5zMQ==","_resolved":"/private/var/folders/7w/2kt_k8wd08z17584vncn7zsh0000gn/T/e4ec487b009c52d7fc3fce8498584150/sensejs-kafkajs-standalone-0.11.0-alpha.1.tgz","_from":"file:sensejs-kafkajs-standalone-0.11.0-alpha.1.tgz","_nodeVersion":"18.15.0","_npmVersion":"9.5.0","dist":{"integrity":"sha512-FPeQiayY76ifon4AmjoRHL1teRFpMBzUblBECHmDsWfdyD3pXKov+Lta2Rx5VNnmQayYTqXk2QzVkrF9mC5zMQ==","shasum":"041db05d9a3f8bd59567bf929b57cb66f5d6b5ea","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.11.0-alpha.1.tgz","fileCount":86,"unpackedSize":268292,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIEVO4XOmfFmJ3CPNIFjreSY40Ol/dHTm2NUYUq5slp8YAiEA6OT17mtdEFL0cUPZN9xfdHUuyp8KXi+WnEzdRW1rzVE="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJkNDuDACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2VmrxLQ/9HSvgVkKyB/ZYBgJVjBfX2STfSH/aK7Vj7fvVPLNYAuJVy8qM\r\nwnAHY4i437+SyLjKLADrlVHlESlYPOPT9RNnvzAd732RaeRoxozk9zOwYflj\r\n6qYiyBP3J5PSbbZlRWUSqYkfXM+EQvULtcge7ddCF2rtH6M6Z/XHnrhd0LHH\r\nPdVslVYSXzwzVxA/ISPHVPImMmey9k4GuFJaxE+nCjZSP9Fh3KPJlg9disUl\r\nJzP/yLnQ+d9ZQxRz2z2mCNp2BLb4i3QiKpGqDUWpRK0tVX0TcjFMQo6wum+w\r\njb5gyIhLdFnKAKWwyM88MWqJgD0C6ve9mOY7K4yn8PDGvsazCWkAUauUYKDS\r\nCBZAtXnN7j8EPokl0qcjklS9en3M1zy3GnYmCw9pkbCVFjvfBM9Tl4CoaJvC\r\nm25w6qRBTKSnYcPRuh8uNDP4nzxjJHGAT4M4kzpO2v40m3G5ZoVTCBnrqMZu\r\nAxhLXKVxE6C0IDAs21EJIDGpJ9XTDnkB7UM/DzzZu/KYQVrqd/pbEaTVi4cC\r\nFUlsgOaflZF9oL5B/2v8cVeeo1EMCtE530JQ5JEtky8AR0zMYaJsnw/fBBi0\r\nDtvMCeYorgYZ/vPGFplzhUlfFlp2wnzUzhAvIgWB92yi10ZzRpGy6hvUFRha\r\nsbLZsdX+Rd/DL09wF6tjmQaSrhpPCvo/Tno=\r\n=d3qF\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.11.0-alpha.1_1681144707556_0.5237706659832717"},"_hasShrinkwrap":false},"0.11.0":{"name":"@sensejs/kafkajs-standalone","version":"0.11.0","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies.","type":"module","types":"./dist-dts/lib/index.d.ts","main":"./dist-cjs/lib/index.js","module":"./dist-esm/lib/index.js","exports":{"types":"./dist-dts/index.d.ts","import":"./dist-esm/lib/index.js","require":"./dist-cjs/lib/index.js"},"publishConfig":{"access":"public"},"author":{"name":"LAN Xingcan"},"license":"ISC","dependencies":{"@sensejs/utility":"^0.11.0","lightning-pool":"^4.2.1","long":"^4.0.0","rxjs":"^7.8.0","tslib":"^2.5.0"},"peerDependencies":{"kafkajs":"^2.0.2"},"devDependencies":{"config":"^3.3.9","@sensejs/testing-utility":"0.10.1"},"scripts":{"test":"jest","build":"tsc -p tsconfig.build-cjs.json && tsc -p tsconfig.build-esm.json && tsc -p tsconfig.build-dts.json","clean":"rm -rf ./dist-esm/lib dist-cjs/lib dist-dts"},"_id":"@sensejs/kafkajs-standalone@0.11.0","_integrity":"sha512-UCsrcr3oP2bWeZtzPacQiJsZ602bfqzXXnsh58FHd5yp/yaKvVxwdbT/aXDzutPr03TEz1/OCVz/Kho/NPOHgA==","_resolved":"/private/var/folders/vm/gz75zcmj2tvcgj7crtrv80rr0000gp/T/c984ce3e037e27a552a0e70b533cb44d/sensejs-kafkajs-standalone-0.11.0.tgz","_from":"file:sensejs-kafkajs-standalone-0.11.0.tgz","_nodeVersion":"16.20.0","_npmVersion":"8.19.4","dist":{"integrity":"sha512-UCsrcr3oP2bWeZtzPacQiJsZ602bfqzXXnsh58FHd5yp/yaKvVxwdbT/aXDzutPr03TEz1/OCVz/Kho/NPOHgA==","shasum":"89f656e64541e63d2538df463a94692d1b331a79","tarball":"https://registry.npmjs.org/@sensejs/kafkajs-standalone/-/kafkajs-standalone-0.11.0.tgz","fileCount":86,"unpackedSize":269748,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD7NenRRo7jxbTwJPB5ljdBq7uQDKL0GXsaoksjorCHnAIgJ678Zg9vMaaZoxAdL7wMXrW9Yf+B8KcH4MyQ7ec3peI="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJkP4l8ACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2VmobVBAAnJvG4RjQBZ8cp4tYHoI8HCSUHT47NaKMjmMQWSHdNFsKeqBS\r\n4ZmcQaTK5sOk9c4b8mDzGDYrOBza4gXoIR7RxBstDQiCFBWqr+laced49Pjv\r\nbHWJSFVlXvmyXG5VyCfbAJ9kBNbIkXwPqH56SVhi5VkusNU1CDeHkBATPpYs\r\nhG0+0urEFjw+GDqY4+tQgA64iWcPpn3yV4N0gWIrdoLVFHo0x1unt6cTl5Yk\r\njus5L/fhDuDR+3LRS1vI++mKjHmT2WHXQ3CLSJ7lxw0KT9VFT5/7zRzOmDaB\r\nK4Vl3Ziw0TF4GP/4gqskAxrGt1DNL9DUSs+ohNaWB2ek/JJU4zdHlB2Y3SpT\r\nSvIfXop5tSJxH+SHz9ngtrcOvRaRtlE33+OKMjgENgtUk6FmV8PDkhwq5ltz\r\ngMZCar8EYpWi4Y54Ez6xqWeUCQbYSewkHyAqMdn3X/FxpwfKksbtC7Yx9UPW\r\neKb08Xiy5oajhcExmM6IoEBFJo06qyoMqkSQoOD4UfoeVDa+7AeDuuKcavJz\r\ndcXRCRUyAtAnUOb63jJnXvhCe2bSawI8hmWUjzCMxvntWi5HNVlMG69TFeTY\r\nX0jfQExFfzeXnzK0/EmP92zNBp1lAZ+ndOrF/efL2kJpLSNTzX5HmiCzbNwx\r\nV0cFLAzO4Viyf+VsN9yrIx1xRF1r65QSVvw=\r\n=e87T\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafkajs-standalone_0.11.0_1681885563798_0.734789019403526"},"_hasShrinkwrap":false}},"time":{"created":"2020-01-16T13:22:19.140Z","0.2.0-0":"2020-01-16T13:22:19.525Z","modified":"2023-04-19T06:26:04.103Z","0.2.0":"2020-01-16T14:04:27.091Z","0.2.1":"2020-02-28T07:09:41.290Z","0.3.0-0":"2020-03-05T18:32:51.776Z","0.3.0":"2020-03-06T17:07:46.555Z","0.3.1":"2020-03-07T17:35:27.933Z","0.3.3":"2020-03-11T06:53:51.697Z","0.3.4":"2020-03-13T08:28:18.591Z","0.3.5":"2020-03-13T09:24:57.233Z","0.3.6":"2020-03-14T17:02:52.553Z","0.4.0":"2020-04-03T04:27:48.226Z","0.4.1":"2020-04-07T08:58:02.469Z","0.4.2":"2020-04-07T09:18:32.780Z","0.5.0":"2020-04-07T17:41:21.803Z","0.5.1":"2020-05-17T15:06:20.182Z","0.5.2":"2020-05-20T17:36:43.321Z","0.6.0":"2020-08-05T03:52:53.852Z","0.6.1":"2020-08-14T09:50:32.523Z","0.7.0":"2020-09-12T19:36:43.573Z","0.8.0-alpha.1":"2021-03-25T22:23:31.199Z","0.8.0-alpha.2":"2021-03-29T13:23:35.874Z","0.8.0-alpha.3":"2021-04-12T20:47:06.555Z","0.7.1":"2021-04-13T09:14:19.455Z","0.8.0-alpha.4":"2021-04-13T12:13:53.658Z","0.8.0":"2021-04-22T01:02:51.569Z","0.8.1":"2021-04-25T15:26:58.144Z","0.8.2":"2021-04-27T00:19:05.132Z","0.8.3":"2021-05-09T17:15:03.869Z","0.9.0-alpha.0":"2021-07-08T07:31:33.438Z","0.9.0-alpha.1":"2021-07-20T11:10:39.480Z","0.9.0-alpha.2":"2021-09-23T04:14:13.987Z","0.9.0-alpha.3":"2021-09-23T04:18:23.086Z","0.9.0-alpha.4":"2021-09-27T01:15:21.131Z","0.9.0-alpha.5":"2021-10-28T13:48:37.025Z","0.9.0-alpha.6":"2021-10-31T16:54:32.109Z","0.9.0":"2021-11-08T09:25:58.153Z","0.9.1":"2021-11-08T09:40:50.467Z","0.9.2":"2022-06-07T08:36:25.538Z","0.9.3":"2022-06-21T07:41:49.366Z","0.10.0-alpha.0":"2022-11-18T06:21:44.999Z","0.10.0":"2023-03-19T06:57:17.738Z","0.10.1":"2023-04-04T18:49:59.232Z","0.11.0-alpha.0":"2023-04-08T18:16:37.397Z","0.11.0-alpha.1":"2023-04-10T16:38:27.735Z","0.11.0":"2023-04-19T06:26:03.986Z"},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"author":{"name":"LAN Xingcan"},"license":"ISC","readme":"# Standalone Wrapper for KafkaJS\n\nThis package provides easy to use kafka consumer and producer based on\n[kafkajs], without core parts of sense.js as dependencies.\n\n## Install\n\n```bash\nnpm install @sensejs/kafkajs-standalone kafkajs\n```\n\n## Highlights:\n\n- Consumer:\n\n 1. Automatically set `partitionConsumedConcurrently` to number of\n partitions of a topic, to maximum the throughput.\n\n 2. Detect rebalance as quickly as possible.\n\n 3. Save offset when consumer group is going to rebalance, to avoid\n any message be re-consumed as possible as it can (while still\n you should not expect it won't happen).\n\n- Producer:\n\n 1. Default `maxInFlightRequests` to `1` and `idempotent` to `true`,\n to fit requirements of transactional producer. Can be overridden\n if transaction is not required.\n\n 2. Ability to provide `messageKeyProvider` to assign a key to\n message if not specified.\n\n[kafkajs]: https://kafka.js.org\n","readmeFilename":"README.md","description":"This package provides easy to use kafka consumer and producer based on [kafkajs], without core parts of sense.js as dependencies."}