{"_id":"@chronark/upstash-kafka","_rev":"11-7ebdf4a5f6f2f0bf5df34a9196fb5c12","name":"@chronark/upstash-kafka","dist-tags":{"latest":"1.1.1"},"versions":{"0.0.1":{"module":"./esm/mod.js","main":"./umd/mod.js","types":"./types/mod.d.ts","name":"@chronark/upstash-kafka","version":"0.0.1","description":"Serverless kafka client for upstash","license":"MIT","repository":{"type":"git","url":"git+https://github.com/chronark/upstash-kafka.git"},"bugs":{"url":"https://github.com/chronark/upstash-kafka/issues"},"exports":{".":{"import":"./esm/mod.js","require":"./umd/mod.js","types":"./types/mod.d.ts"}},"scripts":{"test":"node test_runner.js"},"gitHead":"c42fdb495a5667ef8b79c37131fd5beddbd739e7","homepage":"https://github.com/chronark/upstash-kafka#readme","_id":"@chronark/upstash-kafka@0.0.1","_nodeVersion":"16.13.1","_npmVersion":"8.1.2","dist":{"integrity":"sha512-5rMQcq8+Ex5xe0BFEki1VVkdO6J+6GXtw/hH7AiQCX1uFmhSvUN5MmpQhc/YNWz44pWTm30UWI6ux3NFDX8TaA==","shasum":"deec8034e70c2654f1bbd331485e673c8c37b7eb","tarball":"https://registry.npmjs.org/@chronark/upstash-kafka/-/upstash-kafka-0.0.1.tgz","fileCount":17,"unpackedSize":12718,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJh1J8LCRA9TVsSAnZWagAA73oP/2WyfSkSQr+DN6YNzFA3\n4NLlefl8G9ETya+4R0eUxYRGmPEiGtvnXpHpHe9HzxipfUeKyCdKU0BSb16s\nmWcTAIdJt3VSw6l5SIsK4EgGDCNAI4u/C10FhOftRNPXjMkjyHdhtcbln6KY\n4K8ueeYycH4tJws3p6KVxmhji0kQSumeUNhSZNAAls8A13ZeDfFkzxxjZSZD\nnypOHH7AOjo1XcIa/A71j3+A2DPxUj135h00vqIjNDSOkJudhpFmLhinKpZE\nehcO1jhA3jy83N7uA4ne0fkMeDQ96ZUa4zoXTHM21BU5DxzfKNEcpRV+nA+9\njZofkZeBnWJ3j0KVzHUgT/EEmYySCUgiXogpI6GogsedwJe5yGQWjFDIQK27\nqbxKlfERjRDpzHfXrsWrTnbVhn2IQ9t4vRqq9MW6C76wja0tWpVPMosINrKk\njPJGDa/3a/ugLd4gk2TjUWjDFKyNWAotN8VqNRxKi1BaaMbDry+FnttE4gT9\nrr+QDWh/ISCRsglv/5ZuFFd+hztBsJxyPiBNJHjYrQp6hYThIbKgOhRHDsBQ\n8pRrsmfoPO+TQcucBarbBQy09XHfoGK9PBSPRb6WxRjehDZUNMDr2+qLPHN+\n3s4FOPsFi27cI73jBOC7oylk5KC8whZnx/25YtwyRNZy7tONTlhEbGW3ojXC\nydA7\r\n=IMv2\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCkF2DxHlFIQIOrg2+eq8rAblWqO9KiwkJ3Xy0AVC6hEgIgdE3lB8KQeZm+kxBHa5HGe62n/YiVhsIVrXQDmkp7eZU="}]},"_npmUser":{"name":"chronark","email":"dev@chronark.com"},"directories":{},"maintainers":[{"name":"chronark","email":"dev@chronark.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/upstash-kafka_0.0.1_1641324299754_0.9656167887212148"},"_hasShrinkwrap":false},"0.0.2":{"module":"./esm/mod.js","main":"./umd/mod.js","types":"./types/mod.d.ts","name":"@chronark/upstash-kafka","version":"0.0.2","description":"Serverless kafka client for upstash","license":"MIT","repository":{"type":"git","url":"git+https://github.com/chronark/upstash-kafka.git"},"bugs":{"url":"https://github.com/chronark/upstash-kafka/issues"},"exports":{".":{"import":"./esm/mod.js","require":"./umd/mod.js","types":"./types/mod.d.ts"}},"scripts":{"test":"node test_runner.js"},"dependencies":{"@deno/shim-deno":"~0.1.0","undici":"^4.12.1"},"devDependencies":{"@types/node":"16.11.1"},"gitHead":"c42fdb495a5667ef8b79c37131fd5beddbd739e7","homepage":"https://github.com/chronark/upstash-kafka#readme","_id":"@chronark/upstash-kafka@0.0.2","_nodeVersion":"16.13.1","_npmVersion":"8.1.2","dist":{"integrity":"sha512-dPPjZEnHDhow+iPk+Mpb9rFyptMWEfS2MSYPnxzTW6SZcPv26dOIi5P2qDldkPf+m2IHHoGluBMYqzIHuvib+w==","shasum":"c0c0b6bd9144703b80ce0b2b0f32e09071664658","tarball":"https://registry.npmjs.org/@chronark/upstash-kafka/-/upstash-kafka-0.0.2.tgz","fileCount":20,"unpackedSize":20627,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJh1KJ+CRA9TVsSAnZWagAASn4P/1ZZkdNnwYKF4gVv7YNU\ndTWAI/612k7zY91PiQo4c5Vg5M5GcpCRrUuNFldeRuxO15wRlAQ0SxMyx5XK\nEEBb/raiRMImQbZodfgdZ0vKFdrkMSjwm99w6Ko+OjrRBmEs5tjGL6qUJfBy\ntcWQRpJp+ObIYqyp6ZNUSB0o0wPckta7pJO3wAfYEhi3MWy53kHktF8edw0o\ncUrmat9FhTVNAJgVMmcQTRErvnNeItdJBSo6xWghS4G01G6Rw7Yb0moP5LTn\n2amsfJjOcn0RTzScqZbqXmvNh/YT28wndSAbGOHNuWbfVFadgB0T10nsY41u\nk4o1tJcxL4Uf0oIZU0vmu8z72HRS1NxkE4/k73Ydyarst9tb8Wi/zUWarQ7I\nSixD6QzDlryBbYcpOG34rkV/DwNJV2hOkbgQ6YzAl2gbYMWBJHT3X5bNEezh\nGXt3IXT+atY6kDd4Yy1+7n1D+pjZV9jSS7Lvg6BWZyz7mjiUg3QlmipU47sU\noWCWC2F8uFRuTmd3MuJFGgothtb+ShlaR9+mdYPrk4Ae05kV1NrNLr8RAng4\nDt6pCJJNXLSPpbm6nZriUO0vNi3jrFW1RD1aDoLLNlHT9LeluIYCsMg5i8Ve\nZN+YesVGhT++PlvRhOgtUX1Z6lvY8Xr4VdyBxjvvYf4GimD5Z/4NC35UeGiP\nR3dr\r\n=9Ucv\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIF1P0ns/XBrbnMuAudzuq5aXFVbJg8D4MAw7auZnATyzAiEAvT1V3C6OdH8fbuIM6sep96YYhQmcOirC8RR5Q5uprSs="}]},"_npmUser":{"name":"chronark","email":"dev@chronark.com"},"directories":{},"maintainers":[{"name":"chronark","email":"dev@chronark.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/upstash-kafka_0.0.2_1641325182254_0.7437610957656577"},"_hasShrinkwrap":false},"0.0.3":{"module":"./esm/mod.js","main":"./umd/mod.js","types":"./types/mod.d.ts","name":"@chronark/upstash-kafka","version":"0.0.3","description":"Serverless kafka client for upstash","license":"MIT","repository":{"type":"git","url":"git+https://github.com/chronark/upstash-kafka.git"},"bugs":{"url":"https://github.com/chronark/upstash-kafka/issues"},"exports":{".":{"import":"./esm/mod.js","require":"./umd/mod.js","types":"./types/mod.d.ts"}},"scripts":{"test":"node test_runner.js"},"dependencies":{"@deno/shim-deno":"~0.1.0","undici":"^4.12.1"},"devDependencies":{"@types/node":"16.11.1"},"gitHead":"0c986324b613c1fd84b9d802c636c983e0e9ff0f","homepage":"https://github.com/chronark/upstash-kafka#readme","_id":"@chronark/upstash-kafka@0.0.3","_nodeVersion":"16.13.1","_npmVersion":"8.1.2","dist":{"integrity":"sha512-LZ92V7wCqmxWWws632vqCIVIONzf1Ga0jTqkjEvf2YPG/lya0P2a9AQAg3w03dBiMtYlZcUfx/q8DmsC0KKejw==","shasum":"e9a5ada7c7e8ae96ef54a367927dda56fa903202","tarball":"https://registry.npmjs.org/@chronark/upstash-kafka/-/upstash-kafka-0.0.3.tgz","fileCount":20,"unpackedSize":22070,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJh1KhWCRA9TVsSAnZWagAARh8P/jNfzZ+UfOGECjRgFHQz\njizSMAFNsUo1lR4wbWpy4fj7x2OomdnkhcMRQzEpwgajNCr5COuxR/DBWoow\nAzx065crw7T2g2lCjCsbMvkntfFGLUUle88070yBh+609aNJyUVmWQAl1Qn9\nvi2FGpNRpvvxURH9YiGDgMciPlqGbSWhF001GzJBb4qqHFbEifMdaLOtUdqc\nfAB29cxDTzXsPEbj9A89AXxnIBgUAMx8tZMoL/fGUn3tjSFmtYbzhcmVtMu5\nmrinEw9mR0lYHD6103c4XeXaMQ2FuWP/agWEjwSTVLeLHVpSf8BYlcP2Ope5\nx3eCttsS7723OBEUW5c8L/r0shHttCJXsMHbQVGcHFLfb124z13U5kl9aShl\nw9DmSxTajQLC+o22juXyA2QXDVkOhgQSJ2621Ra0D74rlJH/NEXYT16t+H1Y\nMjWojSxfLYshWE0gxd4iRLPDO4Yrjnk5y8L8XMeiYHQjYgI+XBe9+4QTSOVC\n7Q/AZFGR3rqBy09sHqrdpx7mo0aTLgb56oCd2Kn/i+s4haXCynpIOuq53y0r\nu/cuCL/pqBALOuCN1ug8/b6HmDTjv/Q4fJ+3XjFedzKDXJxdVuPsRSu2uKoD\nX4xVSlq3zdMT+5RJwkC99CfqibLESEhHIW0c8Lnif5KZWBFQSNP1klUmCRso\n2v8Q\r\n=95yV\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQD4d1Phgrz90u18++2Fk/XnZtbrOxTsicnCCLMRXratkAIhAKwfpi9bKqF7JCt/OkBAX2vQ7Vx2/IoeeprZwOfyHTEN"}]},"_npmUser":{"name":"chronark","email":"dev@chronark.com"},"directories":{},"maintainers":[{"name":"chronark","email":"dev@chronark.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/upstash-kafka_0.0.3_1641326678350_0.980205285219266"},"_hasShrinkwrap":false},"0.1.0":{"module":"./esm/mod.js","main":"./umd/mod.js","types":"./types/mod.d.ts","name":"@chronark/upstash-kafka","version":"0.1.0","description":"Serverless kafka client for upstash","license":"MIT","repository":{"type":"git","url":"git+https://github.com/chronark/upstash-kafka.git"},"bugs":{"url":"https://github.com/chronark/upstash-kafka/issues"},"exports":{".":{"import":"./esm/mod.js","require":"./umd/mod.js","types":"./types/mod.d.ts"}},"scripts":{"test":"node test_runner.js"},"dependencies":{"@deno/shim-deno":"~0.1.0","@deno/shim-crypto":"~0.1.0","undici":"^4.12.1"},"devDependencies":{"@types/node":"16.11.1","chalk":"4.1.2"},"gitHead":"984fa5d59828bc2867285c2f837321ca38610f57","homepage":"https://github.com/chronark/upstash-kafka#readme","_id":"@chronark/upstash-kafka@0.1.0","_nodeVersion":"17.3.0","_npmVersion":"8.3.0","dist":{"integrity":"sha512-zfajTrfoDOnPe/ypiz5LYWuNoVhvOLcoQV8bqMIMXkiAeOyXi0e/y9PYLabbmGNcGtMCiLZAsvzYvd858SAHsQ==","shasum":"4c7887f3f256df3497fcc5b2e3092aa4edbf6505","tarball":"https://registry.npmjs.org/@chronark/upstash-kafka/-/upstash-kafka-0.1.0.tgz","fileCount":1,"unpackedSize":792,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJh2HMZCRA9TVsSAnZWagAAGRoP/3Y1SSd2lZS1Lb9+yI20\nktQmD7eHr0e7J6iFec/xNsT73c0Sn3qtYZz+v2J/W0q62Q2HPSgY3IVQkw3w\nvy3mRHJNVTK6AltEJ8q+/xYAsMI7YuNZqk+4WFcO+HbG6JI+pGZaR1AiAx3Y\nHz2cmIBSU4UfN04Zg/I8dkc+KnQmv1PL8UJ1EDeM5+2PlU2v3sJxxg7ZrFQA\nTOu5E/xzr7Fi5bMAakcH4todMj1LxXmOTJz6V4FM9ovth/uTrm+BbQFdL815\ndh60lvEqAhwGarAQFeqaFRBPC9gjEC3M9uiBqBYSfLI0yycV2Za8FdcZIOCx\n6/l2sw5psKEXJ+CZrUz+2ve1Ai600+ucOU9oxNt0r0fUGh1LIYUeG4P+eIRl\nF6nUMYnXH8F5TeBoWvOhRMKrfZd66bb9EWIsxGpVfO3vyQWyOrkokGTSGX3L\n29XOXJc2fs06uDPss29YnfC7F2WgvhHemi8R8hvfauMHtGCFAKYIc/u3zPNe\nFIV9hDFeBz/0/GPf/XF8/I6so6DXndRApEf5TKNIOKB5gQg/ebTsX7xBeE2m\nYnOtr6VGKJva+TyFuBtgc2xQCsA+p8P6T7636kGKy4qj/D3PCHq8vgWLalIm\nC7nwSVSQnLWxETETUenODOyzSL/8Dp5Aba6qUqjULWhBgdKNtJJevSnXEKHJ\njIwl\r\n=0Ksj\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIFzkmLPW8NaZCMSLdYntJ4LH31SAY29xKdk/TEg945L7AiEAn1aZJqIMDOTbMItm5yOgrMPiYNJv7Tbua0tjkt/YTUY="}]},"_npmUser":{"name":"chronark","email":"dev@chronark.com"},"directories":{},"maintainers":[{"name":"chronark","email":"dev@chronark.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/upstash-kafka_0.1.0_1641575193761_0.4110744243434521"},"_hasShrinkwrap":false},"1.0.3":{"module":"./esm/mod.js","main":"./umd/mod.js","types":"./types/mod.d.ts","name":"@chronark/upstash-kafka","version":"1.0.3","description":"Serverless kafka client for upstash","license":"MIT","repository":{"type":"git","url":"git+https://github.com/chronark/upstash-kafka.git"},"bugs":{"url":"https://github.com/chronark/upstash-kafka/issues"},"exports":{".":{"import":"./esm/mod.js","require":"./umd/mod.js","types":"./types/mod.d.ts"}},"scripts":{"test":"node test_runner.js"},"dependencies":{"@deno/shim-deno":"~0.1.1","undici":"^4.12.1"},"devDependencies":{"@types/node":"16.11.1","chalk":"4.1.2"},"gitHead":"553d11584dc68486207a122796d662cd2416ef49","homepage":"https://github.com/chronark/upstash-kafka#readme","_id":"@chronark/upstash-kafka@1.0.3","_nodeVersion":"16.13.1","_npmVersion":"8.1.2","dist":{"integrity":"sha512-qvJhc1ZHxMR8zUFpt8pL+tW4cXdOWPsov2aEMwEJlsuDprujbWh3+QsEhb6xY0YINlSAnotam7lHGnhPurVzIg==","shasum":"fe987b8863752ab156ba94b1f2648a06656f2177","tarball":"https://registry.npmjs.org/@chronark/upstash-kafka/-/upstash-kafka-1.0.3.tgz","fileCount":36,"unpackedSize":76811,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJh2YLgCRA9TVsSAnZWagAA5dIP/2cNxVrf+CQNE0megsaq\noJVGrZ838wc5UMv4ykXNgTvtkKU6GzcD3pfRHAI6JRfGKkGDxjDoEzoh49N2\nARJFJkjSDBrQDC8Hgcg3FWDt+NqI4exaVINFjIb7NoGKOmsWnJd3oRTOWJzU\nCFmHTyy8uMPCijbwuheXeoETofVaUpe1DcIHI3GKtZNj+SEOf1WBFJD585gn\n4V+/rDlBqcILPl3klxzKtG4yw9dlxTnw0YwRXnpo0+HBw7DjtfsAbW6gr9sl\n7pb16je3EgQmAJYeakyb0UKVFEaKPk8YbhDzmiR/OQJbi11zOpv5C+LT3uDh\nTwxN+gIKU7ncKO+pzZchvzladanaPSMaNDeb0rphoFzcYYHip7wcyAhCcxLN\nQMRnGhfV345Jzdp22368cIt6xaLhVFreI/QFPhWRW3PoY09rlTklTi36Ocgy\nU3a+f9mGWyD8QPiKY/n82OZIznDb0xp39fF2mYnbRzTINd9pqbgeYtrgTacW\neLyguIG+a3CyFstqV2dspnIEj7vpNhIje0U3dMGO2sAyufd9VdOLGHlnbXYy\ndF+fmrk6oLSinUtl2Hznpm2b6j9FuDLuy92mNBTU2qYjHwQUsTq1rqIY/H7r\nf+dGyZT/uWQ9vFrsHvDq7AjWVY80sBF+TEYuL3oXJ6FOqsH5t3K2fGmZsNom\nucvs\r\n=KTB9\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCAukLFpcofmpfdp1iFiTCZtFM0JuRjR3+8PMCLoFAimAIhAKNM3CnBvEKYhKvYr3dbSxeghgaC9gqXG5aDguTWkkjN"}]},"_npmUser":{"name":"chronark","email":"dev@chronark.com"},"directories":{},"maintainers":[{"name":"chronark","email":"dev@chronark.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/upstash-kafka_1.0.3_1641644767911_0.5317157749852903"},"_hasShrinkwrap":false},"1.0.5":{"module":"./esm/mod.js","main":"./umd/mod.js","types":"./types/mod.d.ts","name":"@chronark/upstash-kafka","version":"1.0.5","description":"Serverless kafka client for upstash","license":"MIT","repository":{"type":"git","url":"git+https://github.com/chronark/upstash-kafka.git"},"bugs":{"url":"https://github.com/chronark/upstash-kafka/issues"},"exports":{".":{"import":"./esm/mod.js","require":"./umd/mod.js","types":"./types/mod.d.ts"}},"scripts":{"test":"node test_runner.js"},"dependencies":{"@deno/shim-deno":"~0.1.1","undici":"^4.12.1"},"devDependencies":{"@types/node":"16.11.1","chalk":"4.1.2"},"gitHead":"7be7788ec1a0e5c81ffce3e345fdff9d6fc9b5e5","homepage":"https://github.com/chronark/upstash-kafka#readme","_id":"@chronark/upstash-kafka@1.0.5","_nodeVersion":"16.13.1","_npmVersion":"8.1.2","dist":{"integrity":"sha512-RRXGTe9tzS2Zk/MxQfmMgmS333WRKuRjrZR19w7roiv+AcJz5Vca15Ix6mteenP4SUENKcudXLgJNTATG6wJNg==","shasum":"c8cc42019f66c896b710a2c5330cb8f07a3e85ca","tarball":"https://registry.npmjs.org/@chronark/upstash-kafka/-/upstash-kafka-1.0.5.tgz","fileCount":29,"unpackedSize":63097,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJh2rpvCRA9TVsSAnZWagAAqykP/0ljLMYf731WaJPOgeWZ\nf+JWWtgQOSysZTtK2m9/6zQJLNoEk+/lXnIG8c8r6PxEMY74wYUm9eYsV423\nC25hVOwGBUy8XazegZEGuEU/pjFxA7IYLzCMXP6alzTAkt3+nKKgEX31NWIZ\nvOCmHlwu1hz6vaFTf2+iGR3bOG725quzrduK4GLXBs/zfU6NSqIYMzd4uOm0\nhOKmzmyYt5D0jPrpPZ9PtY+AVkl0CGPMRz1JLjG5y/UDpQnk4PRIaX3ke6Ij\nNLc+z4GkmWsWDiO2P0CcMqZ+P84na/WNPvDMxrr2BZgbd4xW5kUvFLFkGHxl\nqExHkXYN0JdJ+T4aOBhFbNc1sJIGZRjXoMkJQzUhno1ZEmIFWRdtr+oUYVa2\nc+iVvK2i9MhnakWgfvemS5l7pFo1o3CgnXsuVMhr0B4lkDIlQRMetdQAc74v\nkHDP0357Oz0HcjNJhBxQf/07z14s8iTdoRs+zLVRw3lthSG6lMpHR5NCfqjk\nbgPaJnO4nh4S4AdT6JvX2BITf4CC62D6d2YIQLcRpOFKPodAFA5JX6YcxfVu\nPfPRVP0S/4N4vefq/2XaXPQaQZiSiMl+F2t5KbsHQLdMg5RON9z4u3wyKoMq\nY2pUJi45RX0yRKlf/lqTKJI0rd7/T+xOJy6o6XrdCZXHqQvoDhkgWfAH6FIb\n4o64\r\n=jtwH\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIDs9HAUQND3y3Kh5WgKMoQWk2684N35I0HjsgOCuvC9/AiEAhvbRoa8pJYUJM9olMfGH9HdYAvw6Mf9KsdaV92c+rDs="}]},"_npmUser":{"name":"chronark","email":"dev@chronark.com"},"directories":{},"maintainers":[{"name":"chronark","email":"dev@chronark.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/upstash-kafka_1.0.5_1641724526913_0.1516136262105845"},"_hasShrinkwrap":false},"1.1.0":{"module":"./esm/mod.js","types":"./types/mod.d.ts","name":"@chronark/upstash-kafka","version":"1.1.0","description":"Serverless kafka client for upstash","keywords":["upstash","kafka","serverless","deno","rest","api"],"license":"MIT","repository":{"type":"git","url":"git+https://github.com/chronark/upstash-kafka.git"},"bugs":{"url":"https://github.com/chronark/upstash-kafka/issues"},"exports":{".":{"import":"./esm/mod.js","types":"./types/mod.d.ts"}},"scripts":{"test":"node test_runner.js"},"dependencies":{"@deno/shim-deno":"~0.1.1","node-fetch":"~3.1.0"},"devDependencies":{"@types/node":"16.11.1","chalk":"4.1.2"},"gitHead":"43655d753fa7d2b07b4ab349a6a536ee7b8c70ae","homepage":"https://github.com/chronark/upstash-kafka#readme","_id":"@chronark/upstash-kafka@1.1.0","_nodeVersion":"16.13.1","_npmVersion":"8.1.2","dist":{"integrity":"sha512-NWEg+hUs+4+sVyyYNBByeFvz/kdZgcA0Ezl7xDsG1VOAMYFKHoPTkLsM7gO4Im5QBNOD+hQaQsiCCL5Vxs1CkA==","shasum":"911bd544c5c7ab7190fae244218b21584c897cb2","tarball":"https://registry.npmjs.org/@chronark/upstash-kafka/-/upstash-kafka-1.1.0.tgz","fileCount":20,"unpackedSize":35445,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJh2sTBCRA9TVsSAnZWagAAEs0P/RwxyZfHTqomVKmudUiF\nCOrlU1JSJNiHKv1dj32ECspbaN0ZvMNUDtGzmzS+tCZv47kZaqttFSJkyiKT\n280hq0/luyCmXJGARZ4Ocv2hEoRTs+qznDqU1eD8pnEsHxgW2Jmh0fADjuy4\ntecOAqPqZ5mLagzWz8ghSQFHsVfce4B6Z5wedyh008WrF3MiP78Q9drkdsJd\nE0YbMegvcR3+MuJjvHiB5H+irN6HhnsoS/96WTCE1hlMx/DfUKledDF0Run8\nyIFnnvKyCPGJ37I+8mJ3jRGnC5krCArB3fM5mh5+k7wjm6NhdarHfARfXxTK\nMfNKQREj5IawTtJ5TdfPfH934vG3KIYJFhGp+OUZzWaLIDLfWjHx7lSuV8kn\nwsUUZc7pk28sBU+CYe9lt/JYp0DSPDPzBxgkUly9ybrwWZPXeTs3G41aTP6h\nNbqkOqHFzgHW4Wu6098rBmrCF/vELitVP3vPNIW8glUifuw5X1z826+cgxGR\njlaee1Wm6YOMTma4rVWPmvlMMd8wdLyKjysefxbJgJAlbWDm1mOLJNt/gVwm\n2sr1naU855xdnrovJWcTreF6Ea9aYyFnY3kO0sgDFzZn2s77Fi4+uDSR3yVT\nLouIntNSY2DQqYcPu0TnO2QVMpeQYYIomj56pKTz0imzeoOurLwzno5L/tR7\nM/Id\r\n=2jIS\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCdY04Af28hscpeiYiZgqnNLJJkvwWxVrmV9nxtjVaJIAIgOdC5ukm+NJdpPQzaMtVatrHCyaWC9rLU9Cqnl14fcz4="}]},"_npmUser":{"name":"chronark","email":"dev@chronark.com"},"directories":{},"maintainers":[{"name":"chronark","email":"dev@chronark.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/upstash-kafka_1.1.0_1641727169545_0.21521798799411962"},"_hasShrinkwrap":false},"1.1.1-rc.1":{"module":"./esm/mod.js","types":"./types/mod.d.ts","name":"@chronark/upstash-kafka","version":"1.1.1-rc.1","description":"Serverless kafka client for upstash","keywords":["upstash","kafka","serverless","deno","rest","api"],"license":"MIT","repository":{"type":"git","url":"git+https://github.com/chronark/upstash-kafka.git"},"bugs":{"url":"https://github.com/chronark/upstash-kafka/issues"},"exports":{".":{"import":"./esm/mod.js","types":"./types/mod.d.ts"}},"scripts":{"test":"node test_runner.js"},"dependencies":{"node-fetch":"~3.1.0"},"devDependencies":{"@types/node":"16.11.1","chalk":"4.1.2","@deno/shim-deno":"~0.1.1"},"gitHead":"8b27e928c813d56bc04af970dbe4557c559d28ed","homepage":"https://github.com/chronark/upstash-kafka#readme","_id":"@chronark/upstash-kafka@1.1.1-rc.1","_nodeVersion":"16.13.1","_npmVersion":"8.1.2","dist":{"integrity":"sha512-eAcxPx4Y/8QvaSrl88KwwmkWukU9lEONsqnmo8ylqPcsDkZT/h2ed/6vnqMrax0ZmwoBMziJcMxr6RLLVhYd1Q==","shasum":"615369faf8b17958d2597a08b2ff42f77b741a73","tarball":"https://registry.npmjs.org/@chronark/upstash-kafka/-/upstash-kafka-1.1.1-rc.1.tgz","fileCount":22,"unpackedSize":35172,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJh2yL9CRA9TVsSAnZWagAAHOMP+wdw2tGiBysLIVnRKnGv\nFZ9APkMNLpMJUTzdHntH3haJuc7hKDD9BdZ9/J+GwA5k7DfeNgKKHgxLvTPp\n5qVIn9XRMbmlBD0xuSyAiQMEOPyy2hN9C6XNaAHhKhHLmWOdbyG+0lUVRACM\nNgc/DgbHjBsHTS8IkRskP6loSlTCA9niMrzIh4jH/H/PfAMGKb+hd8e94rS9\nh3/m5/ORdxt8oMhSEaQqxi7J5fgFVMxXlAzCz5GoNZg3CS5e/ojF1em8gfVK\nYoG8LboIdog3tzkxq1BLkCvryKI8jm7MsTBa12/7LbExiLJjTVinj6OhFsIH\nNX6slrTDkYdHHJ1K+LDaRZwL/bFCk8w2T0y52u44iccDYajZx3ZtWijcufpK\nIFd0uzaD4fwuhLGysGpoYFMmRucaKJkD8i7odmUjj0gVTv2wibG8PFoe+jFp\np/vJ3FwBS6XGOdVJppR9KseYp9VJ4WzKe6pJq3ZvSGj6uSyauGYeF8mQVbtJ\nf8WFBYCb88dHQ3Oa3wV6UZxEohnoBuCHWA1wZfuilEG2ipUJWyZihcQPVviY\nXExFq6LkIxQpnXOidSp3iD3z14YL69inWf4aZqDv8RYi5aP5H5gNIi/VsNni\nOuLtDCnwB/KTSJ09umwc9g1BIoVc4bmb6zFBH6xOarbrUfM210+g04J8VrGZ\nECjt\r\n=HDcH\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCRZEsXfWuvU0h+EPTULDbavekgTtfSEryHBruJMphXTgIgVsvjH5GrUkDCKgFnEVT0/WOqi4fESHqJiB15SHEX/vs="}]},"_npmUser":{"name":"chronark","email":"dev@chronark.com"},"directories":{},"maintainers":[{"name":"chronark","email":"dev@chronark.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/upstash-kafka_1.1.1-rc.1_1641751293248_0.4710212367570603"},"_hasShrinkwrap":false},"1.1.1-rc.2":{"module":"./esm/mod.js","types":"./types/mod.d.ts","name":"@chronark/upstash-kafka","version":"1.1.1-rc.2","description":"Serverless kafka client for upstash","keywords":["upstash","kafka","serverless","deno","rest","api"],"license":"MIT","repository":{"type":"git","url":"git+https://github.com/chronark/upstash-kafka.git"},"bugs":{"url":"https://github.com/chronark/upstash-kafka/issues"},"exports":{".":{"import":"./esm/mod.js","types":"./types/mod.d.ts"}},"scripts":{"test":"node test_runner.js"},"dependencies":{"node-fetch":"~3.1.0"},"devDependencies":{"@types/node":"16.11.1","chalk":"4.1.2","@deno/shim-deno":"~0.1.1"},"gitHead":"8b27e928c813d56bc04af970dbe4557c559d28ed","homepage":"https://github.com/chronark/upstash-kafka#readme","_id":"@chronark/upstash-kafka@1.1.1-rc.2","_nodeVersion":"16.13.1","_npmVersion":"8.1.2","dist":{"integrity":"sha512-jFu1CPYoZLBExf9XfuXFvn0Ps7CvdeSA0wsldA7lzEHRejezk0VCr4vGYMxcZGuc0C6jyO6jP1aVZcNj4By/dw==","shasum":"572fb5547dae196dde40fc49110d878df3a1f66b","tarball":"https://registry.npmjs.org/@chronark/upstash-kafka/-/upstash-kafka-1.1.1-rc.2.tgz","fileCount":22,"unpackedSize":35172,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJh2zJFCRA9TVsSAnZWagAAuYEQAJP+WdicDCSANv7dIvbE\n/yyoKI72yGOvj+2Ct0sk2V2gu+P0XXLuiOK1GG7oqPz3PRT46BLUUOKn+5Sz\ncfbgCzM9YrZxVUn5gg3G6Iw48Tyy7R5/quc4k5/vJLmA12n6sBAvhg3kY939\nKqxRK1Kh7jt3PxCtn8ZmYRbL5CXEsCXGKtLld2sIkBFjBHRIUKQb1Lkrr9gq\nQfW5rhwwqvJ1HvZEmJ+nJLxIOCpHp8G/43k+NzQpxfaSgUsmNNgZq1lDxDDS\nDhQ6ymXYgUS0y+18Cs5CI6XZyUhI+Gdm06mUGU8P3D1KmIBhRqVowaY7PEoZ\nNhZhqLAMDuVBJC7FFTFXjUi9NOrcrhcL39IggbFFVDIeRSmW4FparaFYvE+e\nkUW8K8r5n+BWrE1KITVp0Xl6xBJRCfH/6DhxnJyS+HsIQM/GvLDe0M+I9DiT\nb48rgcaoY1cZFcVCAlXMQgdHBsFNw5QRgwQZecfJIxsl80GFd8jijqICu5Eu\nrtLx3R7QqJ6AwZN+M//hWQMj9SpB5sSn7l9CiTI904dXVd3BcH2B8AgrXlPA\nHeq+S92QP2xZvo7orAhdPJNVTrramVNNZmGRqO5n5zPfutaLVyvm/HMpeSGB\nbuMR1Z9ybojRnMEfAY8n1mCxaAKsgnGn1PjDM84hGfgmb/MuPykpcEkvWq2E\np7Rp\r\n=sQ+n\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD5QGd2Mpwidn9+GWsXnn3Frhf/iQg176e4okH1t9G8TwIgK9aJKI+FwAIfWtwbTMYaXZsLXlVfO5fAlP06ZDoAYHw="}]},"_npmUser":{"name":"chronark","email":"dev@chronark.com"},"directories":{},"maintainers":[{"name":"chronark","email":"dev@chronark.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/upstash-kafka_1.1.1-rc.2_1641755205431_0.025704091261927298"},"_hasShrinkwrap":false},"1.1.1-rc.3":{"module":"./esm/mod.js","types":"./types/mod.d.ts","devDependencies":{"@deno/shim-deno":"~0.1.0","@types/btoa":"1.2.3","@types/node":"16.11.1"},"name":"@chronark/upstash-kafka","description":"Serverless kafka client for upstash","keywords":["upstash","kafka","serverless","deno","rest","api"],"license":"MIT","repository":{"type":"git","url":"git+https://github.com/chronark/upstash-kafka.git"},"bugs":{"url":"https://github.com/chronark/upstash-kafka/issues"},"exports":{".":{"import":"./esm/mod.js","types":"./types/mod.d.ts"}},"scripts":{"test":"node test_runner.js"},"dependencies":{"node-fetch":"~3.1.0","btoa":"1.2.1"},"version":"1.1.1-rc.3","homepage":"https://github.com/chronark/upstash-kafka#readme","_id":"@chronark/upstash-kafka@1.1.1-rc.3","_nodeVersion":"14.18.2","_npmVersion":"6.14.15","dist":{"integrity":"sha512-+GRW0wVRVyMlPzGvJ80C9OExW3Vtf5aXr6PYr0IZfvX6hkMUDt6us1n59/g/aSq6BjlXdGEP4u8WaJzZmQzPLQ==","shasum":"af84209c28f5d560b550f58ba980a50c6069e6bf","tarball":"https://registry.npmjs.org/@chronark/upstash-kafka/-/upstash-kafka-1.1.1-rc.3.tgz","fileCount":31,"unpackedSize":50249,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJh2zoaCRA9TVsSAnZWagAA1I8P/A/OMIZ/cumAA86DD9h9\nXD/k6S13lSDborbbaRHwwxqfO0pUzIoZUxbS6Ueu70DLAizaYRKR6AYoD70V\nT0bWqwueZSFAz0Xii1V3CYLzjOOywe8NLQld1rkekurqMHeUsGJ2fxFeGU25\nceP1x/dmoowoP5KEE6Nag1RHeojxNx0x4pmueGoKN7JbVqv2rX2TNzGfdTpF\nXO0IXjXS4gQKt3J+Z8Gn6oIhMzBXaAhYtGMoqUDiSM3myx0aPwq7aAUCy6xu\nxGsgTq0xhG5tp0E/RaJQwjV2+iYD0kNU3qhyDtuO/qvjZBbGoLiZHp1aKU3J\nTnbDtmflhURePqhb1fEeySBj6Wv+UgtkybG+1G5OfOKIPF8Krhs6NZNomChP\n8aR/nP28HRhBE9gl7xtRauSMWe2layjClQREHDILatF/9K3q0he7qukTvlIq\n2ScV/Q+/gIGURnhH28b1wd0P0tjQmqHM6EDAGuj2bZnWOTCSfW+ec2EGmjNB\nM53D97fchL2nSC9hjsKkP+r/4xWi6GOIY/sXcqFFpeshAY0PEdfFLIxxevGs\nhNlZdOOn2OuKLQKNueMcZezwnHUDLmC2CBltOTfysgKMlbvDQ+DZ15yrzf33\nz1nDn4GdrwVJSHIjCbF+gJ01OQSRpw/G6u6dcrAnpPL1JojFROx2ojnE8OCt\nssZ5\r\n=mTss\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIBAuec5oK5szTihyb8VH7iLr5vBYLEuK413LOJFsI3dKAiAuhMOJsozzkwYIBnl1ZGwuq/ddFHgcTqghs8tD+uuRrw=="}]},"_npmUser":{"name":"chronark","email":"dev@chronark.com"},"directories":{},"maintainers":[{"name":"chronark","email":"dev@chronark.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/upstash-kafka_1.1.1-rc.3_1641757210552_0.8326266868431638"},"_hasShrinkwrap":false},"1.1.1":{"module":"./esm/mod.js","types":"./types/mod.d.ts","devDependencies":{"@types/node":"16.11.1","chalk":"4.1.2","@deno/shim-deno":"~0.1.1","@types/btoa":"1.2.3"},"name":"@chronark/upstash-kafka","version":"1.1.1","description":"Serverless kafka client for upstash","keywords":["upstash","kafka","serverless","deno","rest","api"],"license":"MIT","repository":{"type":"git","url":"git+https://github.com/chronark/upstash-kafka.git"},"bugs":{"url":"https://github.com/chronark/upstash-kafka/issues"},"exports":{".":{"import":"./esm/mod.js","types":"./types/mod.d.ts"}},"scripts":{"test":"node test_runner.js"},"dependencies":{"node-fetch":"~3.1.0","btoa":"1.2.1"},"gitHead":"f30c67ba64a57b1e4144308d137264b24da3a9c3","homepage":"https://github.com/chronark/upstash-kafka#readme","_id":"@chronark/upstash-kafka@1.1.1","_nodeVersion":"16.13.1","_npmVersion":"8.1.2","dist":{"integrity":"sha512-qcht7n6Oe52gHI2DO60VnUKQTO848lDZ3t0l0piP10xZ2xJOQrzo8qHc3al6Fi8cAMpyviLl3Hy8b+eLDPDkVw==","shasum":"db2efd0685404687f03f65f4e2ee6bc296339148","tarball":"https://registry.npmjs.org/@chronark/upstash-kafka/-/upstash-kafka-1.1.1.tgz","fileCount":22,"unpackedSize":35960,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJh20AKCRA9TVsSAnZWagAAqmgQAKSZbs5BchwXZfEn2Ibw\nVMO/DnmQnqi/wE9RVpkjsk2SdhGxPPyD7Ems6rQAeM3ApX+1SZUzjJmHhq1L\n8QH6NTOcm+wMKZ/U5HBgxunWpnxD07Qwg2UynQMdt/5xlEmMOOyGz0Gm7Lya\n5bZaWXVOhiZlDBU29x0+BhyA+XymLIlVe52dWRArfuFn21jXCMd1Wq7+ncxS\nmOQKzWVFTaviVORQCrslo3xSS4UYuSpruIGOix1JMTeOcMTMFcLdNMNpLmBD\nhsztqeywq4e6Wvh5RC0bsVzffmBaEP7lyHo+EFPmWxrnoNJ0Meuxb6MwRCIf\nmp7Ni962/T3EHr2z86iUPXjNf0xDyuV9FSBvk8WYSmSeP+pl24cJ4Y4dxMDI\nMM4eSa3W14bwhLn2Glpe163qgi2k6nOUf4+RBodFHEZrYC1E20u0lpc/rbEl\neGL0TwWT4Oge7aQsNP9Ts32dw2gyE5iAFmR8RAQBRyKPx2786P2xtgPDK90b\ne7v4KWzbQDJVn/zUrMP/ljZTG9p+hq73t06qI3kvyow77akT7XkMPE4XTxHF\nEJC5/oIb71cHq16ceDyV4fybyMC7D+GqlcQTECbJkBXnAZbglC7uiPUa+R69\nEVUkVjT/SMn8LKlD3quVlwHGrNjvnwJrS1NKq7YpO7FXRMuPxwSjRyRVl/kb\nze3d\r\n=ZL/s\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDzjzpaiUWdWn5ygIYnzNR63e9shAiBWbSHQWTHMWl7XwIgapMYJ/18THyD9b4H52dpuv0ZoSuK97FYFPJJsO3vDZc="}]},"_npmUser":{"name":"chronark","email":"dev@chronark.com"},"directories":{},"maintainers":[{"name":"chronark","email":"dev@chronark.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/upstash-kafka_1.1.1_1641758730451_0.3425873242292181"},"_hasShrinkwrap":false}},"time":{"created":"2022-01-04T19:24:59.690Z","0.0.1":"2022-01-04T19:24:59.849Z","modified":"2022-04-04T22:55:27.866Z","0.0.2":"2022-01-04T19:39:42.437Z","0.0.3":"2022-01-04T20:04:38.500Z","0.1.0":"2022-01-07T17:06:33.906Z","1.0.3":"2022-01-08T12:26:08.123Z","1.0.5":"2022-01-09T10:35:27.057Z","1.1.0":"2022-01-09T11:19:29.716Z","1.1.1-rc.1":"2022-01-09T18:01:33.504Z","1.1.1-rc.2":"2022-01-09T19:06:45.570Z","1.1.1-rc.3":"2022-01-09T19:40:10.965Z","1.1.1":"2022-01-09T20:05:30.595Z"},"maintainers":[{"name":"chronark","email":"dev@chronark.com"}],"description":"Serverless kafka client for upstash","homepage":"https://github.com/chronark/upstash-kafka#readme","repository":{"type":"git","url":"git+https://github.com/chronark/upstash-kafka.git"},"bugs":{"url":"https://github.com/chronark/upstash-kafka/issues"},"license":"MIT","readme":"# upstash-kafka\n\nServerless kafka client for upstash\n\n[![codecov](https://codecov.io/gh/chronark/upstash-kafka/branch/main/graph/badge.svg?token=BBJ1FCHPF0)](https://codecov.io/gh/chronark/upstash-kafka)\n\nThis project is written using the [deno](https://deno.land/) runtime and then\ntranspiled to node and published as a package on npm.\n\n# Requirements\n\nEither deno 1.x or node 14.x and higher\n\n# Installation\n\n## Deno\n\n```\nimport { Kafka } from \"https://deno.land/x/upstash_kafka/mod.ts\"\n```\n\n## Node\n\n```bash\nnpm install @chronark/upstash-kafka\n```\n\n```bash\nyarn add @chronark/upstash-kafka\n```\n\n```bash\npnpm add @chronark/upstash-kafka\n```\n\nYou get the idea.\n\n# Quickstart\n\n## Auth\n\n1. Go to [upstash](https://console.upstash.com/kafka) and select your database.\n2. Copy the `REST API` secrets at the bottom of the page\n\n```typescript\nimport { Kafka } from \"@chronark/upstash-kafka\";\n\nconst kafka = new Kafka({\n  url: \"<UPSTASH_KAFKA_REST_URL>\",\n  username: \"<UPSTASH_KAFKA_REST_USERNAME>\",\n  password: \"<UPSTASH_KAFKA_REST_PASSWORD>\",\n});\n```\n\n## Produce a single message\n\n```typescript\nconst p = kafka.producer();\nconst message = { hello: \"world\" }; // Objects will get serialized using `JSON.stringify`\nconst res = await p.produce(\"<my.topic>\", message);\nconst res = await p.produce(\"<my.topic>\", message, {\n  partition: 1,\n  timestamp: 12345,\n  key: \"<custom key>\",\n  headers: [{ key: \"traceId\", value: \"85a9f12\" }],\n});\n```\n\n## Produce multiple messages.\n\nThe same options from the example above can be set for every message.\n\n```typescript\nconst p = kafka.producer();\nconst res = await p.produceMany([\n  {\n    topic: \"my.topic\",\n    value: \"my message\",\n    // ...options\n  },\n  {\n    topic: \"another.topic\",\n    value: \"another message\",\n    // ...options\n  },\n]);\n```\n\n## Consume\n\nThe first time a consumer is created, it needs to figure out the group\ncoordinator by asking the Kafka brokers and joins the consumer group. This\nprocess takes some time to complete. That's why when a consumer instance is\ncreated first time, it may return empty messages until consumer group\ncoordination is completed.\n\n```typescript\nconst c = kafka.consumer();\nconst messages = await c.consume({\n  consumerGroupId: \"group_1\",\n  instanceId: \"instance_1\",\n  topics: [\"test.topic\"],\n  autoOffsetReset: \"earliest\",\n});\n```\n\nMore examples can be found in the\n[docstring](https://github.com/chronark/upstash-kafka/blob/main/pkg/consumer.ts#L265)\n\n## Commit manually\n\nWhile `consume` can handle committing automatically, you can also use\n`Consumer.commit` to manually commit.\n\n```typescript\nconst consumerGroupId = \"mygroup\";\nconst instanceId = \"myinstance\";\nconst topic = \"my.topic\";\n\nconst c = kafka.consumer();\nconst messages = await c.consume({\n  consumerGroupId,\n  instanceId,\n  topics: [topic],\n  autoCommit: false,\n});\n\nfor (const message of messages) {\n  // message handling logic\n\n  await c.commit({\n    consumerGroupId,\n    instanceId,\n    offset: {\n      topic: message.topic,\n      partition: message.partition,\n      offset: message.offset,\n    },\n  });\n}\n```\n\n## Fetch\n\nYou can also manage offsets manually by using `Consumer.fetch`\n\n```typescript\nconst c = kafka.consumer();\nconst messages = await c.fetch({\n  topic: \"greeting\",\n  partition: 3,\n  offset: 42,\n  timeout: 1000,\n});\n```\n\n## Examples\n\nThere is a minimal working example application available in\n[/example](https://github.com/chronark/upstash-kafka/tree/main/example) as well\nas various examples in the docstrings of each method.\n\n# Contributing\n\n## Setup\n\n1. Create a kafka instance on upstash\n   [docs](https://docs.upstash.com/kafka#create-a-kafka-cluster)\n2. Create the following topics: `blue`, `red`, `green`\n   [docs](https://docs.upstash.com/kafka#create-a-topic)\n3. Create `.env` file with your kafka secrets `cp .env.example .env`\n\n## Running tests\n\n```bash\nmake test\n```\n\n## Building for node\n\n```bash\nmake build\n```\n\nA `/npm` folder will be created with the built node module. As part of the build\nprocess the tests are run against your installed node version. To disable this,\nyou can configure the build pipeline in `/cmd/build.ts`\n\n```typescript\n// ...\nawait build({\n  test: false, // <-- add this\n  // ... remaining config\n});\n```\n","readmeFilename":"README.md","keywords":["upstash","kafka","serverless","deno","rest","api"]}