{"_id":"kafka-pipeline","_rev":"38-ba0fc54fc40275513de8ad988f65c0aa","name":"kafka-pipeline","dist-tags":{"latest":"3.2.0","next":"3.0.0-0","beta":"3.1.0"},"versions":{"0.1.0":{"name":"kafka-pipeline","version":"0.1.0","description":"This library provide a robust, easy to use kafka message consumer based on  `ConsumerGroup` from [kafka-node] that helps you managing message offsets  in correct way.","main":"index.js","scripts":{"test":"jest"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":"","license":"ISC","peerDependencies":{"kafka-node":"^2.6.1"},"devDependencies":{"@types/jest":"^23.3.1","@types/kafka-node":"^2.0.7","jest":"^23.5.0","kafka-node":"^2.6.1"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"fba21e25158a282f2883c5770c3f88b0617d7b97","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"homepage":"https://github.com/thynson/kafka-pipeline#readme","_id":"kafka-pipeline@0.1.0","_npmVersion":"6.2.0","_nodeVersion":"10.9.0","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-b624mAZZv7MjoPlfjHE2bA7HCpvX3bTuAoONQzsB7quH1WGPIGi8Akfdx/JJxdVxOfegzlkWyJ3Ii3Hbn3+pdw==","shasum":"75d10f7fc77e182382f5bc156b9cac157e5be217","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-0.1.0.tgz","fileCount":11,"unpackedSize":32032,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbkINOCRA9TVsSAnZWagAAfaEP/1rxlUonvRka6EeIatk7\nbjSeYSXeMpc3iyOqWMaDvk3CrwvKwaa13dstpMEqVpqOJu77CryglSkJ6TN9\n0LWXvTBJWYEvZdg1aTuaZ/2gpd3AqoY7QfrxlOd1wLDOP5mAxghzrV2J5Tar\nVxEbRMS6HGWuiwqrF1itQjz6Dxz36EpK5Q7Guc7aKrLL4o0IZ0QPSj+QBIFS\nyWH9LPm43tAlbXZIoRVmTK55UWhC0okD9xwxWlAhz4r+NOvCIDLzuYgbJYtP\nHyeiZta882CSo79OhUwrnOFXWY9m7kq+SVwp8ZisMAT3iWsQqzHHNWsy8xO7\nWQtpVbpR73Epmw+NLd5pZ/WwwiLAQ9d5QgCE0B8qfPKv6JyFpeewbyp1PW2f\nzMhkMA2efgs1qOu/x0EUjzR3le9MUBRKi0aRU5iBAXt/TXCph0TBUeQgW/3u\nc7I6fTaJgjubZ24ZMZ2rjSHWb2TMqTs2/rz3oRCVpJtO06AqX2pkUPFw7MgO\nK+HKhxdaeMJovevEBmCkP8JNYBsHoi+FFtkizf4WdScwWr0+coOsTkXi0vE7\nDHHrBkFxpid4b5Fhlo31WpWvemO5H1Xe3d34Dj7yLM19hRrbM5GKoYPip4hr\nOWK0CUhfhC2BMBbdZoL9J2OsChThkJiuq4t/EgCWjnM15JDTnnaVnGoKwvyt\n8jiR\r\n=EX6B\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCisTbQ9gV9TxViRS0OEbIIAy0wU7p7QyXQnqXt08rSwwIgIwU9yKn4Yh8youna9Yw6GMeecF8+TOK9/nmUuRws08c="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_0.1.0_1536197453679_0.844343855214823"},"_hasShrinkwrap":false},"0.1.1":{"name":"kafka-pipeline","version":"0.1.1","description":"This library provide a robust, easy to use kafka message consumer based on  `ConsumerGroup` from [kafka-node] that helps you managing message offsets  in correct way.","main":"index.js","scripts":{"test":"jest"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":"","license":"ISC","peerDependencies":{"kafka-node":"^2.6.1"},"devDependencies":{"@types/jest":"^23.3.1","@types/kafka-node":"^2.0.7","jest":"^23.5.0","kafka-node":"^2.6.1"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"981e09a2ec47630e6da71cd15136891634c7e769","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"homepage":"https://github.com/thynson/kafka-pipeline#readme","_id":"kafka-pipeline@0.1.1","_npmVersion":"6.2.0","_nodeVersion":"10.9.0","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-O0J+UjWs1ZWNzoQf4OCIKLWchHPz895P9lBPnP5/3n7qZm5uXY0l2ePfgucZA5+kY1Kl03z6hMnM1GQzzHOw6g==","shasum":"6c2babae5910f0e824fcfeb546a74a86854bed4e","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-0.1.1.tgz","fileCount":11,"unpackedSize":32422,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbkPpBCRA9TVsSAnZWagAAhpsP/R31chRfWizo+4fScKS5\nwMPeJB4nNYa5pOaixfvQstfk5tZYkCDnRlBlbzfcUK+xjlInKPN2atSFr0iL\nuAwm1B4dkn2WRCYLRaP6/Jcqo9vJPRecU1gZj45C26NfSEKKWhftBMOjYQeu\nz+o75Mxr5W+ulpAVx77b4hRETZqW1r3IQsQFf4D8WwSVUmF2KSVMzYuj6W+m\nJoYTYL1pZdednnx7KKK9VoPO3TinYUdn5nEoSzls7/a7pv8s2Xw7FOb62uX0\nJX/4o+eemwJA+fAqCWmgl8gsv2l9TWDnsW0k6V/VZccvt20lVO8OOi2VJmxo\nf078aRoInLqe4ungZz/hVwIy8jMBDL6O9ivpXe7wHztWjo9LzmEqxVkDIpqM\n0Qrwovfns+/t1wD9AevVR9OV44qZ6OUQcHTct6YFN/hkYD+1Z9Z1yJ0pdhsR\n/0f3nqZWCwE/jVg9uENwYy+5RjjbEoAzj0f0Al+8UyMvJu9PqmpXJwNFTlaN\nfyWOvoSfnzwAPeC76fqTvt2/JLzs+Iu4gcxL1rvn5KpKn6y7j59svKIKXT4h\nJ1McjZZpl9Yn5mishXMqvePicq9WalNJy7/XOX/W80cGACGo/32ur94qIaGg\nykAvsqYnWj24FrmgShUGEQ48O3T7tU/2To+XdIDt7qX81D81IG7Ypmf4irO7\nmRn4\r\n=O4OL\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCICBOzEJZWuRfIJtI+uXZerwZDNoiHyfj0uyjf5ToUuv0AiAzqC9exTEneYsh2SkpxylEHMkx+wv7zRqM9jx6d1MkSg=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_0.1.1_1536227905131_0.08493152840502738"},"_hasShrinkwrap":false},"0.1.2":{"name":"kafka-pipeline","version":"0.1.2","description":"A robust, easy to use kafka consumer","main":"index.js","scripts":{"test":"jest"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^3.0.0"},"devDependencies":{"@types/jest":"^23.3.1","jest":"^23.5.0","kafka-node":"^3.0.0"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"b0096bf4de2f5f3337198e404b9b9da8d3393e1e","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"homepage":"https://github.com/thynson/kafka-pipeline#readme","_id":"kafka-pipeline@0.1.2","_npmVersion":"6.2.0","_nodeVersion":"10.9.0","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-3tI14aH3CFo6PkaohNZSt3UiIfFmHah4qBeavOKvJqpQZHJvctaqOFoQBmoYRXnuv39Kw3uyZMbjXwAXyxt3Lg==","shasum":"308be1ecaea14d51a0bcf08d6125a751d7186bc8","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-0.1.2.tgz","fileCount":11,"unpackedSize":32493,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbkWPECRA9TVsSAnZWagAAfZcQAIj2y6v2m2BqJV9G1t3L\nH0ZxXys0IDaDybBfHuRO4DZU/Nq3RgnV9NqofPSb3z6QWADDrohHrjxZtt+K\nW+r35EsPzwVWDcqPVZf1mhWDr13vs8ckJE2M5KI4/KkztwuNInarSOhYCc69\nPkKhJmqfK/b+eLbMvos9XVxyaKOqBxaslnEWGwu/aowMlSLD2zUwdCr5AawJ\nQgQGmLrGb80gJRZOv9IPNpsNw/kP1cGLZ14kS3ncI87uX6dNxTqGVpd8ZW8/\n59eKPvKAnpx6CxDs176CC8UN6ARdECLrng72LpMpk4uJyf80vTapioaqmRBA\nU28vJeoFDrjHyOS6p/pu3DRJX0pNDH/1W/UmOf520Q7xxnlg4QlZtsId21t8\nDnT+UsD17VA5pn4/kSUupLsdWirV2WZrnr39f57nX+tkSRTjvIwc4VL6soKO\nooXlpAkgDPKajXk6Z9YDMSpp+eqNJGxzy9F6imULtJUXinERBqXD2XnPI3I7\nIemtC4ZZ0LOWda/2X93ddtd8B+jisAf0sE9L8ddnBbAungA/XDr4O2O0MQR9\nO2qP+7qTI8AbO5alJhbJGv/HNzeL7UEaIBBuWzCoxAWZW7hU+SBdco+LeD8z\naupvTRcYq2pQdKKzibvNyoSRLXqGPKTaiWVtqxhmw+3iCjwNqs9fyKuQnX9o\nsP82\r\n=P793\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIFkjR6oLcJv2MobOkESiSmynZZkXwyfwCpCA5r1tHNBnAiANXygyRZUyYz3y8az38ieGft2KyLZ2LF4WADsCMjP2GA=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_0.1.2_1536254915572_0.5701173192461988"},"_hasShrinkwrap":false},"0.2.0":{"name":"kafka-pipeline","version":"0.2.0","description":"A robust, easy to use kafka consumer","main":"index.js","scripts":{"test":"jest"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^3.0.0"},"devDependencies":{"@types/jest":"^23.3.1","jest":"^23.5.0","kafka-node":"^3.0.0"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"7641654beab32fe5e78389ae8a2425f5fb7a32a8","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"homepage":"https://github.com/thynson/kafka-pipeline#readme","_id":"kafka-pipeline@0.2.0","_npmVersion":"6.2.0","_nodeVersion":"10.9.0","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-F7bSuvHRnZbfcCuhFG7bkF8Zr2mlD6ktBpnUozR5utaJYjijf9+LoKcDpjGkJLsT0BCJMYos9rLn2ECYzsclUg==","shasum":"56835e3c6f25c877bfa3ed7b8ddc02dd3fdb884e","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-0.2.0.tgz","fileCount":11,"unpackedSize":32582,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJblfCXCRA9TVsSAnZWagAAFfcP/27avYnqGK1n4q8Gn++j\n5RDBnhuuVbzZCVmDYIxoZOz7KGCScU4cH6U0SgHDuHFqFK9Gf4B1eiPv8DVU\neqijCVw2Xpgh1/dMrTYRGTSuQg/nKeaRHNg3/3zoZ37/s9n71b1JsFqS5WHT\nw/50n0bjGC0hk7TzGcAU9yCpI6N/2iua5TdI1rPgxiB61GiEOrzrOm4HDifY\nuNqjnDOVHlqfVcVp18rfliz8LFcidIdB3ctUKmlY0nWv0kk8tIh0MEyMf7Lm\nyiFP9RmbEm0WMqEf1PRHcHx+Nw5g3HLfXYa/8nvrPS9k+pHrxBl4yWxxwx/5\nlmW1UoUtGzP5oTluAslG95w0C7iVbFw/1l5VC3tbWkQcwF1YvMV15BsQj+RY\n+0ixtQKqR4rdMWSePalho9sJUArCBJZTr1MVWH0ZgOOv5HOpjEWnqt9dvarQ\nj5Nv7vmbp8YkRG4VLOIFVtTeacW9zEiL9ddYK9eZyNUOf7FlZ3/4V6Uw0duo\nRC3iIoHPbPYkCAb1vv8pyeIPQBILAFeqaYU/t5bZfiNqeEbXiNIv5YA+THRY\nF+BvBdJ7ZmNanmQzFjrNSOm6cdcAcc84KDRGpq2vVXSiPS+V6H4zOy/FS7qZ\nzGej/4SfcqNp2TNt7fUMa4cXJvVS/kS7cafi8pFGrm6mRFLh2dEblaw+EUGl\npANg\r\n=nry3\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCICfF/gWXgeOvucjcuDKs8Wt31GAeMxIbD9UVLV9bydxfAiAgFp18YH+GRPFs7Yej4/5UlQ5b7WhUNz3LnWjsvkPk4Q=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_0.2.0_1536553110743_0.5338216295043425"},"_hasShrinkwrap":false},"0.2.1":{"name":"kafka-pipeline","version":"0.2.1","description":"A robust, easy to use kafka consumer","main":"index.js","scripts":{"test":"jest"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^3.0.0"},"devDependencies":{"@types/jest":"^23.3.1","jest":"^23.5.0","kafka-node":"^3.0.0"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"caf29b5d400933401dc6029fcc1123508a082e81","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"homepage":"https://github.com/thynson/kafka-pipeline#readme","_id":"kafka-pipeline@0.2.1","_npmVersion":"6.2.0","_nodeVersion":"10.9.0","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-cn8SU5RrIudGn/a/zf7j9AE1CMOMAxWN9OhZVTsUwayVXHXvYxP+SjAM8KCtJP2a/HrS4SgUYkoTO/g2mlrCoA==","shasum":"e590e0f72b77012d2304fc01d5539ae0a94c3108","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-0.2.1.tgz","fileCount":11,"unpackedSize":32359,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJblhd1CRA9TVsSAnZWagAAhj8P/2Xfmo/7d7LigAAaoX49\n5YwrH52FDrB/fKhTvlkNBgXpX8hquUn7LT4yXuTNp1f6G3HkO36HlNSiZo72\nkFomMTHKywpqhVuX/9hX1/m24kxLJPjicPW8EaM41HkgKdq9ztMaNLp73JtL\nHBePf5W0Qbt9+S19GVrhC3Yvk9GprxMfX8XUz/6M4sPQdQZwEO3CR7Yivr2z\n1zsvjxBV+zi3l6uoM9RxL1tCqLn2GlgCgP/sPOub0x/VUOrsVfJdtzzRL4xi\npemDboPAMbggQgDhF99G3JKev0wKap75m5xziA4nCByLm5oicPiTMiBCpo0r\n47LBUlxY0l0X2ZkkPmpUEeQ1hPWj08Vcy2ojRjThC+zCVfiNxHlQZTWd6Yes\nFNRZLqRAdqs+Jn1XAx36WPJMDFxSl1c3E7UHtlyPBZTv2sYkPfutIieSH/YG\nB9i/K+3fSBrCD9YOrqpI6mheKzTMYfeUhePoo1oNMexXCTdWk1Ursv6fZNAE\nRwxsp93DdHX/Vibx4tj1OK+Bg/nsGJ2qk3LOcgLbH9dskQgsGOMXCSBsmyZH\nbIiuuWKHtkLTExWJTAQgLr19tyEiqYagxqpV4u5PMvZuMJ7EInGdQwlnVivF\nUv/ZnXtc/GyxN3Ewadkjc+RdgKtV9BmfJkOZneV72EQi576B+SYGR/Juyp5G\nIqo9\r\n=pvFz\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIGFzU8nOr6FSZslMfp3LF45sOAwDcVnlBjYtfNwP/+uKAiEArNbJW2ahgIy2OL/LcAIcBgHrpDWZtP3g8R15t4h7JkE="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_0.2.1_1536563061120_0.1668212308053152"},"_hasShrinkwrap":false},"0.2.2":{"name":"kafka-pipeline","version":"0.2.2","description":"A robust, easy to use kafka consumer","main":"index.js","scripts":{"test":"jest"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^3.0.0"},"devDependencies":{"@types/jest":"^23.3.1","jest":"^23.5.0","jsdoc":"^3.5.5","kafka-node":"^3.0.0"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"551544e796b8e618a107958baabc7ff26b3d102a","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"homepage":"https://github.com/thynson/kafka-pipeline#readme","_id":"kafka-pipeline@0.2.2","_npmVersion":"6.2.0","_nodeVersion":"10.9.0","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-GrF6B7ADXs6IoTLsGpZGke/0vhtCI8Lopzi/bbuRh765QbQK29EoBF7qRZFywil4ISIUrnocIOFxHw6Lhf5hQw==","shasum":"967a77a719f054601325c28f7ecfb05a942d642d","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-0.2.2.tgz","fileCount":23,"unpackedSize":65885,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJblk9eCRA9TVsSAnZWagAAoR4QAKTHONucH/wwxygBicWP\nDDC5/yxdHGVaX2OGPXAsaQJwLoVMr/0Ww/m0fWgP3+wjFj+0dNr3ieQRQczx\nS9EACnEDEun0S1bnhXVolZ+begW6dpkVhB2ycs8UOYpNkzLUD0/wIoz0d/Au\nPnboxks6jeVM11DW5CXAWFy9M4+/MBvOzipBKuqhsfI/VEzB5nBoL/7dAefq\nPKzuP8RMtTEuJCcX5I+4LwZ14R2OLmpvBl8GxrjSppBNPrguSNyTIIfX5CVz\nuFQuSgS4URXkdBwIuPSapXC3HBZwny+WSf4d/uvFHHJXu31yTkJuDTUGJtRu\nTr+6pOxd6jn+KdmRnT+N142qWL92yABxXYsxlEmDB/88F7l1wtkba+AH1gSc\nZNClFPdE4ipFZp1nMrtQUuTpgeLPnsD9msU1xQJ4IRJmYirNBbSST45LUBlh\nKdj+MNHVmS8Ic9ZbdTCQkLv2w/IMWTRYh5wF2N/K+vV9jqlxNnJl85tTWBg2\nO/DrFS9tYkKw5noU1QHTXXy7a29lfYXASoFi8yw9EZohnIojaQdB8cEe/bci\nsAe1QlVENsZo+XhzTCevYhnMY+g2OFGDOHYtRIMDYac8EWMORDpziAp/yeCP\nPFh9tikA2Jlhs22TBDCnG9ek9ZLfnmAx1lOCm3g1yEnHDzwMAXskKPqhII8f\nLmvz\r\n=gj/L\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCRe3fBZB5vtT62xPs8WOgeaZLuh3rZrSjx0P3tW5FxTAIgKnC5GWU/oG0XT3r8OiePUg5NCfYNhjXhS25y2nRfJkQ="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_0.2.2_1536577373187_0.02718863848594011"},"_hasShrinkwrap":false},"0.3.0":{"name":"kafka-pipeline","version":"0.3.0","description":"A robust, easy to use kafka consumer","main":"index.js","scripts":{"test":"jest"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^3.0.0"},"devDependencies":{"@types/jest":"^23.3.1","jest":"^23.5.0","jsdoc":"^3.5.5","kafka-node":"^3.0.0"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"7a820742acc154575d8b04847397f5d1b96faca5","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"homepage":"https://github.com/thynson/kafka-pipeline#readme","_id":"kafka-pipeline@0.3.0","_npmVersion":"6.4.1","_nodeVersion":"10.10.0","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-aLs8lcgqQNM+Fk3wPOhgUX60zbiaeJCLpMeYUrH3e9r3+2FM9PyMMoRc66j9H8Hz6cQONa9CdMSFhUowiF5v2w==","shasum":"d8f9a141345641aa5035fcb1103dc834b1ed3ff3","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-0.3.0.tgz","fileCount":24,"unpackedSize":66403,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJblyO/CRA9TVsSAnZWagAAzE4P/iARxhNxPg98dGqELk0P\nOSEdPiKK2zripQopHrZFqPtJzO/nT3G4iae5KS6ACBzyln0A16VcxuUcGpRx\n3K9kvcozwzsdb8LRfXAhbwiJXehC3dNcEMAaqOBuwTKgfQJYp9M/WopcoFaO\nOv6eP6vCY4j6rRYFS62P1CIFtlvyyul4aw3Ys01wunPJvx2CVHSHfxSs5Vbh\ny/ZQ34j1kfS0joEt+47dGaICNMjYJV/cVoboNJvbiQEWZdAprXcpe27oZNkF\nuy5CYYXVjHy8R4jnFYyWnk4ow44skRPsVjCenk9C9gwFZ3g4O4/ifhrxYDNU\n+ofGtkVuEPnPltMhTbV+vnlzoE7VeKLMcPbHZ7J3UbqVOWePebuTptDNVmqx\n+/oYLlkJoSXPzbYBgMMusyY3dHF0JjZeYVAx0NblrvUyuU1i5a2cWrRE07TF\n+f3CVdNkC7lutOy3wjhrGFPc3s03dM+nxvVVQT9tp5TO7EvON8DmCuBqXgL1\nt4DkTvMUOvwQflH3Um2PFnjLRs4nQPO1PfqSX2xABlKItiCGtVs3oKf13Mxu\npQTXVFSxSHwgrTkvJNRYsz5phb5ThieIOVDrpSAHejDHtmYbaL/SrduhxoBH\nJQQfKcGh6IGf4iKVwsC1GUWlf+pE8xqZp1V1ruxonhzr6+I8QdPtJlqX/D9P\nzdAm\r\n=l2dQ\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDXfF5g89oUCVy2K8cbtZxmpJO3SuRgoDFKnRcZ4Cy+TgIhAIQY9TV0npZhDq/Orxe3sJiNu+7XuEq3PS1YJ3Yb+SG+"}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_0.3.0_1536631742521_0.7217570124545956"},"_hasShrinkwrap":false},"0.3.1":{"name":"kafka-pipeline","version":"0.3.1","description":"A robust, easy to use kafka consumer","main":"index.js","scripts":{"test":"jest"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^3.0.0"},"devDependencies":{"@types/jest":"^23.3.1","jest":"^23.5.0","jsdoc":"^3.5.5","kafka-node":"^3.0.0"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"4d8dbce6e8bc871995d8fbff7adeced82ce8887b","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"homepage":"https://github.com/thynson/kafka-pipeline#readme","_id":"kafka-pipeline@0.3.1","_npmVersion":"6.4.1","_nodeVersion":"10.10.0","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-PspsIk+/YftjTp3JX5TZbgI4ITFrVJe5TYQt7l6HQBSQvRjJLn8XcsyHdD+Guld9QKL8RoEXDjo/6GL55SpyUQ==","shasum":"81d38db429f0a374521939c7cb6f7703b14bb9fc","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-0.3.1.tgz","fileCount":24,"unpackedSize":66354,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbl43aCRA9TVsSAnZWagAAz6AP/iyHDILRsAb1NGszRMWM\n8kURkCe+yzTWUcwqBRxRHfS/PvDuCJHBmqBFvb52oRUJV8gFPQDJ3pVwiK65\n2K1wAu4w967MDC4L35QG8y+gzmj5net8BJt6JxqbN+f3rFdFUybVBfZjswZs\nZLGpeSRyM3U2DjnilBvMw1a0MzUOBA6ApT3buI2cZQ04GF2yVcs+AXKHuBbj\nZ0QV0PQGr3c9CkSjExtp8njQPM3u5i7B/kZt+OtzVfyXbeM5kqYy6eZEZXH3\nWlVH12RzHnW4uY7d+WRwqLW11FJDFdBsYh5HxGGlv1T+92R330W/+vuUDXrI\n+7Nluoha9R2XDzcrm6V7yrQO7b+uoS6OMyui1dm7ALENGBa54ogeaFHQkZZ8\nXIHfBQDY9/RZ60UgJ2s81ZImdns8y8Q/wKKwMZQ5Tg4uNFnJyZzyB3at50ee\nF8xVFTTbHfArS2QzDHYgh8TwRLkU/9o4sarS1lOrwuQJcx5Ixr7+Gp0l/CRC\nb/gS8pppCeUQ8UsAE7GWo9rby4lCxRobyYE+VgM9s5rZJHHYuuiG0i76UGEM\nCT8EXfmaH/48wkCMqoftZeK6sYxLYECNaa89PlmrlpckTR4NU5vi0yrSNUto\nAJU6WLIfVEeBcSn4/JqpjsGV8ht236uKwXD477xyj5s6Mo+QYhfXvmC+T5rp\nw+zf\r\n=YEHL\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD873KuEBgC8FjS29Zp1k3nIwHFEmXg7Bt97zBEnlmZ2wIgdNo2U8jZPr8Ij5dJ3fLnFMUpDzq3Bf63tpU57LRGYIk="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_0.3.1_1536658905815_0.014185699999907708"},"_hasShrinkwrap":false},"0.3.3":{"name":"kafka-pipeline","version":"0.3.3","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"index.js","scripts":{"test":"jest","postpublish":"git describe --exact-match && jsdoc -c jsdoc.conf && gh-pages -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^3.0.0"},"devDependencies":{"@types/jest":"^23.3.1","gh-pages":"^1.2.0","jest":"^23.5.0","jsdoc":"^3.5.5","kafka-node":"^3.0.0"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"fdee5a4693202c6932a7134ca2e905b42cae74b6","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@0.3.3","_npmVersion":"6.4.1","_nodeVersion":"10.10.0","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-DVpzg/zS7VrYo/1Hd2uQGGm7pvwoM8dCLia8PYGeUP5rCP3gtQfZtqifbhiJTH4zzw+VAFwZ5Mvyk3KIeHL+Mg==","shasum":"d4b066fb809cddf00ae08c2031ee74bd0192bb13","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-0.3.3.tgz","fileCount":13,"unpackedSize":34613,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbmix3CRA9TVsSAnZWagAArxgP/RnlYP5KXutRaJvQs8gX\nTD7AIELeSVJkwtuhFsK8H+nKBb/pRDyX0XdQ0n0gM6FhtA21ECXtbtNz3Egv\nIY5myGvVrl26vSHeDuuiD/smzHNzSugCxzfzNqbQpSQ46Bwe9sI4mHBCRdqF\nrThExGVa/zKUtCENByx0oKeEmcyb7fSNQ8ScPEwqtUtYAge/h/9Usnaynijf\niMz64WHUODv0u/nRgU1scgCvq3I7dXGfD6D2W/7mCDLOYjyzCQ0Iwo6TLtS7\nKoDrxOQXmGD4OoGJycbCgXH+DdkBUYm1VrTMEpGPl8yAHhE5i8LxCBaJtoC+\niAVAHhxHjR1sYP2FikNQTldNFmXW3M/x+sfUKyqOTQ838M0aiKIwNse9d4t5\nnSwH+s8GKjeqw0Ri1lMERbiovJ6MaJvyIuM/xP+O77CuYQxwL5oqim7gKRoK\nAdP8QBuRGuMUXn88Ns2Mi8/1Sh6MfIxm7vyxpNo/PlYXZzINuZpHv6gqxcV8\n6XIwTuLQC3/AdDfaJs42YOEHS5PPqeZaRwJWc9AkNO3lhqz/wya4/8Ukp8Mu\nbi6SvMIYcUUGJ4FFaUuqtLsBqiAIeoCQXC6zhkU7yxo6tMbxB1lcg8zia+H1\nTSVIeQq6u+8gyYJnjNr/9uFj73u8p8Zy0nTE8K+uva26RVLQjXWRdJ0GiPkD\nE2yM\r\n=3cZ4\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIEKCn7WZ6QLtFeK5wKcOdkpR6s/44ra9cD/2auUgEl/oAiEAj2PehK3sH7UgVG5ehJgFwtNVvMqv3ZyX/wtY7WI3U68="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_0.3.3_1536830583252_0.7170573941907454"},"_hasShrinkwrap":false},"0.3.4":{"name":"kafka-pipeline","version":"0.3.4","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"index.js","scripts":{"test":"jest","postpublish":"git describe --exact-match && jsdoc -c jsdoc.conf && gh-pages -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^3.0.0"},"devDependencies":{"@types/jest":"^23.3.1","gh-pages":"^1.2.0","jest":"^23.5.0","jsdoc":"^3.5.5","kafka-node":"^3.0.0"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"62b3b5fbba50c863190f260e47beac329490548d","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@0.3.4","_npmVersion":"6.4.1","_nodeVersion":"10.10.0","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-n08pELpUweB8QnZaV9Zb1PmM8wv2HGbfkuIAv1J/dL4vxj2H5SDaQtpHhZKsVMi5u4IHIm4hwjacoUp6HoKiAg==","shasum":"56cf380672909a21138d04fda7a408db92db7ebe","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-0.3.4.tgz","fileCount":13,"unpackedSize":34650,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbmqkbCRA9TVsSAnZWagAA+MIP/ifik4Y/4dFLeEEEhiwU\nHDTW5E94ZlxJzBFzg0bZZ+3jk4/HgR1g+pLe/ygye42efsW6pU0LFsD0zJ53\n/+mwc5VLQTdXU/gwg6U4m9bupaRBOQ49gsaAorlxxtxkoCsc6QpqEE+yoFAz\na/y7tKFMJCfddWd5QJwurK6/yvMnyJnncLp6FbcW4oQsOxG3opjWfHJlxVZI\nMBuyMrbSWTnoLc44dvPnV23/iCy0sRBcnTGye0Y7d5a5MVUxYsPmAekVc/zF\nq15rsOal+edTq+3Yo++7qIFEwRUwX/Y63sq/mGABjYHd/zOpRWZmyK21SRoI\nNWYWeMP4DI+RjZWRXz1BAiGHSxXDalYnZd5149Pzjja4Tvwl2VSZ2JRv9wes\nUKt8/JR/Absy/8jJwglz3x5dRKqlGwz3sVrITTK2ZS4t9MhLIdD5cxCoTF64\n6/kJd8UiqhsXhhAnMdR4pV5TBF25v6Q0CxNQYPfrZtfEIrnV/cJI0C1xdLG9\naLaCKiZbzSdEaA5/RsKx3X33d4RD7LVBsga4Vdu0DtaocRxHHTc1nk8eHS/I\njWgND+dP3xIe7WMk9k7yaqEsndK3tZxlOjPUtW5mosYkkh/uhj20JAtEy5Is\ng7BVOHME+iT42SyyqGvJMCac8lSFZ50KB4I0kdrR8JX5m8gUqK6WdgPN3S2Y\nLdLq\r\n=1SyT\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDZZIOt3vW8zxVGXUbpxV9mRpdi+2EZXRya+gzi6LLSggIhANBXH5x3/CYwc+psXBpZNs3rCzhWcu/ZNl+zmkpoiLJT"}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_0.3.4_1536862490643_0.4839349029633526"},"_hasShrinkwrap":false},"0.3.5":{"name":"kafka-pipeline","version":"0.3.5","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"index.js","scripts":{"test":"jest","postpublish":"git describe --exact-match && jsdoc -c jsdoc.conf && gh-pages -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^3.0.0"},"devDependencies":{"@types/jest":"^23.3.1","gh-pages":"^1.2.0","jest":"^23.5.0","jsdoc":"^3.5.5","kafka-node":"^3.0.0"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"1eb1bda17d29a35a78aec5273d20f11a5e43c44a","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@0.3.5","_npmVersion":"6.4.1","_nodeVersion":"10.10.0","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-hXjmJmAeCHyeKWIWoSYLLdFgth5vAuWesZi7+EzGzxSSSDamXuuxSjLMWoHUJA1Rplpcr73yXSYW7nBYFBH/GA==","shasum":"ec878539e743c0d02deed16fcfda8a58b0e84c74","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-0.3.5.tgz","fileCount":13,"unpackedSize":34647,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbn146CRA9TVsSAnZWagAAWtwP/1n85m5xYvdAo7+9aJT2\nQzgbXNfzbquqsBt3CKRiBSbAicV7BWaSBP9n9/llJVA60qVKqMMqdPGCxl8v\nCwxPbZP+TqsbQWPhct3cywZz538SFah/rGeLNBUDTFl8RDdsI6YNLz2EnIw8\nv95u4QxcFNKvuYrHTAwkDnLT1O7BFlM3ohD3rQAKshewgIiSpiiuwomg1w8W\nBpMkVEoW7JpRhq9OB31vFa3gB3M106uD99zmsMEwM4kTtu5v7jIomOJtaisw\n0ABOtduQ2sc32ora7pwL1aS8qBsSuIvXRedQgS5p7INEXFSE8vZ3N0SyO4/q\nNy34YfIUZqVhFc/tv21QDD12d/0pAL/4XIJ6JH26oJJxso5xczRvEk7B96s/\nJVNxDoQ70ZfyoLsnvY9OSvhfwfhFlcVDGHnO4nuKBMXunJqSNeq1XOxBocgm\nZ3Hw46gJwO4cy28h0mKVf6/kU6vtVd6jX8RMQqmD4rfmuyVvRJDK3J7yUPl1\n66uQwtfFCLu8IDr0Hd0XZPzjpddaoxeAtK4p2uiB0F6rtJB663Elg9RLRUun\nnxxr+LC8wWQr9tCb1cEX8gB6knHkva7B4bVjel2Ode0ORoqBn7YA+jnUnDz1\nTvDBlkOY5FAUZj+YKSXrIM8gaNFKht2l+4FXSWK/anPFsGzH84sZ/zXlQUE7\noMEA\r\n=UZkZ\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDec/Wt8GBFUdv3vIZmOGRJDIZWULTy/xyPjClvn2WPaAIhALda4998FkxzKWjqoiQqNJHpqMQL3lJpuqppW6Ojl/Kz"}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_0.3.5_1537171001388_0.8542235791421164"},"_hasShrinkwrap":false},"0.4.0":{"name":"kafka-pipeline","version":"0.4.0","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"index.js","scripts":{"test":"jest","postpublish":"git describe --exact-match && jsdoc -c jsdoc.conf && gh-pages -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^3.0.0"},"devDependencies":{"@types/jest":"^23.3.1","gh-pages":"^1.2.0","jest":"^23.5.0","jsdoc":"^3.5.5","kafka-node":"^3.0.0"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"66cea8775314a955970b02c20776d572435633f3","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@0.4.0","_npmVersion":"6.4.1","_nodeVersion":"10.11.0","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-42PSSMMa4a/7ishSVVxv8PfzAbNqm4nO/Ezj94ijro/ddrb328ntqZn4ANRVkLBbMHsepip5pPFI19cNjck8hw==","shasum":"03ef434d285128680519229ce3d7c48f0727e308","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-0.4.0.tgz","fileCount":13,"unpackedSize":34863,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbvFnvCRA9TVsSAnZWagAAU2cP/1ZPYwaNdS1GHp/daRJH\nNgItaLAFUsF8v4uojFfcWB3ds3NfgHuag9PA74YS3PILtzYPdJsMx1x+NINF\n3oScH916wRqabW57xqYN2RTMfmqRHwIG+KqboWMNmJj/1BaXshxEmh/+Qtu3\noNqiyW/cDDWie8FmAvwA/LWSni7GpVMUOWubx/V/FMuSLyBVaBpAXQBeTkHd\nX/L1qJ1Y1+B4Gs3QJrTxuSjHUi6evy+3y/mA+fiUhIqtS1gvSQg1PHG8atot\nEYKJkgpb+g5ugi5kIff7MwpIQapmKxTIikZ5i7lfxv3L92w8wDxOj5Pg707c\nBKQVi/Bb9bd3Yi2rVl9wZWlxCnNhaNAUzOo+Q0KLKZFEdlkaZSLGoqUrnsXE\nI7iVGICLQ3Z00JYgZwjbmnaWoBqb1+9s3dqwFD/+MgViQ9AKkKuPje+Wz3+z\npEf0qhm6UoyF7UDp3flSktbh7Cp5QPAs6Yr+N+22MDzG6LBAEFJC0qZP0fEN\nneobuFnLkxEFtgl8JIYWW9ndizd/zfqKqw4lJdR31H74kc7k612BGC2U47gv\nuxBwHLFxLptRM/xTk0Rmg4S0xKB3FXgurrw++sbQ4pA8WhVeQtx5n0ruDPa3\nltTlyexTzvsz4zS5OHyeWTLUI+/mPck/rk/Usw/bGQGLZ/Msj8qfj2NCrYn9\nqWcf\r\n=jiAn\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDlykLKZGtv2IZhZkV13ryDNAFotodsP087XxDYIEKVTAIhAI01qe9aD/BvT5cyCvmNlyRvoXifyP3eVHr+DZaTHJn7"}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_0.4.0_1539070446866_0.5539292599504091"},"_hasShrinkwrap":false},"0.4.1":{"name":"kafka-pipeline","version":"0.4.1","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"index.js","scripts":{"test":"jest","postpublish":"git describe --exact-match && jsdoc -c jsdoc.conf && gh-pages -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^3.0.0"},"devDependencies":{"@types/jest":"^23.3.1","gh-pages":"^1.2.0","jest":"^23.5.0","jsdoc":"^3.5.5","kafka-node":"^3.0.0"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"53dea5063ebb7e02c3e7aaae5da9b587e1ad8e10","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@0.4.1","_npmVersion":"6.4.1","_nodeVersion":"10.12.0","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-B8DOZJTHzeR4cp4JNG0HadSt+L083gD0vCMaHqaFkcA3XyBsefKT+4daWRSFVEW79iCiLdjTu/ec4CAdhrKtdQ==","shasum":"a2daad64efdc9d2374d813284c4bf8f649e9af87","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-0.4.1.tgz","fileCount":13,"unpackedSize":35020,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJb0op8CRA9TVsSAnZWagAAps4P/jlIgGG8glo4WE6XgrDq\nIo5xs3NU7D9LyQYOPa9ycFsj6Fy0Eo/I+nA8z09TsEKwo1WgRXJ5p85nvHV+\nJia4gy1FNyOmjdpB9kBIBsPtXFRK113jf4TZJYe0GSS5HbcxXltwTXWt4Ryw\nFqb7JYp1HxMSfu2DeJ+ADO5o+Nmhw/S/F/NZ8NMnJeCSN9DPhy1CDVHU+SRe\nLJRCe4cjWO4qZEbQ9pA+VoDdAWV1dpo12O/oaUgN4V++RTnP5w9VLvYktt/i\n6hSmWieELtnQRXITuED2g5LijV7oIy3N6yH5n2OKZoQtG7R6ERMSMxtYij5b\nwpI5CiE/4Uo9RDnEbM0Kac6BXfrPn5fmGQaozG9SRNsFHF4sGegpwepzqs7N\nOXTV/qIwd8A+KWWnOJqdy7jN1RapAoy3SeT+EUpAJ3H9VP9hhvHv/TLNy2l7\nHbS/VDclAxqMk5rLvcIRWWh2TvRcXLzsM6ZLb+l2cWpbcdGl8BRGQoqWWxx7\n7hXBCdICRr48kooFMv53LpHlkcmBbnJhDZRPegTEImeLTlAKm5DRrJh6G7Pt\nKQ0XPcz8467+8VmxE0cc1sLq0fLpO79X+yJZSHOmvzURJ/WakT2a8bZpOZnc\nzMWiMfU6S9Zc2pZCKQjUJ0ILqTpMCzjtn6I8BSBcglAXC+dJ6YtVvFMNswcl\n7kV4\r\n=ArSJ\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQD7dBDQEpVswrqkKpPZaF+8WXosit33RhObXu57z17I7AIhAPdQwDzAxcJrYb1Wb/KCZQtyl8MvVGoB3/2193anQIvd"}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_0.4.1_1540524667799_0.8014047145958347"},"_hasShrinkwrap":false},"1.0.0":{"name":"kafka-pipeline","version":"1.0.0","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"index.js","scripts":{"test":"jest","postpublish":"git describe --exact-match && jsdoc -c jsdoc.conf && gh-pages -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^3.0.0"},"devDependencies":{"@types/jest":"^23.3.1","gh-pages":"^1.2.0","jest":"^23.5.0","jsdoc":"^3.5.5","kafka-node":"^2.6.1"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"c22816855413684d200da3c8d4f8c05599cd179b","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@1.0.0","_npmVersion":"6.4.1","_nodeVersion":"10.12.0","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-Q9RXvnNdnqdo7hqCREdTMNhZB/wQB2fixKU1IezZImhzICRLtb5mK7THKNAiLjTG5OrzP1oZAIi5fUkuAZGv8A==","shasum":"4f32fa8048c4c6fc32f3fd53e3f216332b662fc6","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-1.0.0.tgz","fileCount":13,"unpackedSize":35021,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJb0q//CRA9TVsSAnZWagAALgYP/0Qfjv3Jg9nV43h+zAhP\n0Tf7wnEuT3LwGckER7gXCjwLvUpfHdKDgNmw3pqby0QUEFJGyx0epoupIoYP\n/f0ZTThAqyP2Ud3MD8Vpn5G9phP+yExQTJ3FTyRv3/pPuBjQ0YbAhv/mNQ/P\n0N0OMA0bb+HFubk5l5LdWii0TRznFI9rZlhiW3FNwxqEmHK/72srzJAV2dCJ\nU7Jz1FIcy4eC2M4S1m1kYEZ6ZMnU2N3xLKmHCU5BJw4wDl9meJULWLouipbB\n7qee8bAOnSS2G1NFJD8/tIUBL1h8OWlvqOWRZ8bjk/k3thP40/hQAqGQoUCk\nuiwvyzICuCSGVAy2LfjuMNJdIZgbx10M3jZ/IwKfOnauMbBU0KVZgKJaKBLS\nFlAl1uy1UZ01t8K3yZsTZtAVP5S3/DYJQBAvgF2pwAUqTtkAOaDWeyuX6xLK\nybAQ1KJfbjZWEhU65AD/Iq3ozV8INANtlfPbAvxpZNQzviyH0ydWuY4Ve2EB\ncrgnwTiPrTNlrwQtxSTW9m9RW9OHD68Ftx3IoIH57hA9R7XqgRsvUjqyoWub\nf6yzGZUq4uNpxi2osAkvEi/XBE+oXXi/fziKurq5pGvayBCasyEkcLQWQOYr\nCZX61dgGYq3pnT3jHyqkub1SgTJvUyTPqKbItn+cDF2QtIL4V0ShloPgePMZ\nc9Fk\r\n=0GoE\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCq0kwcTsbncqJpgkS4CPcfYYawnexSUbw88NTQ4lOiCAIhAL+9s7SLsQoNTbUEzI78HjH7EoSx7nrIHA0O+Ud4CqaX"}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_1.0.0_1540534270573_0.699454517735711"},"_hasShrinkwrap":false},"1.0.1":{"name":"kafka-pipeline","version":"1.0.1","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"index.js","scripts":{"test":"jest","postpublish":"git describe --exact-match && jsdoc -c jsdoc.conf && gh-pages -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"2.5.0"},"devDependencies":{"@types/jest":"^23.3.1","gh-pages":"^1.2.0","jest":"^23.5.0","jsdoc":"^3.5.5","kafka-node":"2.5.0"},"dependencies":{"bluebird":"^3.5.2","debug":"^3.1.0"},"gitHead":"93eee03f1e764f3182402ec355485c0400d989d6","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@1.0.1","_npmVersion":"6.4.1","_nodeVersion":"10.14.2","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-tIg40zdXCEK0P2v8ElePIblrUXpW7tVm6MEOvOcrlw2/Xug+0BAkbAfFg6FSVad/2zr+aa8tLmivbt4hOGM4nw==","shasum":"3964d91b89d7fa1554e2c2a2bc4d8937068abd2c","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-1.0.1.tgz","fileCount":13,"unpackedSize":35019,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJcGMXzCRA9TVsSAnZWagAA3RgP/02HG/yv+SPmHczo2pOU\nAW+WZuy8+L8z47P9oHV8CBu1nxRRIM4ncPR4iI+9adftMt7P3Nhnjj+mzEaV\nOEo/rfHqdtEFJtaNDYUDreBQeyCmRAt2u4LhE0w5AzKGueFKs5Nn5hF1crGQ\nE8PpXo99W8w446wHeWeW9ScGPYTgrSh3ibWmu1G2W+JCxTihyY8Y5BYQY7ge\nsVCVu8CoSSXRkuA3WYeW0CEBfYx7y4vNZn0VInSu7I9yeVAVQ5XZxLWrYvyB\nooMRBlEYWTqVYyZIzpdcE1MUKT/qMNEX2wFkz6kDZ4G9o35+80sUjtT/OShY\nSFXuxK2Im3ZKLjogiGfOGhHrYEqlhSgSFc/ULs+2swFBV9QaCfJbaxQODIqa\nQLZqt+vWFnTG0+sB073YhboMhtAKf0gtjXjxUfiF7JyxeDypm5OiqVHYVWwz\n9PRyLZAodtcxbzf4QjDjYcA7knZzpj3v1mmG/kHxursSnRYD+KNVeAzc6iXK\nWTN2kCUJKHaBgZgL/VRijJPeFToFqqhoui1rYAYZ3CBIw5WtC/8NSnGj5K6P\ny0zVfkIYHt5wjx0A7HEj0OIpgL2u79VCi6R/lkQMteBoumCmK1KMjtkH2ahy\ngxOuHqrtvacXTZi8J+cXvth8qVe70hiFYhtWrbxUf2n+Z57WrwjJfDg3gJdb\nRkmR\r\n=SKxC\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCID0L98Jslg6HE33zNX+BGQC5jgldNkoV9bIokcQ2m/YOAiA/ZcEeznFhlIeszBG1JixiI1xfK+EVmksNQDlnOT2w3w=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_1.0.1_1545127410352_0.48674867168411606"},"_hasShrinkwrap":false},"2.0.0":{"name":"kafka-pipeline","version":"2.0.0","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","scripts":{"test":"jest","postpublish":"git describe --exact-match && jsdoc -c jsdoc.conf && gh-pages -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^4.1.1"},"devDependencies":{"@types/jest":"^24.0.11","@types/node":"^10.12.9","jest":"^24.7.1","jsdoc":"^3.5.5","kafka-node":"^4.1.1","ts-jest":"^23.10.4","typescript":"^3.1.6"},"dependencies":{"bluebird":"^3.5.4","debug":"^4.1.1"},"gitHead":"5553ae066f82af3b196cf4fc8dcea30469e91db7","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@2.0.0","_nodeVersion":"10.15.2","_npmVersion":"6.9.0","dist":{"integrity":"sha512-ArBECzPdwItRW3yEe87/tXBxEBM7uHm1urNfY4uYdqGS9XT0HA2hhFqfnWOoUcGxR/OoFiBLgEmcBufwXuFsig==","shasum":"155e213247b8008e831750687c3c2dcab3b9f1ad","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-2.0.0.tgz","fileCount":48,"unpackedSize":125060,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJcto6vCRA9TVsSAnZWagAA4DcP/2HOgUgX7TruOAM6SrAq\njo49e7oZI+YAv7i0DKNRlAC2Z72UiqRZuGv2eBjdHulrrFM6lzasRDpOpvTu\nwK7mpa27skk9Ui3R6sK7eSvQRymrxSrl3duX5e3ttcisnZ1HhFQSX40dS+Dg\n22kX1o3k6E9CxRLIGYFr0xqxxfEy+eKISjFQ2TyOV9UuPe81itDBpaYu7B7r\nddXVQ10U/0khl1vhcMpUx5IbRTiHQZJT5VoiIeXLnZotJlwTkjtR0zNOTKeI\n53IRKxpbFdmS61IPPoiVMAhr9+mca3Q7ou6dghi7ixY1tqOlzzmHpsRKwtPo\nUysRerE3rOzsaohUtXD6oe/zBDd62mtW+TweOXmR9PUaPQN8amBPM5Jyco87\ncrBMXvC2kWONbk948QJ3+bQENPc+vVV46ExqTKjskQANb2MSMqACRSRj56wF\nDDzlqjmQfMP/3x9x827uFkdu6edTYf0waZe0Uk9clXBHHfb8gncBGCtNb6/z\nYnT4SIt69Eb0o49ZtX05GnYAR/8kraMBLyq0hj7bgFkFNfNmLfVFVqRFLOwV\neWjismsZZcODpVkeGii7+kplvoJYtyJKYwEnH5WisCCZ4ysg3jeAKWTrwgCq\nQ04FAHKoeIfn5CZEwbti7bWP+QbBHHTgD1/el14GPtQQU0uCz8ay5Ua8KZpI\nkgpM\r\n=6NqK\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDvPDFmD46sOOZMDh3gSIS8CpIVOYdQz9wdndf2oT7pKAIhALDUwNgFMmmsmsGOj3/DekZV8rRLLXEQ1zML3wpEFP4M"}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_2.0.0_1555467950249_0.01884445816755176"},"_hasShrinkwrap":false},"2.0.1":{"name":"kafka-pipeline","version":"2.0.1","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --out docs lib/","postpublish":"git describe --exact-match && npm run build-document && gh-pages -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^4.1.1"},"devDependencies":{"@types/jest":"^24.0.11","@types/node":"^10.12.9","gh-pages":"^2.0.1","jest":"^24.7.1","kafka-node":"^4.1.1","ts-jest":"^23.10.4","typedoc":"^0.14.2","typescript":"^3.1.6"},"dependencies":{"bluebird":"^3.5.4","debug":"^4.1.1"},"gitHead":"c35e9d85a5537388d52978a71bdf162a9d0c215b","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@2.0.1","_nodeVersion":"10.15.2","_npmVersion":"6.9.0","dist":{"integrity":"sha512-mwbRgrmUjp7uJ5hZoFM6odqF2wuKwC8bFcLBSAbKW6LzNY9lYJVntbgQx+DU+gSYdX7sGvUg5hrcqsYkHAsmuQ==","shasum":"de6a6e66622f1221f2ea4ee564da494cd4a08394","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-2.0.1.tgz","fileCount":66,"unpackedSize":193951,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJctu5YCRA9TVsSAnZWagAAVegP/1m4ph9NOkOD+Z3By9t2\nitEJk/K5pj9ufas60u9KeX7GCujnmcGzQnwlhdcnZfBKyywsSS3dE69lOWDw\nJQGi1VHo4+R6MB4iAl7xa4tWWiHw2x5ka1xAOhQIkC+RyprRI7RsWQY+q5Mg\nChlv56XFUmlCP1otPr5IGLXUCiDZNACOBHEN52/zYRkTcvF1k/SQ+ksKRmuo\nTNlyTydanEO3KQXtSmM1tTXaLbnwUYEmtTewG7rWJL/2GUMWEkxevONrCtHt\n9V6HMnBJAPEcS6ylCbWR7VBVG4wcdpOqHCBv0lFhYPicAXD/D6MRdMvuFFHD\nmHOgleSXaB/lKwB5bgTPCMOpmsYWassfyyWQ/ZNYuU00SY5nGzoieBTgKFpz\nJVWuh20ZsxsZvPJmzN/BtkRhE/wrgT6jHs5pCsXlSL/GihnQCiJrewzZJfqT\nobJrmSI5intfHyE7pmgTqW7kGVZxKib6rl3xLHjbmyQXaoZXEIrxTeRXnG7m\nF+37G7KHs6Z5XXFbCv7fIncLv5n5n7p05raIJ+8IS2gjs0zrSpz7W5fAdNfT\ni3wGRGJ5iSx3FeIKvfLWH8i+cjKJzmgHQynudsn1mQXZaiefTD2mfuGTs0C5\nK+cXr1cTCpwpxuHDD5nCZWE07nOctFQ/vwwWDbRDQwgitD2waxZN8JWF/GVw\nUgqT\r\n=Qkpj\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIHVOkxvybzbGd4nNVntj/XtjuVJ9JVcEDXNcpb5S4yaAAiA5IWHclB56fZSB2ocvJ3ZPEi2HSQBVnVGqAB/qMrhIhw=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_2.0.1_1555492439928_0.6500826393272867"},"_hasShrinkwrap":false},"2.0.2":{"name":"kafka-pipeline","version":"2.0.2","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --out docs lib/","postpublish":"git describe --exact-match && npm run build-document && gh-pages -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^4.1.1"},"devDependencies":{"@types/jest":"^24.0.11","@types/node":"^10.12.9","gh-pages":"^2.0.1","jest":"^24.7.1","kafka-node":"^4.1.1","ts-jest":"^23.10.4","typedoc":"^0.14.2","typescript":"^3.1.6"},"dependencies":{"bluebird":"^3.5.4","debug":"^4.1.1"},"gitHead":"d28c5e8e85c3f4babbca5fd6b26340ab7f6a1050","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@2.0.2","_nodeVersion":"10.15.2","_npmVersion":"6.9.0","dist":{"integrity":"sha512-TrXz304RkOFNM4LUW+D+VdMZW+OS0igLOTVuAcy8qR2JajgSE2zRwooEk5M+AmdnDh1xcTYtl1Csbl4d28NOSw==","shasum":"b089d5c74992e589e504ba59bb23ae7f2f0dbab6","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-2.0.2.tgz","fileCount":66,"unpackedSize":193880,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJctvDuCRA9TVsSAnZWagAAUKIP/R271D7Cgd4Fq2/lBi4t\n6m4VD4y0Ks4lpK4SItHK/MvnC31CxWtZSnn8yXMhup+tEqiWClY84keVI2MO\nl5XMJWC34LBxT3Gi/CXXDZaMvFhWKF/eK00rsfGZ27/L/OGZfw4Iv2gNNUo+\nQV5EzERVl5L7F4+lU6MdL4uHy0Nxng9/OV9VKnKCbf2wml8hNlE0+XS/VF6h\nwOHQzxa83wIL/+dTrPC8mhNcouXDH08fy1+xinlpFdiynn1OZhHfXeJlgFJ+\nuRso3oZzvsWjrkG8HCyBvRyrDpGTz71/MnH2jxwv2bl2lbc7vzMdT+enY2m2\n79soQrt+hdQYL+c2W3UbrIPbwulSa3JKrxg/j8my0A4NBpsAo9orSrShn1b/\nBxw8PssIOB3BTiZ7z+KBEt3ovH2pkiZfW9i6h4iAJnufcKVPLWF7csBKoD1I\nchljPB1XBnBPIEvHFLdd+lJCw8L6OAiXpvCAftl78Hmq26VLCNTnJJWTNkct\n4R9v9b1LNCvcqW24TKQ2dTexIljnwL6UfhWRpjUq2oVuMytQkJYxNp0qHusi\n3KMctU3l9PCXhUzrMKuF2raNtXOd0HDdUGpuekCOx+ittI52HXSdIfSZT4XJ\nHf7yDO2Qx/PZsH1xlzuTVmoyVLvtOYGg7/Het55EO2C0a7e/zz0S7etFxiGX\n+i8H\r\n=NkB0\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIGRGWw3E0Z42aGZD5tTgc5bwFsZeuf3T8y5vJtV9etDmAiACTVdOodzx8OpHVppQXgUSJgm7bU0d1NGH05ZelqRlOw=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_2.0.2_1555493101833_0.5346385644302585"},"_hasShrinkwrap":false},"2.0.3":{"name":"kafka-pipeline","version":"2.0.3","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --out docs lib/ && touch docs/.nojekyll","postpublish":"git describe --exact-match && npm run build-document && gh-pages -t -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^4.1.1"},"devDependencies":{"@types/jest":"^24.0.11","@types/node":"^10.12.9","gh-pages":"^2.0.1","jest":"^24.7.1","kafka-node":"^4.1.1","ts-jest":"^23.10.4","typedoc":"^0.14.2","typescript":"^3.1.6"},"dependencies":{"bluebird":"^3.5.4","debug":"^4.1.1"},"gitHead":"23ba680ab91e0aefe55375eaca8822d3b1eff70b","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@2.0.3","_nodeVersion":"10.15.2","_npmVersion":"6.9.0","dist":{"integrity":"sha512-9JoGxLo8raA5YQeQMXgG9qddSUNS6N+VC89s3PWOCPpi63TMZI9NgfuhnraAgBYK6qUW4aiBjdysAV4E2N/Ipw==","shasum":"87229b82aad34dc84907ce65b9f7312c5e074e1f","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-2.0.3.tgz","fileCount":66,"unpackedSize":195442,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJcutrxCRA9TVsSAnZWagAAFKIP/2U1K6LaTubjmiM/SRqc\nuLTZmndDt3eXWhQLfyFQECFxM223drzDKvqACiLezv4xPhuKy9pxgSGX5swG\nGh/qlaDZbBeMyL2IV6aGmyYMU4QP/4PnBnhxOh3ruYiSV289aNeJ6IWq0dZ0\nQVAqjSqeJjKxWBERzWMzxmRmt6Aid6trsGGaUknmvKZpYwcqYk4PhOWl2Ogx\nVIOIW4d3cBZSBXaj+tOfdIYc/jSMF2gPNESb8xYoIfix6aUq1N/5iPbtRvF9\nf8z7XlhGryv2W/NtcAYrk8cPJRAKI8kRraktHkLt6B+TB/5haim2DMHiY5aV\n7Ji5WdZ55CshjWQE/B4NMZxcUqz5h2u3MgsHpeZB4IFOVLuZ3oypN50ijau7\np0e/FK0hPjbhKysYsoxrtM8YseBv3Nw02CViwgaNonHWlwIZMuH13FB0IPsO\n5Sz5SrlCjdtBicDalkRVRKmnZMvLUJw4UWsshhnsBP+1jEwD51OcxUNcsNXN\nmNNchby+5b0dFh2ZM5MovNtx27M6Nxe8IQt4ljVtoxLBTf3TwfJBOQVl8l5U\nRxweaugshQ9+krJyWh/pWh3/AgqQpOBumxXZSSFIuEkGlB8FdYQp4AgIhwiq\niJuTiDRIZqNS991m0aKkYt5w0Pd2+aJ7XylQE715+P9+ZZkPDyzYLqFeWxkc\nQ8Jm\r\n=6f2b\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIB5SZ8LdQiRshDj/530yoaTUdDLCxPcaqhnYN2V1RYYQAiEAsZ+hytzKFRuHk9TlQ4tqdcb8bfKmrCMr+WETpuL9nyQ="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_2.0.3_1555749616180_0.6925408178601278"},"_hasShrinkwrap":false},"2.1.1":{"name":"kafka-pipeline","version":"2.1.1","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --out docs lib/ && touch docs/.nojekyll","postpublish":"git describe --exact-match && npm run build-document && gh-pages -t -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^4.1.1"},"devDependencies":{"@types/jest":"^24.0.11","@types/node":"^10.12.9","gh-pages":"^2.0.1","jest":"^24.7.1","kafka-node":"^4.1.1","ts-jest":"^24.0.2","typedoc":"^0.14.2","typescript":"^3.1.6"},"gitHead":"18b8b286b76b4fbe75ea76afb9ad3d592ac555df","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@2.1.1","_nodeVersion":"10.15.2","_npmVersion":"6.9.0","dist":{"integrity":"sha512-80Y8E4MB6dhyXodhyIsvAk7dBR9pTTPEqtOYwdDzxKcuoqvWVHUoE/861mH+jYkKYw4KVksp0bbTf7tQfD7x2Q==","shasum":"175ced44224beeb61e0564a1af86aa900347b060","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-2.1.1.tgz","fileCount":66,"unpackedSize":194827,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJcut9pCRA9TVsSAnZWagAAgIYP/3XhvB+IKyLP/9zR/kS3\nYNH2OFoyirUdcHsInBjE3aOkXZo5PnsZ2GwF1/ZQloQFaAW3n2Zr/6FMV5nB\nMkDHaw4HZVHXzB3Qqw9lWN1OECIqGYk90SCdyBorJSYtMpUx4dIcB7UfPzl5\nvZoeC/TcTzWKNeUVrdLHndJElf1pEU+Z77580KwA1uqV0keRGnLoRd9N2BDk\ngY+GTDQo9OxQGxitKSKrPv9t4y+pOAJOHFb5EF9zB3N7IQu+8iItBo8Yqh9k\n6VzAVXDozdF2pw28ViPzSpyudxpofGGzbBNY6DuZ7RqdjqLUW2UP5FTwjwkQ\nXH8vp1+7Ho6a4F0T+m1bh1OyRM9fiLXKcKVHjVBZEY1SK6prw32WtsZrzVPo\nsPXsUl37UwnQ12G6vBTlfsQs1C9itNAijUpWU6F2k3NYhfHO0pXFrouQofp7\nREIKiR6kGytPu0Rjq5y5YIkfpyPaZJO7nTxdc+4F+FU5aIA6MQO2g7jxxv6x\nEjRfR0OaklOUk2qC4/1ZiTORmoYd8UYrS6Yikf+pXLtbKINT2HB4Ld65cGu0\nPc1G9bOBIs2WKYpM27Cn2pRwkfp52cOBxM2WnEcXDq8l1ZQ8LKt6zCAbANBM\nLDVoIzgiIdyRFV8j26IzfwYCRWFIDtenq+0S9+IGWsiHaZq2SiuAoGvprbDa\nHZI5\r\n=bmCw\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIBNCG67Z7V/7usqD5+nFsIDLFhJRfp9fypEU+TuWtezGAiEA4BpUeSRbiphlCTox4U9uvtyC0eCiGkakH7BDa7I54y4="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_2.1.1_1555750761278_0.2204057186717443"},"_hasShrinkwrap":false},"2.2.1":{"name":"kafka-pipeline","version":"2.2.1","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --out docs lib/ && touch docs/.nojekyll","postpublish":"git describe --exact-match && npm run build-document && gh-pages -t -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^4.1.1"},"devDependencies":{"@types/jest":"^24.0.11","@types/node":"^10.12.9","gh-pages":"^2.0.1","jest":"^24.7.1","kafka-node":"^4.1.1","ts-jest":"^24.0.2","typedoc":"^0.14.2","typescript":"^3.1.6"},"gitHead":"b90e4817e88160ba1a75a22f3da065d15fecd601","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@2.2.1","_nodeVersion":"10.15.2","_npmVersion":"6.9.0","dist":{"integrity":"sha512-8FMZ9Dj0aTV3j1dOc1cgVOOplsIUAq9xa76IfChhTeBTQyN73nF/PLO9DKGqO87v97d6QpPuw+cI9skF/nBR1g==","shasum":"44e4a2d609ce0873f2fe48b804b6934ec302053f","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-2.2.1.tgz","fileCount":66,"unpackedSize":194997,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJcuum9CRA9TVsSAnZWagAAUkgQAIMhEA74eNhqY3HV9d5J\n3CLKntRO9N5ZHpbLgJByzz3tDgAqf+G1vZRiFoCoxcjrvX46bsiMq0gYGRBn\nkW1/bIxR4AOE7HVlgMbtQodUbzuae7Ko4CPlHGoyfseYceCt+nxFzPdsXBm/\nlJ30k8sS89U9ukQ3gbYmK004oTf6DVWH8fB/3RS04wO6yDY6XjXPGPGedG7T\ntTcMTZx4Sn7FnZOvZrVM87PA6zgZw6Mpq/nJlAm4OIVtSM/deUBOFeC7fHCN\nop/nLGrEtf4sqP1HC/8l0aL6UGJFXioccYWv/509NfUmKNtvMZYZdY7mRhsV\nKoOKeLwFvGb/5YEPXNbV6g0RpD0syzD5LqbjoaZ0+yPfHCXi2TGtGKN83nuZ\n4KL1gwuI0c3iuNB/BX5OCxvEqAoZO9UuxwEHbIQktBPeUuEdNpkWLOhPqbNt\nCTUFCwwFdI8wB9pMkjgHIyd1J5XezWRIYXWYwqtX5iXdm0aM4utYEZO+h6pL\nhP080ZIUHro8nu00KRuLIXWv933WYXIn2tifqWY8YcU6eFHp3a8kzywNX2hq\nkyLPN0RZm8NBGi5w3WnBQWXN6jHix+qTnRL0K5E5hIqjeAtUELP2XpJPY6sw\nYpOr5Nby4rjQjv3NuNOfHpcsrgO4eCcdH5x11VDTyoPEMIuW3qAkQNDrXICc\nNw8W\r\n=ikii\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIAzbKvCdasjw5YFG5tp8YvFxKG7w3I979wzUFI5eutsFAiB8TGxSxE27EEd9Hzl7hZVReO4erhbrTL4nrHAy/3KpOA=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_2.2.1_1555753404688_0.49294877017503214"},"_hasShrinkwrap":false},"2.2.2":{"name":"kafka-pipeline","version":"2.2.2","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --out docs lib/ && touch docs/.nojekyll","postpublish":"git describe --exact-match && npm run build-document && gh-pages -t -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^4.1.1"},"devDependencies":{"@types/jest":"^24.0.11","@types/node":"^10.12.9","gh-pages":"^2.0.1","jest":"^24.7.1","kafka-node":"^4.1.1","ts-jest":"^24.0.2","typedoc":"^0.14.2","typescript":"^3.1.6"},"gitHead":"15a29a14b52efe9a272f23e551727532b9090a69","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@2.2.2","_nodeVersion":"10.15.2","_npmVersion":"6.9.0","dist":{"integrity":"sha512-TGm0gkia1MG54rBr1FHwvHjfX5D5KtBMJwKuB4YGkJP5gK0E6kiNWrX/3D/JgBwhIJqiBSv6yuU4PI6THXLqTQ==","shasum":"053536a07ac5556f3b73f79f1cc0e838875839bb","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-2.2.2.tgz","fileCount":66,"unpackedSize":194829,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJcuvCyCRA9TVsSAnZWagAALJwQAIVDHUirtm03SaYA/7oZ\nJKoGBKquqnM2+FzFqDUzHk9TojEekESMXNjrW4J+cF+EjAgjdZVBmqnj+WON\n52TiYBF1Y0n/0hFx92VkF848zqHBP6p32gCuuMNZhheVZAcC+sTW0w9P6I9J\nxbC2bFXcYS1fihMizOhIEg9hh36XOQfRB0Q52vUeA9Oe8d6lsNJecoR8c0en\nx6fqFB+lD59s5rrWnZDVZShuyKxhmaNcu132RULyGgr0bQCzwa7y/bfMvFWp\ndtrz2j927Hl71GoD1F9mgM0wBDfThc/ENjBoAhBVR3pkwjXtIyxp0Am+iHy2\nZtxc3okCPMQOyNmnLPMPisUVr7gXPVkt18dL2RDKxt9LiUpHPLF57yv+ez9r\nfGHJPS/DcsvWSjODbH02W1C2Ra1gC5naW6qu1EiPbGv8tce4MaSfo2L+4OlI\njNw7Pa2YB5uXoYEAUNHbqWLzyOaD6SbN9dCL2DLENHScHjKMOs9jC7o2FQ0r\nUiRF5NogTLb2as8cixmJFogMA/5bHZ1gEjcsbaL7fDVnGC33Yr6nyzfmB1BI\nySpD28IU56ftxO4oLuGdFIvW0+Zxlg35lQujKtpW/CPXBzMZVeblOZ1Z+3NB\nL5WSszAMDiL6M1YEWO/dBLX1g2Vzu9+GNfZl0eHumzifh/ew6wphMHZEWRPr\nRURV\r\n=EVW/\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCNRMwCGK68vbug0zXqVwizIMPMxHm0YRYW7AW42qlsgwIhAOWfmaAyNcN8RNfJDZQIqf0XTkpe7JpYl3/DN6meTomU"}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_2.2.2_1555755186082_0.25536234192281304"},"_hasShrinkwrap":false},"2.2.3":{"name":"kafka-pipeline","version":"2.2.3","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --out docs lib/ && touch docs/.nojekyll","postpublish":"git describe --exact-match && npm run build-document && gh-pages -t -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"^4.1.1"},"devDependencies":{"@types/jest":"^24.0.11","@types/node":"^10.12.9","gh-pages":"^2.0.1","jest":"^24.7.1","kafka-node":"^4.1.3","ts-jest":"^24.0.2","typedoc":"^0.14.2","typescript":"^3.1.6"},"gitHead":"e0ddd106d777199f1a243b92b207d308b30ff6c3","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@2.2.3","_npmVersion":"6.4.1","_nodeVersion":"10.15.3","_npmUser":{"name":"thynson","email":"thynson@live.com"},"dist":{"integrity":"sha512-ryly/2sbOHBWd8+BYS7xVEGSrG998LKOs3k8zKDwElmbWG8PiWOh9MRKIaoPwP3LT+/66vHtHwDpaQSZNDa33g==","shasum":"0774bbf30decde01245e4e36de1b492bd1e4e6fc","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-2.2.3.tgz","fileCount":66,"unpackedSize":194891,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJc0uaUCRA9TVsSAnZWagAAOu0QAJQE687cDO/UtYL4r08i\nBkFqt3rLCusqLjrDZ3b1KGV0jjOLjVoqTp4/yAFCKmhxCn38wyfKgbsgVIOl\nC6e93dWpGaeciTpiUDxWM7PjnIlIGoAyoxvBoboUaOZFVc3ESZFaxF666qzE\ngtz3kbnRZsjhlqmiOgvXLNQivwXTlncfCtU6BJ3Oui9Z0iVnBagAGeM19elt\n1AXs8s5h8unCr2EubY6vU+iGYnRl7pihbOM3aEzq/SN7hGQ5yS4SDAECLFzG\nqwVp8AGKIGBj2D5/nnt5vPE46DQJfYSK6Jw2SzFOILNpEaF/3ggGn7oBaUi+\nM4V98Tic4DkHnbFldfjAS+5+pRtXflPxAuCvwzUmhQOm1yxp6a2iQ2NKmVXJ\nlZkuHb1Dpb2rBqyEmD4xImI4VNoTfFXUIi5PBDDXKd+JDYs8TLkgWEyezSrD\n3aWsG/gEdySnN2WE9FfzYWYlqxqMEIb7TUZa7OkhMnCQxTiiD+Hp6PiQilt6\n2hCJiFPXegYS592MqVVockgTum+ZeCJzyXhvBI4CW/nbRQJHawuw+stz8jCx\nVRGNVkvwOmpI1VLgBqH2WYgy4+HILmUNJ1yNRUORVCwN0o//cUCGBJu5NpZo\n2Y0YaWvGjj2F4l6gngl3CEJcIDqSWHiMZcYqx0h2eufXJc9CC6ewQlR0k/W6\n4iy7\r\n=G0XA\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCpbj21Uyv78nMvuIRazjsxHWat2XDaxCJ7o9scp/lkJQIhALz8fLpp9hgrS5EnZs7ZlK5vpDaUcixs1siI0lK33b/r"}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_2.2.3_1557325459234_0.7730669627186935"},"_hasShrinkwrap":false},"3.0.0-0":{"name":"kafka-pipeline","version":"3.0.0-0","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --out docs lib/ && touch docs/.nojekyll","postpublish":"git describe --exact-match && npm run build-document && gh-pages -t -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"git+ssh://git@github.com/thynson/kafka-node.git#803555ebb0a774d53a294995e9ef97dc07ac60ed"},"devDependencies":{"@types/jest":"^24.0.18","@types/node":"^10.14.21","gh-pages":"^2.1.1","jest":"^24.9.0","kafka-node":"git+ssh://git@github.com/thynson/kafka-node.git#803555ebb0a774d53a294995e9ef97dc07ac60ed","ts-jest":"^24.1.0","typedoc":"^0.14.2","typescript":"^3.6.3"},"dependencies":{"bluebird":"^3.7.0"},"readme":"# kafka-pipeline\n\nThis library provide a robust, easy to use kafka message consumer based on \n`ConsumerGroup` from [kafka-node] that helps you managing message offsets \nin correct way.\n\n## Design notes\n\nThe basic idea behind this library is separate consume progress and offset\ncommit into two [Transform] stream, namely `ConsumeStream` and \n`CommitStream`, messages will be consumed by `ConsumeStream`\nby invoking a specified callback within a specified concurrency limit. And,\n`ConsumeStream` will yield all received messages in the same order\nto `CommitStream` when all the condition following are met:\n\n1. the message itself has been consumed\n\n2. all predecessor message in the same partition have been consumed\n\nWhile the `CommitStream` remember the latest offset of each partitions\nand topics, commit them repeatedly in a specified interval as well as the time \nwhen the consumer is rebalanced or closed.\n\n\nWhile this idea is originate from \n`ConsumerGroupStream` from [kafka-node], it's buggy when you try to use it\nwith offset being managed by yourself, which prevents you from implementing\na reliable message consumer meets guarantee that each message should be\nconsumed at least once.\n\nEven if you don't care about at-least-once guarantee at all, \n`ConsumerGroupStream` duplicates a lot of message after rebalance. Although \nyour apps need to be idempotency when handle message, this library take the \nbest efforts to minimize the duplication of messages, unless error occurred\nthat prevent the offset to be committed, it shall NEVER duplicate any message.\n\n## Installation\n\n[kafka-node] is A peer dependency of this library, you need to install it \ntogether with kafka-pipeline.\n\n```bash\nnpm install kafka-pipeline kafka-node\n```\n\n## Usage\n\n```javascript \nconst {ConsumerGroupPipeline} = require('kafka-pipeline');\n\nconst consumerPipeline = new ConsumerGroupPipeline({\n  topic: TOPIC_NAME,\n  messageConsumer: async (message) => {\n    //...\n  },\n  // A optional callback function handled messages failed to consume by \n  // `messageConsumer`. When error raised in `messageConsumer`, \n  // consumerPipeline will be closed if you don't provide `failedMessageConsumer`,\n  // or `failedMessageConsumer` also raise an exception \n  failedMessageConsumer: async (exception, message) => {\n    //...\n  },\n  consumeConcurrency: 8,\n  consumeTimeout: 5000,\n  commitInterval: 10000,\n  consumerGroupOption: {\n    groupId: GROUP_ID\n    // Properties of this object will be pass to ConsumerGroup\n    // except that some of them could be override by ConsumerGroupPipeline\n    // See reference of its setting at https://github.com/SOHU-Co/kafka-node\n    // \n  }\n});\n\nconsumerPipeline.start();\n\n// The following code is for demo purpose only, not suggesting you to do this\n// in production code. But to avoid message duplication you need to ensure your\n// app will quit in a graceful way that await the promise returned by \n// consumerPipeline.close() is resolved, which will do the final offset commit\nprocess.on('SIGTERM', function () {\n  consumerPipeline.close().then(function () {\n    process.exit(0);\n  });\n});\n```\n\n## License\n\nISC License, see `LICENSE` file.\n\n## TODO\n\n1. More test\n2. Consider support HighLevelConsumer?\n\n[kafka-node]: https://github.com/SOHU-Co/kafka-node\n[Transform]: https://nodejs.org/api/stream.html#stream_class_stream_transform\n","readmeFilename":"README.md","gitHead":"8bd1cd46f1af993530e9040a81aade66491e1d7d","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@3.0.0-0","_nodeVersion":"10.16.3","_npmVersion":"6.9.0","dist":{"integrity":"sha512-EBW4Q6ZNxDqSVWhJ0CB6ne820PMeT/OgrxVTuEg6TzzGZje5KwO5A5hvXXlUVZobtFG5e8X8zJXOWZLxJm/AKw==","shasum":"b1d4d994b31b1c734214a78a8ab5daec4c6a210c","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-3.0.0-0.tgz","fileCount":66,"unpackedSize":200487,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdnfAjCRA9TVsSAnZWagAAWdIP/iaCFNU97d8l2uHTABeB\nrU+egmwzlY/CAVaMxRC2f825LwaROf85BNolCx28SitQFqu5WufNVsPxFmQE\n3UCu0bC4oJUbYmVyhmaHdCLGzObbLZaYqPrAMNqTXlzZMsT5MQHAJmG1SVOL\ne8wLWLq04kNSJzbKK6czdlG2jaaan5/0gn1phsCHzn3kr7qJmCP82xyNX72B\neNqGWKHwq3FvGb24Wd4qMutbzatBrcCNvetupYnbXKBslqbBkgdvmft9mqY1\n7VEv1EG8L5OaxFKxL7+1Egf1wM5MeS43FnHER7nq0fPBOW1/4ztOLpMPNBjM\nVupn6n9WyHcKJQhkSGlTQnCxr0Mco5FbuNLYTbn7z72wJ21CysdVc63XOwZ/\nbypPPP4rQUFt6xvaUxdXRBd5g9kjRxShAt1IHT2D+nrkuTCYaWiMpscSTDma\nBMJAMwHhFro80pD36lim31fh+cbb2EDJQq0wcM7vxxc0xhuE19Ic0WURt8CD\nLbmaD8PU/q2G4p8mQM+DQuEePNhpInUwid/oXDOKJlzZk1ZubxxBhsh6AVcD\nJ4Tn2Uu6W3GZQPq+BashQJ9K84e/5jd5nQ8oR3Cc/Khf/puVm7lc0iKccgrZ\nuyZDFNJpPZ31J8TH5sxnTfMNyszSwJkFVTfRUGsDn0rrtKxGhgUSngxNdxZC\nIba+\r\n=2tQw\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDxjPDIaX+5/I5Ah/8gKBRLvd7iw2y+4IwMvX/k2KOqUgIhAOSrVHVrohMqYwKNBV7k/dXAtY9WwyxPJOfD+EbX7g9K"}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_3.0.0-0_1570631715271_0.793780305382279"},"_hasShrinkwrap":false},"3.0.0-1":{"name":"kafka-pipeline","version":"3.0.0-1","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --out docs lib/ && touch docs/.nojekyll","postpublish":"git describe --exact-match && npm run build-document && gh-pages -t -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"git+https://github.com/thynson/kafka-node.git#803555ebb0a774d53a294995e9ef97dc07ac60ed"},"devDependencies":{"@types/jest":"^24.0.18","@types/node":"^10.14.21","gh-pages":"^2.1.1","jest":"^24.9.0","kafka-node":"git+https://github.com/thynson/kafka-node.git#803555ebb0a774d53a294995e9ef97dc07ac60ed","ts-jest":"^24.1.0","typedoc":"^0.15.0","typescript":"^3.6.3"},"dependencies":{"bluebird":"^3.7.0"},"gitHead":"f3ecc270a01f6c02a06ab9ff56c1dacf178b8bdd","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@3.0.0-1","_nodeVersion":"12.12.0","_npmVersion":"6.12.0","dist":{"integrity":"sha512-0W3OB/Y5/zaQmHvSzPlUV0Ry+VaJCeYsczxbxL7SQz8P4KDVjR4dFDyjjhCJpHWZ4PU5mDUXEizXfPU80GnTeg==","shasum":"c716920da7ab9cb52dd09f2eae71bdc808c3df0a","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-3.0.0-1.tgz","fileCount":66,"unpackedSize":200247,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdrbZjCRA9TVsSAnZWagAAj7kP/igSpIbVPtXF7llCp8qv\nK2A1qP0C36RmEHzn4wlH9BjH/BCj1mWpF6lauuvX79kRrQAyGwKvbH5z2lh9\n8BHFlPjYI26BYkpTUKsK1D08Lw71Xj+NyozjIDMoxSA/gW7PaUm/tMYHcGI7\nTUgMreIviOMW9GS+U16CmGQ3UMQG0Dlx9GsQNwyrrgoi2DqNXfPgjwcfIYJl\nbFD+29wM3h2rSjrGdJbcaBACaImd9ASX28n1p01zCfE92bKNHQLdDudfdeGp\nUKI1wSQ1xyqGWA1Apyw9u/aFN4eXLgq55CfJYcMH28vAtyJkxkhe0pdnmAjq\n641qEamAA++UM80D7JVuWxywa6daeYb2xF4+Gg1w+pyXBggE8Drb0I/ofG9k\n2hH0wsGLIlGGQypIIxYv0+fxkHoYUfNGz7BtA81VIKJ0AZCzDO1I5eDz2O/6\n/eyv+ILR7dKUsUCqUjDHxOSuv+YexzkcCTXs6OKp5JvIl9GMe9ZIRWcf1HMx\nT6oICmKl1FmKi+SiHNRwB0RD1kOVJ+ht459NqNwZdK8DZZzZBaSVSpgL32B6\nQVsGNo7liwSQQJPWP4ugqwzV2dXiIMfSH4OFVl3BIYbYaqEdVazoh2WaUJuz\nFAIk+Ed9/TOOvVLhtC2CRnX1ieR2RmaUVUWvNhOR/hnigle4Pgobv3XCplab\nta0f\r\n=biwc\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCICYM9OBM8M00KGRjqyHcldDjBuA4Jx+ZJoo29IJATP8WAiEAupakIU85qnu0Ke7aA/o5p3PG92Y+eZFZeTwWzxzsucs="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_3.0.0-1_1571665504253_0.8440577057234091"},"_hasShrinkwrap":false},"3.0.0-2":{"name":"kafka-pipeline","version":"3.0.0-2","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --out docs lib/ && touch docs/.nojekyll","postpublish":"git describe --exact-match && npm run build-document && gh-pages -t -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"git+https://github.com/thynson/kafka-node.git#803555ebb0a774d53a294995e9ef97dc07ac60ed"},"devDependencies":{"@types/jest":"^24.0.18","@types/node":"^10.14.21","gh-pages":"^2.1.1","jest":"^24.9.0","kafka-node":"git+https://github.com/thynson/kafka-node.git#803555ebb0a774d53a294995e9ef97dc07ac60ed","ts-jest":"^24.1.0","typedoc":"^0.15.0","typescript":"^3.6.3"},"dependencies":{"bluebird":"^3.7.0"},"gitHead":"44059858c072a1f448b339afa8f31e7e4b19368b","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@3.0.0-2","_nodeVersion":"12.12.0","_npmVersion":"6.12.0","dist":{"integrity":"sha512-KMGcmbNyH8tak41zwA/Axebo8ix/24P9jIsfXPBeLMPymGmPjm883CAa+hTLh60W8UQqJrJUB6ILPmrxRVzUjA==","shasum":"12c43fd40b7c0d342d155ceefc028b1060313d6a","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-3.0.0-2.tgz","fileCount":66,"unpackedSize":200172,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdsC+PCRA9TVsSAnZWagAA6xYP/2kCWXYq5M+nXA0BN7OO\nu9HBhZhC31FWDDPYROC/ptcKiNsCHAqTtGfB0kjpC+e3mTk98O53lIOfr1Zp\n84ktyduZp0uO7eCb/Y2UFSbEbEjg13q54Oy1Q8U30Dzqn5gBNs2EJPl8OoLH\nqqOVg/PFzpN3GYOU3ajqNsjftDrMB/6cQxIcC67dqmOPZlfA9zt2u5aLtrip\n+w/aViw0Z3W3m/V4TTASLwBka2MmMF4pUv35qVJ9YrVC3hiVQrtUkQna73nb\nJKaAzcjlW/TVwCoV26USxX2ISIMKpViLxy4xLVEses2ql8d+jAplkiJw4RMB\nXwS8jliwg7Wy8rmDdbzuZwprR+Wd2o67fDHRc3d5JKVt2S2/3ewk+lgxXPAU\ngDTOLm+xRBOuA2YI9mp0UaLtzsAnWjiJ4a2dmInEttmrQ7pjAsmxADHrIhtz\n0KyRD8ews8MczXYXgcEPt4anO9/Dzm279mZ6s8rb/7Bqx2QAIr+8YyScA+Up\nLyIfB6+Fq0nTHypsjuiznIkDqFOEXIoKESM6xMsFZDtuDqZA1TlgHC4kFgym\nDkv6HJTnaq7iIPFPKA4Yle4RCVy828sJxBvp4JCY0z6WNL9l8Pnt9KzwHOkE\n9qpCvtkB++nKchU6lpu+39/a9OG1htpbDhOVFp+wmXa2IUJVXtKzFVoqSSmg\nZiTW\r\n=Y6x8\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIHHVyUm7W6e8YY0o8Qxt6y7TN9jnM6iJw8mllnXxT9VMAiEAnumEVGmpL4Ijf8QGNqy04TFzkhLihlM6eY/47gZPk/w="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_3.0.0-2_1571827599248_0.12934045901414848"},"_hasShrinkwrap":false},"3.0.0":{"name":"kafka-pipeline","version":"3.0.0","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --out docs lib/ && touch docs/.nojekyll","postpublish":"git describe --exact-match && npm run build-document && gh-pages -t -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"git+https://github.com/thynson/kafka-node.git#803555ebb0a774d53a294995e9ef97dc07ac60ed"},"devDependencies":{"@types/jest":"^24.0.18","@types/node":"^10.14.21","gh-pages":"^2.1.1","jest":"^24.9.0","kafka-node":"git+https://github.com/thynson/kafka-node.git#803555ebb0a774d53a294995e9ef97dc07ac60ed","ts-jest":"^24.1.0","typedoc":"^0.15.0","typescript":"^3.6.3"},"dependencies":{"bluebird":"^3.7.0"},"gitHead":"32e9134d56fdfebbf1cbd8b1d6fb18702664e4e0","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@3.0.0","_nodeVersion":"12.12.0","_npmVersion":"6.12.0","dist":{"integrity":"sha512-HGt4danZNQ9WZbddkdBhCzr9biiYxcaZ59FggpJtINqqPssaNBh8oA/JUhhpVxj/Uekm8mi4G5RTiCbXBr/HSA==","shasum":"8e6fdd57bac3b790263c865c1df2387a46e1f613","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-3.0.0.tgz","fileCount":66,"unpackedSize":199895,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdultXCRA9TVsSAnZWagAAn/MP/0+XunJxi2SRYRko0Apw\nHiU2xCEAbdDL+Wc/O50cdQCgeyn1C0AsrFwA+PT+wpp21bcQZz0pEoPVsbhA\n2BbAsfAq8dxgXnRGWckfk4xr/QNT+ml66j0hQee8uhiuMQM2O7a/8NGerU0N\nJmQ23n38RbvRTu3k/ThbvAlkbAQyGgXLTB5LgQxBlh/0oLTqCiYMwYfU1WI4\nKuTPEyywlkXjOzFT2KhTZhWMjMIWDzi9tpPdDSujAMBz4bbu8TPLjOtfAgf+\nc3ZgA2CcU48LeqnTIYdhrcKXfloNP/5GAVUCozU+ivSB4moliVLOOwagQzQG\nPCOyTuSnKayU9heOhEIm0PJquxGeESdZp9JHTMe3GddYSdD36pSSZz5mBT42\nrkXkdAieDsq8waME3CrCaMoFrOZpkKJmJ4n1ZkAn6+7plsm4Xh5q8lbXhaZL\nQOxxMN5J9Gx4n66vlgyx2hGQJJkU5SiqAl/vYL8zyZRM7mt8H0I6Jir03K76\n4uqBKrrd4mcCvDrCZXn+mKBgZ36C19FkZzx6HiyGAn3RJ4iBHjeidCl8/+4u\n0rfm3bTKi70OuqKnahqSuF09QgthDzR8tfewQuGFUdcf+3A1CAO3WnP7VLbw\nmTSBJpPitXRXkq0uFnqUnuKliIbReBi1/buszqq008MY6rzcQblgu/GzUWe/\nWPsl\r\n=wuzs\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD5AXQpvQEcjYp0ydaPf5naCWQyTmpfc3//BZSawhUefQIgauZQI2dmJLZfvu/HQOjD9OHI30pyXmazMbjmxJ9hm5c="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_3.0.0_1572494167092_0.9996068141316841"},"_hasShrinkwrap":false},"3.0.1":{"name":"kafka-pipeline","version":"3.0.1","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --out docs lib/ && touch docs/.nojekyll","postpublish":"git describe --exact-match && npm run build-document && gh-pages -t -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"git+https://github.com/thynson/kafka-node.git#803555ebb0a774d53a294995e9ef97dc07ac60ed"},"devDependencies":{"@types/jest":"^24.0.18","@types/node":"^10.14.21","gh-pages":"^2.1.1","jest":"^24.9.0","kafka-node":"git+https://github.com/thynson/kafka-node.git#803555ebb0a774d53a294995e9ef97dc07ac60ed","ts-jest":"^24.1.0","typedoc":"^0.15.0","typescript":"^3.6.3"},"dependencies":{"bluebird":"^3.7.0"},"gitHead":"799dff24b630e11235dfc8303832d1f7a7b8d3e4","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@3.0.1","_nodeVersion":"12.12.0","_npmVersion":"6.12.0","dist":{"integrity":"sha512-oI2VYPK09mXi9mA4X63y5rlaYTmWmFj8iBhq2M6MnNUkNdxFZi7p/QHkn9V35uxXKq/N4YzAfe2zImz2OxMAHQ==","shasum":"e9c50d616607257a14260d50825f5c69da35015d","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-3.0.1.tgz","fileCount":66,"unpackedSize":199885,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdvT0gCRA9TVsSAnZWagAAvJ8P/3NOMye6S4hXiMmsVh5k\nnzguU0M69NwWKumP5Gb7jkEY1HK9XVbx4NQntudcb0q/QCatm6qXjl+9IXiv\ngv3IMB0YRDGOqDj0Vcl3n1a53dTT3krgri5W1E7JX/wARuw22BQw1mnERIVO\npEwSjoFZl37I8M+DZGDsCHKP74MOtBdFY7mLMTgV+4CnKf7e8osJXJ3Txrap\n+roAQtqACqOR43zgMs7J/4RL53Ul1+tCEwXqQ74kVxgp61qe2NF/qTecUd7x\nVpbFWFd94RT6iApC6gEfyO7Iqxc79iPow/QKUBolqIzH5SODf0FPyAfpjIKu\n3v5Rq92tuhfnMcVueNbz8BVPEfFRzRgtC0xqnHwHf90mx3zL+CZX7i3UJY0i\nuCpfQ1F/EmglDrnHMkeuZW1YnNP1/JJQMrMD4T51OCuuGQSpWceLkAQ/NO8X\nIuxTcEl/WIEEHD8CiH16xClbHart2MTY0JT/ZPNyE89SKCYB9NibI4TCwbQ5\np4Cb0ift0V9SYwFzF3bVkfNcWcxa5BYi1GmN0HbpydPoVV99mjnb/PqjVBr6\nDv/2lUbBJFD+hTTMCpKX41VJtecRXE4DrqRKSj1Mr/yFHHdzABozbMhYQFe7\nMcdfulvYNHsW34JR6eGqPixgkntNPnbEQYqGYHHhRZh+46dOy3mptE0Dj4LV\nWhSV\r\n=IfBy\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIHLwQSBYLmA/vLJ7FrA9hhQSn3+20yS7VbyaTxA9iSqeAiEAhu1AJ/fZuUKIo0NI/hsUmgkVUwgxR8oSK4xxF5SU0jc="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_3.0.1_1572683040267_0.008207021562611327"},"_hasShrinkwrap":false},"3.0.2":{"name":"kafka-pipeline","version":"3.0.2","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --theme minimal --out docs lib/ && touch docs/.nojekyll","postpublish":"git describe --exact-match && npm run build-document && gh-pages -t -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"git+https://github.com/thynson/kafka-node.git#7fd49714142c37af33d1d9c392f09eec5cfc97e5"},"devDependencies":{"@types/jest":"^24.0.18","gh-pages":"^2.1.1","jest":"^24.9.0","kafka-node":"git+https://github.com/thynson/kafka-node.git#7fd49714142c37af33d1d9c392f09eec5cfc97e5","ts-jest":"^24.1.0","typedoc":"^0.15.0","typescript":"^3.6.3"},"dependencies":{"bluebird":"^3.7.0"},"gitHead":"3a1180de1de661c964d134f6f588be45406008bc","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@3.0.2","_nodeVersion":"12.12.0","_npmVersion":"6.11.3","dist":{"integrity":"sha512-Tlzu9UWPd8x/VE0Me1rCiOkSmXRWYT+Jge8i0cuCpKyK5eJCA5ccTn3p8tPo2bX9bayLhIFvcGYGCIqK/Dv/ww==","shasum":"4d104e4fcd5412921fe4eab1fc6c053897f6ded6","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-3.0.2.tgz","fileCount":66,"unpackedSize":199869,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdysCqCRA9TVsSAnZWagAAGQAQAJnXg90QDmecxc9MKxGo\nmc9ugPwOtqQnRc3pf7YL9Apnqzmf6TY2K5vikVegcAwote89XsjXDG+mU97l\nJOBGUDf2HjCRTjZNc6pINKzKZwdJfCCKS9YrbIs2ugxSvBC8k8BPWZaNLZhj\n6W0Y8QlErZp1/l7LYUx9V5kcHnoED0v2KL2prImBmsD7YfYNqdCB9KuEJWFC\nwmrBKOhUYl0wnJnHLgkdEoZ9hD+eknjv0+9jjNFutmd8eKNKcqyfmU+fRq8K\nI/zVfO/Tl1Fv6CYJil0+eBEIwko3lIBpX7Emmt40hSmlFkvUh/GI/Nm7Zaw6\nkqFcodnwAliaIaAm2jiwUC/jdfH4t+HW67/2ZxZ+9NClZotoZDpgRTfl9pMQ\n6AHvKvlg58tmzny5Xb8EI6K5Y/5T+7wO1saAdrDDUowNRKTPtTbqt8tmYgZN\n2twgJKPolC0pDXqoZFHluGD547NPowMH6Mt1Aac8d2ReAfo9KcNCqPjJxLu9\nbWiKDDz9NjwZB647rA7bzcWP3Kt+cFSIrNxODJ/sL5s2DfcXaK3qbHhlUYeZ\npqHC8vMXobBcV3u969tYnLwiw8c6ecoZiTRL2Z9V9CJbzUaqxFw42hgozh3M\nZIdLbTYaZccTIWZq51m+h/bOSpCeESlxVgkW9+mF2aKU20WYO4A+AkFWkkP5\nX69T\r\n=7iT/\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIAUAIf5GJoziLMKCmyg0LR9heUrpTAixWWdMB9uk84t8AiEAwyFCN6z8cbxQ65/824fmd622Obl546w6mpTOn9mKYQ0="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_3.0.2_1573568682307_0.4828023055408712"},"_hasShrinkwrap":false},"3.1.0":{"name":"kafka-pipeline","version":"3.1.0","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --theme minimal --out docs lib/ && touch docs/.nojekyll","postpublish":"git describe --exact-match && npm run build-document && gh-pages -t -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"git+https://github.com/thynson/kafka-node.git#49800b96b7d27a4f6226b138253a6fd8c1f842c7"},"devDependencies":{"@types/jest":"^24.0.23","@types/node":"^10.17.11","gh-pages":"^2.1.1","jest":"^24.9.0","kafka-node":"git+https://github.com/thynson/kafka-node.git#49800b96b7d27a4f6226b138253a6fd8c1f842c7","ts-jest":"^24.2.0","typedoc":"^0.15.5","typescript":"^3.7.3"},"dependencies":{"bluebird":"^3.7.2"},"readme":"# kafka-pipeline\n\nThis library provide a robust, easy to use kafka message consumer based on\n`ConsumerGroup` from [kafka-node] that helps you managing message offsets\nin correct way.\n\n## Design notes\n\nThe basic idea behind this library is separate consume progress and offset\ncommit into two [Transform] stream, namely `ConsumeStream` and\n`CommitStream`, messages will be consumed by `ConsumeStream`\nby invoking a specified callback within a specified concurrency limit. And,\n`ConsumeStream` will yield all received messages in the same order\nto `CommitStream` when all the condition following are met:\n\n1. the message itself has been consumed\n\n2. all predecessor message in the same partition have been consumed\n\nWhile the `CommitStream` remember the latest offset of each partitions\nand topics, commit them repeatedly in a specified interval as well as the time\nwhen the consumer is rebalanced or closed.\n\n\nWhile this idea is originate from\n`ConsumerGroupStream` from [kafka-node], it's buggy when you try to use it\nwith offset being managed by yourself, which prevents you from implementing\na reliable message consumer meets guarantee that each message should be\nconsumed at least once.\n\nEven if you don't care about at-least-once guarantee at all,\n`ConsumerGroupStream` duplicates a lot of message after rebalance. Although\nyour apps need to be idempotency when handle message, this library take the\nbest efforts to minimize the duplication of messages, unless error occurred\nthat prevent the offset to be committed, it shall NEVER duplicate any message.\n\n## Installation\n\n[kafka-node] is A peer dependency of this library, you need to install it\ntogether with kafka-pipeline.\n\n```bash\nnpm install kafka-pipeline kafka-node\n```\n\n## Usage\n\n```javascript\nconst {ConsumerGroupPipeline} = require('kafka-pipeline');\n\nconst consumerPipeline = new ConsumerGroupPipeline({\n  topic: TOPIC_NAME,\n  messageConsumer: async (message) => {\n    //...\n  },\n  // A optional callback function handled messages failed to consume by\n  // `messageConsumer`. When error raised in `messageConsumer`,\n  // consumerPipeline will be closed if you don't provide `failedMessageConsumer`,\n  // or `failedMessageConsumer` also raise an exception\n  failedMessageConsumer: async (exception, message) => {\n    //...\n  },\n  consumeConcurrency: 8,\n  consumeTimeout: 5000,\n  commitInterval: 10000,\n  consumerGroupOption: {\n    groupId: GROUP_ID\n    // Properties of this object will be pass to ConsumerGroup\n    // except that some of them could be override by ConsumerGroupPipeline\n    // See reference of its setting at https://github.com/SOHU-Co/kafka-node\n    //\n  }\n});\n\nconsumerPipeline.start();\n\n// The following code is for demo purpose only, not suggesting you to do this\n// in production code. But to avoid message duplication you need to ensure your\n// app will quit in a graceful way that await the promise returned by\n// consumerPipeline.close() is resolved, which will do the final offset commit\nprocess.on('SIGTERM', function () {\n  consumerPipeline.close().then(function () {\n    process.exit(0);\n  });\n});\n```\n\n## Breaking changes\n\n- 3.0 (Upcoming): `consumeConcurrency` now limits message consumed concurrently per-partition,\n  not per-consumer, default value changed to 1\n\n- 2.0: Migrated to Typescript\n\n\n## License\n\nISC License, see `LICENSE` file.\n\n## TODO\n\n1. More test\n2. Consider support HighLevelConsumer?\n\n[kafka-node]: https://github.com/SOHU-Co/kafka-node\n[Transform]: https://nodejs.org/api/stream.html#stream_class_stream_transform\n","readmeFilename":"README.md","gitHead":"608b24d9d39a47cd1ab1f04130987dd5844bb6f5","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@3.1.0","_nodeVersion":"12.13.1","_npmVersion":"6.12.1","dist":{"integrity":"sha512-oQBjGKA5qjGf9IBZcWMQ5hPvjxLV5M1cfqphipSeALqFAJF0SmgOC2v+c/fZ+WxrFY9/67BAJmJK3UTxYHRDEw==","shasum":"68a0048c91c15c0f490d5119d714382aeed36c1e","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-3.1.0.tgz","fileCount":66,"unpackedSize":200901,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJd+ao1CRA9TVsSAnZWagAAy4oP+wW8mdUG9YHCkEvy7DWV\nMd+ygNE+m7oaZh9R+W+oM4faCiN3nXI9i5KtWl40jrrbb0VEZOgxwFczw77B\n8z8fP0BNdjaNt8MwK7z7qXpMYsDssftSJ3N82lwWE3Qlz9GnqKe9OIHK9vD/\nEpuKDdbVx3K5KmObikukvj902rNI4aius921N9hFH+A7TXQfqcu1xRyiSa4v\njYZtDwT02s9LObjzs9bGqwswA8Mh7wBHW2xUXD9QEELh63XZtzOo95n+IvOI\nnWa6MsyfD6w1opLJxLkaYFJERbRJmvwRD+q3aChyhXjf/ox10G2s+PSB2w0h\n2xMJsROfIDW+YTFkSeoCAvL8ZWEmwDVWxrhpwhdaD+vGHxR4Fd0E2tp+eaNO\nfAl5Bs+MvIVfnYjf52jyxNyIJYv1w99an/kzSl2m0uEpIW9ZHaNjgM4ClcJD\nZ9ZrfOsS5pdgculjXfY8G2raDqo4TUVX5r9/bd9REWncwNqrV8Ih6YwTeq+A\nA7BFvyMgi1BWsNnhJYdJvm2m/GHCdSANPX0w09HG1UIX0beUN3IgjzDEjv3c\nsAzFeIWYjqErK33c8uvORtfZgd3bTHTsSoQ1i+nSRqW+m4gEB8GrAcFwE6f/\n5VM38PBB3pD1v5Yx6FMNLW4+ChwC//tBgHf5KR9fQPrNXShjBHSBzM1kn8L8\nA8V7\r\n=Sms7\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIDizlSPoydR0784bEwT7Kuhu/2SGSa4Hvic/xlPYN13+AiBI4GmV0HLFcKn9jOeUktCmfKx5O8hVztmaSFNC8/F+dQ=="}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_3.1.0_1576643124770_0.14257462744273575"},"_hasShrinkwrap":false},"3.2.0":{"name":"kafka-pipeline","version":"3.2.0","description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"test":"jest","build-document":"typedoc --mode modules --ignoreCompilerErrors --excludePrivate --theme minimal --out docs lib/ && touch docs/.nojekyll","postpublish":"git describe --exact-match && npm run build-document && gh-pages -t -d docs"},"repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"author":{"name":"LAN Xingcan"},"keywords":["kafka"],"license":"ISC","peerDependencies":{"kafka-node":"git+https://github.com/thynson/kafka-node.git#49800b96b7d27a4f6226b138253a6fd8c1f842c7"},"devDependencies":{"@types/jest":"^24.0.23","@types/node":"^10.17.11","gh-pages":"^2.1.1","jest":"^24.9.0","kafka-node":"git+https://github.com/thynson/kafka-node.git#49800b96b7d27a4f6226b138253a6fd8c1f842c7","ts-jest":"^24.2.0","typedoc":"^0.15.5","typescript":"^3.7.3"},"dependencies":{"bluebird":"^3.7.2"},"gitHead":"a7d5615888e9e77e7cff119ec7c09d9f0e29611e","bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"_id":"kafka-pipeline@3.2.0","_nodeVersion":"12.13.1","_npmVersion":"6.12.1","dist":{"integrity":"sha512-Ex2NHz1syorIEsbbTg+eOiCH6Jk7g/O1L6UbD9XZcaEsN/NicwUm9f2skiII85yz/y6MRUI51t1AfP3Ll4J9Lw==","shasum":"81c7b8448ff493ea3dcd9e51e4ba544cbefc0ce2","tarball":"https://registry.npmjs.org/kafka-pipeline/-/kafka-pipeline-3.2.0.tgz","fileCount":66,"unpackedSize":200839,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJd+jLsCRA9TVsSAnZWagAASCUP/1kewuurjsJOCuD0GH0M\njPzO9Xk3k8twwQEUs/YcyoVjZ8j0kk5Pjb5SUxjhqr2NN5JPetlqeaY8LAih\nOu1QembA03kE8QMsLWdMlHQnx7pHrP7wU0mLXZ8scIclRSgQv4bmKw73/alT\nuRe0we9LvFD/8vo2ZEgbTFoq0c0P0kyEWOSdrsuEq/bqkQai52J+8FpVb+Ak\nyrzohfvyLlwzlxzfYfMbHJC3pw3UChYU2nlEve0wRIBEWWw+znfLQo32a2Sf\nltAC2ZDWC7U2+WZwAPppGFLCRATLyGvxhGhipX0HG//qO0aXLY9yBmtT5n1y\nQ6xIvUGg2fAICIutlTV7HtVkUSz1dRmxzRwFQHwO5R09fB2O4vJRdtbDMLrG\nohMgoK4sY2rU02Jj1lBjNuA9J+xtZ+JBAO7N9sqcuoCmxP3eGJqno+e280BO\neCdltgK3Qs3LUGPqceQnz7mQFwbHub18LVK4Ux0rO01ICra33DrrmJdt3mvq\nE4G078AtTLs5kD1jswyVe90UheAiD+5ZgdageXY0VY1iimZO5pRKSu4CXPu7\nNNgcS5o95lsN0VHHcX6JezKdauZ73zfK0mKuMssNFo/W+uPSqW20//CdwiWc\n081lE55d50rkRw8YhFh7Jgk634FEpmulbK3VVrKMPJ9g0NQsoHMt5ng/PUhz\nxARD\r\n=vubL\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQD6FCKl0oF+G4P0Thldut7mPfPBL9BVRKVrE9DRu+9pHwIhAKfX4TdUcFEeY5+ej/MCdjhojMtY///ovgZzOFWe79o0"}]},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"_npmUser":{"name":"thynson","email":"thynson@live.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-pipeline_3.2.0_1576678124268_0.9904391135380695"},"_hasShrinkwrap":false}},"time":{"created":"2018-09-06T01:30:53.679Z","0.1.0":"2018-09-06T01:30:53.841Z","modified":"2022-05-07T03:03:41.535Z","0.1.1":"2018-09-06T09:58:25.259Z","0.1.2":"2018-09-06T17:28:35.773Z","0.2.0":"2018-09-10T04:18:30.854Z","0.2.1":"2018-09-10T07:04:21.207Z","0.2.2":"2018-09-10T11:02:53.328Z","0.3.0":"2018-09-11T02:09:03.289Z","0.3.1":"2018-09-11T09:41:45.924Z","0.3.2":"2018-09-13T09:21:40.994Z","0.3.3":"2018-09-13T09:23:03.435Z","0.3.4":"2018-09-13T18:14:50.784Z","0.3.5":"2018-09-17T07:56:41.628Z","0.4.0":"2018-10-09T07:34:07.000Z","0.4.1":"2018-10-26T03:31:08.130Z","1.0.0":"2018-10-26T06:11:10.697Z","1.0.1":"2018-12-18T10:03:30.557Z","2.0.0":"2019-04-17T02:25:50.411Z","2.0.1":"2019-04-17T09:14:00.132Z","2.0.2":"2019-04-17T09:25:02.301Z","2.0.3":"2019-04-20T08:40:16.477Z","2.1.0":"2019-04-20T08:56:51.976Z","2.1.1":"2019-04-20T08:59:21.388Z","2.2.0":"2019-04-20T09:26:42.751Z","2.2.1":"2019-04-20T09:43:24.803Z","2.2.2":"2019-04-20T10:13:06.204Z","2.2.3":"2019-05-08T14:24:19.807Z","3.0.0-0":"2019-10-09T14:35:15.397Z","3.0.0-1":"2019-10-21T13:45:04.454Z","3.0.0-2":"2019-10-23T10:46:39.429Z","3.0.0":"2019-10-31T03:56:07.186Z","3.0.1":"2019-11-02T08:24:00.389Z","3.0.2":"2019-11-12T14:24:42.444Z","3.1.0":"2019-12-18T04:25:24.893Z","3.2.0":"2019-12-18T14:08:44.431Z"},"maintainers":[{"name":"thynson","email":"thynson@live.com"}],"description":"A robust, easy to use kafka consumer","homepage":"https://thynson.github.com/kafka-pipeline","repository":{"type":"git","url":"git+https://github.com/thynson/kafka-pipeline.git"},"bugs":{"url":"https://github.com/thynson/kafka-pipeline/issues"},"license":"ISC","readme":"# kafka-pipeline\n\nThis library provide a robust, easy to use kafka message consumer based on\n`ConsumerGroup` from [kafka-node] that helps you managing message offsets\nin correct way.\n\n## Design notes\n\nThe basic idea behind this library is separate consume progress and offset\ncommit into two [Transform] stream, namely `ConsumeStream` and\n`CommitStream`, messages will be consumed by `ConsumeStream`\nby invoking a specified callback within a specified concurrency limit. And,\n`ConsumeStream` will yield all received messages in the same order\nto `CommitStream` when all the condition following are met:\n\n1. the message itself has been consumed\n\n2. all predecessor message in the same partition have been consumed\n\nWhile the `CommitStream` remember the latest offset of each partitions\nand topics, commit them repeatedly in a specified interval as well as the time\nwhen the consumer is rebalanced or closed.\n\n\nWhile this idea is originate from\n`ConsumerGroupStream` from [kafka-node], it's buggy when you try to use it\nwith offset being managed by yourself, which prevents you from implementing\na reliable message consumer meets guarantee that each message should be\nconsumed at least once.\n\nEven if you don't care about at-least-once guarantee at all,\n`ConsumerGroupStream` duplicates a lot of message after rebalance. Although\nyour apps need to be idempotency when handle message, this library take the\nbest efforts to minimize the duplication of messages, unless error occurred\nthat prevent the offset to be committed, it shall NEVER duplicate any message.\n\n## Installation\n\n[kafka-node] is A peer dependency of this library, you need to install it\ntogether with kafka-pipeline.\n\n```bash\nnpm install kafka-pipeline kafka-node\n```\n\n## Usage\n\n```javascript\nconst {ConsumerGroupPipeline} = require('kafka-pipeline');\n\nconst consumerPipeline = new ConsumerGroupPipeline({\n  topic: TOPIC_NAME,\n  messageConsumer: async (message) => {\n    //...\n  },\n  // A optional callback function handled messages failed to consume by\n  // `messageConsumer`. When error raised in `messageConsumer`,\n  // consumerPipeline will be closed if you don't provide `failedMessageConsumer`,\n  // or `failedMessageConsumer` also raise an exception\n  failedMessageConsumer: async (exception, message) => {\n    //...\n  },\n  consumeConcurrency: 8,\n  consumeTimeout: 5000,\n  commitInterval: 10000,\n  consumerGroupOption: {\n    groupId: GROUP_ID\n    // Properties of this object will be pass to ConsumerGroup\n    // except that some of them could be override by ConsumerGroupPipeline\n    // See reference of its setting at https://github.com/SOHU-Co/kafka-node\n    //\n  }\n});\n\nconsumerPipeline.start();\n\n// The following code is for demo purpose only, not suggesting you to do this\n// in production code. But to avoid message duplication you need to ensure your\n// app will quit in a graceful way that await the promise returned by\n// consumerPipeline.close() is resolved, which will do the final offset commit\nprocess.on('SIGTERM', function () {\n  consumerPipeline.close().then(function () {\n    process.exit(0);\n  });\n});\n```\n\n## Breaking changes\n\n- 3.0 (Upcoming): `consumeConcurrency` now limits message consumed concurrently per-partition,\n  not per-consumer, default value changed to 1\n\n- 2.0: Migrated to Typescript\n\n\n## License\n\nISC License, see `LICENSE` file.\n\n## TODO\n\n1. More test\n2. Consider support HighLevelConsumer?\n\n[kafka-node]: https://github.com/SOHU-Co/kafka-node\n[Transform]: https://nodejs.org/api/stream.html#stream_class_stream_transform\n","readmeFilename":"README.md","keywords":["kafka"],"author":{"name":"LAN Xingcan"}}