.coditsu/ci.yml | 100664 | 0 | 0 | | | 138 Bytes | e4ebfa4ad81dd12ffe492ff9168a0fb9c20d3e74e8bff0aa06f54c6c76cef711 |
.console_irbrc | 100664 | 0 | 0 | | | 336 Bytes | 4431d0fa2de6c2846d47a90a2f22d6c5dea9a41f097abf9160e05b2b81b30c6e |
.diffend.yml | 100664 | 0 | 0 | | | 158 Bytes | a49a2e6b3b48603cfe838d422d381d219a49d7593c72c9a82c5e10296e90b4b9 |
.github/ISSUE_TEMPLATE/bug_report.md | 100664 | 0 | 0 | | | 1.3 KB | 49838cfbc9c1c052cc8cb1e8889276bee6caff8e24a270c49322f2d61e5dd7d2 |
.github/ISSUE_TEMPLATE/feature_request.md | 100664 | 0 | 0 | | | 593 Bytes | 739d98d20ac43aedb1aa0c34d93209a440fc0ff142037f76950c95888dc4cfeb |
.github/workflows/ci.yml | 100664 | 0 | 0 | | | 1.83 KB | bb9fbbf5ff72be36a80a9e96857e516664350145cd50eea4b2ad872b740a3b8d |
.gitignore | 100664 | 0 | 0 | | | 1023 Bytes | cfaaf830420e24157da66709f087a6f1c395deb5acf38a0bb162c3a77e6fb22f |
.rspec | 100664 | 0 | 0 | | | 22 Bytes | 59cb44b82275dbbbe102e09ad72aaafa8a3b1f15ec35682f21c6741ca9d2c7b2 |
.ruby-gemset | 100664 | 0 | 0 | | | 8 Bytes | 2afae0b89d0be84fbce9611eb5bdcf52d69396704dc429f68b6270ce56c8880c |
.ruby-version | 100664 | 0 | 0 | | | 6 Bytes | 905360921e63f419d6a111dd3216bf28402f367ab9aa69444d80e97419600d80 |
CHANGELOG.md | 100664 | 0 | 0 | | | 30.1 KB | 3e54ef38d6553f14d7e34a8ed4d2b3873f1f782c44bf057e34855ce6e79a57a6 |
CODE_OF_CONDUCT.md | 100664 | 0 | 0 | | | 3.14 KB | c5be22a6783a9daf04a76f109d5695618c5e55638e2f5c5dc8821c3180ec88a3 |
CONTRIBUTING.md | 100664 | 0 | 0 | | | 2.18 KB | 62a44d89701d60a8cddfc91cef9c6e76db51dc205e0b897894f0ab9992a2c613 |
Gemfile | 100664 | 0 | 0 | | | 175 Bytes | 875813a9765a81de5eb5fed5e86bd2f3cccc4e48a4c0eba4e8b7201fbbc8b0f1 |
Gemfile.lock | 100664 | 0 | 0 | | | 3.05 KB | 680ed093b2af8621432398de7e443288fd4d559daef1c48dd1b5fff484e342ea |
MIT-LICENCE | 100664 | 0 | 0 | | | 1023 Bytes | cb5aedb296c5246d1f22e9099f925a65146f9f0d6b4eebba97fd27a6cdbbab2d |
README.md | 100664 | 0 | 0 | | | 924 Bytes | 84f30b059e4b837b2d9e3cde6ca7df5c93a8c9f756c893f47936ffca4e5ee8ee |
bin/karafka | 100775 | 0 | 0 | | | 540 Bytes | e43633fac96e0fd8e25d9a5ac3579d2d94332f7ad31e5eac9a6818bc687862a5 |
certs/mensfeld.pem | 100664 | 0 | 0 | | | 1.56 KB | 0e7b1f6d0c593954357a26b094ce8120234d38cdd69d0949033d92f3fb67cd74 |
config/errors.yml | 100664 | 0 | 0 | | | 1.75 KB | d7a70f8a0b42f75c555a895c8a141adb477c291be8278556f6ebaaf7345a9d7c |
docker-compose.yml | 100664 | 0 | 0 | | | 427 Bytes | 07be37a72e5dc0a24f8c1c51a34440d280a82006845491f1ca46173c032945dc |
karafka.gemspec | 100664 | 0 | 0 | | | 1.95 KB | 55bcaad7d9d38fbca671f012d41eecf270dcb993baba108c1d872d9c7447772e |
lib/karafka.rb | 100664 | 0 | 0 | | | 2.99 KB | 55537d8f3d3ef7eaa219daecb8d88fc6bf11250db6908201c9ae76e452b3cf0a |
lib/karafka/app.rb | 100664 | 0 | 0 | | | 1.47 KB | 50bd007dbb2d293fc6f28debf9749e1fb93292654518d2fd82d25c040d445fa4 |
lib/karafka/assignment_strategies/round_robin.rb | 100664 | 0 | 0 | | | 302 Bytes | d1167c2ae78a330e4d9954c659f5b084bf08ec718f46bf6979211a26e0d4d3c8 |
lib/karafka/attributes_map.rb | 100664 | 0 | 0 | | | 2.95 KB | a4eba58c99d7793532cc03898199790b49fe5cec1b919b331f6072ca423af499 |
lib/karafka/backends/inline.rb | 100664 | 0 | 0 | | | 414 Bytes | 91cb3a4158b166112fe7ba95d5388fd1ba96fc797973dca1c2e07c837e28b320 |
lib/karafka/base_consumer.rb | 100664 | 0 | 0 | | | 1.79 KB | d7a85a24498a4f6fa151ad284e56def94f98e2198545dfe4de085df991a30f48 |
lib/karafka/base_responder.rb | 100664 | 0 | 0 | | | 8.02 KB | 97b271f067a8274304805870139baf32f46b2a736e788d8e03251acb9bb045da |
lib/karafka/cli.rb | 100664 | 0 | 0 | | | 1.85 KB | ca7798288f301e6300ded1c2fedf37b34661aec57d3f84eb9767dc50809bf020 |
lib/karafka/cli/base.rb | 100664 | 0 | 0 | | | 2.15 KB | dd5994557128bc49d49726a43bb961ac3dee0788daec7f94319c5c849405d45c |
lib/karafka/cli/console.rb | 100664 | 0 | 0 | | | 781 Bytes | 2d2fc7986540e3dbb988b281620edd61f079ef74645e894ec74e461596639bd2 |
lib/karafka/cli/flow.rb | 100664 | 0 | 0 | | | 1.38 KB | 71040a0edcccf517383c3ed60a3e66ccda6acaf77da7f615ef4368caeacfbef9 |
lib/karafka/cli/info.rb | 100664 | 0 | 0 | | | 950 Bytes | 82ab2bc448e6ddc99b8df8e8219836c82a57ea893cbbff1acf4f777588266ac6 |
lib/karafka/cli/install.rb | 100664 | 0 | 0 | | | 1.94 KB | 740018f2ad4b6b5facabf978b278e42ce19966091d5c6e0623779fd560507f33 |
lib/karafka/cli/missingno.rb | 100664 | 0 | 0 | | | 607 Bytes | 3f3a3903b94de317ae59ae1bcca2e8bc4abc68add13a19b9695c9f1e1ceffa5b |
lib/karafka/cli/server.rb | 100664 | 0 | 0 | | | 2.28 KB | 1319eef6351bb15118eb668adad03332a20c888730650540143ff7fb8812654c |
lib/karafka/code_reloader.rb | 100664 | 0 | 0 | | | 2.25 KB | 4b4ce4eaa4001d9b6f3d4d0113fced745954b5d752843775d5743b14fe6dfc08 |
lib/karafka/connection/api_adapter.rb | 100664 | 0 | 0 | | | 7.55 KB | 93e5e2bd6785bc373c31f2717f4fc136f46ea0b1f2dade68c3f20e1395d90bee |
lib/karafka/connection/batch_delegator.rb | 100664 | 0 | 0 | | | 2.07 KB | f60d7197f9aaf2acd38799acd310f5d7cfaf224f5008233a3b173a25983682a5 |
lib/karafka/connection/builder.rb | 100664 | 0 | 0 | | | 641 Bytes | b17ff2f6adc1c31a1435f139489bc873d67163917a31189dc469feeed11e3a3f |
lib/karafka/connection/client.rb | 100664 | 0 | 0 | | | 4.72 KB | 5c42c4a305462f65c063c71a46310a053ea9af9a31557a111528450064c629a9 |
lib/karafka/connection/listener.rb | 100664 | 0 | 0 | | | 3.02 KB | 6ec7057c0ef243331dac1d18310040d5397e7e0708d34273806db2a5b454aa2f |
lib/karafka/connection/message_delegator.rb | 100664 | 0 | 0 | | | 1.39 KB | 0765fc60b24df9f4611a92d71ea8e89ff9945c8830b1687090073f41c4500429 |
lib/karafka/consumers/batch_metadata.rb | 100664 | 0 | 0 | | | 219 Bytes | 7dae7712e786ba9e1ea2142cdba6d4be2fedc42ba6645d957abf93c5325c380b |
lib/karafka/consumers/callbacks.rb | 100664 | 0 | 0 | | | 2.38 KB | cbfaab8e64c2a6fcc015eed0340c0824838f5cf9b1337443b123d7edb5ddd370 |
lib/karafka/consumers/includer.rb | 100664 | 0 | 0 | | | 2.39 KB | fc81cc132a23562fc1ced906536752616228b2a23387de49d446a41d5edeff79 |
lib/karafka/consumers/responders.rb | 100664 | 0 | 0 | | | 846 Bytes | 16d6200d55f67bc9ecb3762f5521d4ad180489d39c2e7f47c07723e9086e9737 |
lib/karafka/consumers/single_params.rb | 100664 | 0 | 0 | | | 330 Bytes | 4d3e9c4d7da4155e7fe754cd68eab5d38febc1e425bbe6965a1d7906656edcb9 |
lib/karafka/contracts.rb | 100664 | 0 | 0 | | | 334 Bytes | f0c5e10d7c0d27493d34e7120e85f6770f5e4ef90d709fde22895dfb5f56a59d |
lib/karafka/contracts/config.rb | 100664 | 0 | 0 | | | 787 Bytes | 142718334d5e6a472ccc0d4e2b01d64647a3a46f9cc11d498583bbba879923b3 |
lib/karafka/contracts/consumer_group.rb | 100664 | 0 | 0 | | | 7.35 KB | f7dc3eae19da51ff6906dc0a5d5612f28b3f18662077c4b1c966c42704717801 |
lib/karafka/contracts/consumer_group_topic.rb | 100664 | 0 | 0 | | | 684 Bytes | d2670be0240ce521d8810644954a1076435c5dd7d9a5e7831df4c8e93f0eaf4b |
lib/karafka/contracts/responder_usage.rb | 100664 | 0 | 0 | | | 1.68 KB | 33022cd158b714d8918d1b99e1015109412136ea252dedd3846a116e62c98d6a |
lib/karafka/contracts/server_cli_options.rb | 100664 | 0 | 0 | | | 1.11 KB | bc2e1df03ef43ad7e2b2cccedfdca65c64f4f8c65fcd1c7491e5fc831f7329fc |
lib/karafka/errors.rb | 100664 | 0 | 0 | | | 2.18 KB | f78925343924b40db2c82ed5bc869153b1a63cd824560fc70445ffa87766377d |
lib/karafka/fetcher.rb | 100664 | 0 | 0 | | | 1.69 KB | cc477ee4e849cf8dd567d2866729f9b3b403e20f79b4e5a421c278e14ad95c10 |
lib/karafka/helpers/class_matcher.rb | 100664 | 0 | 0 | | | 3.46 KB | e3bb3eeebce31ca0fd64af8f1d8acf51b78916336e6a57c5bbb242284412b617 |
lib/karafka/helpers/config_retriever.rb | 100664 | 0 | 0 | | | 1.75 KB | 884a69bd4f30bfccc22cd4220354392bc66da092ced07402143d874e4e666537 |
lib/karafka/helpers/inflector.rb | 100664 | 0 | 0 | | | 791 Bytes | 7851e811b342c3d49b853f1bcc4cfc8a911402d9f4b7fe88de7eaf913995b441 |
lib/karafka/helpers/multi_delegator.rb | 100664 | 0 | 0 | | | 924 Bytes | 802e3f2e521937efa5cd449a3e5aeaa637126874e6293265d7eb4b7abce300ab |
lib/karafka/instrumentation/logger.rb | 100664 | 0 | 0 | | | 1.7 KB | 9c60d2e6106306243c2125fa7c7ebe4299d4d8e774a5f1df8a7b44db83180f9b |
lib/karafka/instrumentation/monitor.rb | 100664 | 0 | 0 | | | 2.89 KB | ac99450b910cd363ce39cf66f89cd91672990dde4199ad14514bced0f8bc2e04 |
lib/karafka/instrumentation/proctitle_listener.rb | 100664 | 0 | 0 | | | 1.04 KB | d44fc85a9cc97a943a47838f1959ff8f2dbba976d3ba4be96d85e24e1396ba5b |
lib/karafka/instrumentation/stdout_listener.rb | 100664 | 0 | 0 | | | 5.58 KB | 773e5f08617f0c54bb91192910698f7eb914cd9d5858ab40bd53d9696bff9a8c |
lib/karafka/params/batch_metadata.rb | 100664 | 0 | 0 | | | 686 Bytes | 8589975b6ad7c3bd7914d2d47866d3bc2dd8527c0bda417d8dc099f2bf916e25 |
lib/karafka/params/builders/batch_metadata.rb | 100664 | 0 | 0 | | | 1.14 KB | d4c82f2c45a97f80f32b8e6d19d14c9291bd04396b9e287b025f7cd803b3f4c1 |
lib/karafka/params/builders/params.rb | 100664 | 0 | 0 | | | 1.39 KB | b61e60ab2d733003f52d12b05c9963f79d1eb4f7a4135052baf6627036a166b3 |
lib/karafka/params/builders/params_batch.rb | 100664 | 0 | 0 | | | 917 Bytes | a0493751b9074f000dfe46fb9099dc7952fb43305442a504defd7f6072da1407 |
lib/karafka/params/metadata.rb | 100664 | 0 | 0 | | | 416 Bytes | 2c119798cbb4eb0f0b3f4198219f36c8bc2c388bd6facf40730ad62dc62d9d83 |
lib/karafka/params/params.rb | 100664 | 0 | 0 | | | 1.72 KB | 34888e162b4946a345016a07ff1582d9cc309c3fd34013f8438d86f788d91e8d |
lib/karafka/params/params_batch.rb | 100664 | 0 | 0 | | | 1.91 KB | effb723407348072b4125805c6ee7e0e57e5395f7209d96402a959fc14b8b8fd |
lib/karafka/patches/ruby_kafka.rb | 100664 | 0 | 0 | | | 1.77 KB | 31fc28695a4d9ea8997ff87b0f5e6a37a0c4af0c7c877d86cc92837a9a295bff |
lib/karafka/persistence/client.rb | 100664 | 0 | 0 | | | 1008 Bytes | 68e3fcf57f34de8a699d2ec9ac4e732243bedf1f575eef5a5bc2c985cd7a7355 |
lib/karafka/persistence/consumers.rb | 100664 | 0 | 0 | | | 1.78 KB | f494b4be847c5b84f95d71cbceecb21de94c6dad888584c126673a234335053a |
lib/karafka/persistence/topics.rb | 100664 | 0 | 0 | | | 1.83 KB | ecb8b42c01c97d16fe2b7b23b47ba10bf45d4b665ffd8da044657ac9a0a5707c |
lib/karafka/process.rb | 100664 | 0 | 0 | | | 1.94 KB | 1f0b779daa8e9825584a7f87e565de593b13118e89cdaec43edd91fb6bdee72f |
lib/karafka/responders/builder.rb | 100664 | 0 | 0 | | | 1.44 KB | 097342cc42620d57439b1d67a82c434055dd00ff681b4be4aeff81b27d23cac9 |
lib/karafka/responders/topic.rb | 100664 | 0 | 0 | | | 1.73 KB | c13a7ea412241c249fdb13e41efe32c285cd2fd8d496ed706ebc2c90a6ed4cbd |
lib/karafka/routing/builder.rb | 100664 | 0 | 0 | | | 3.02 KB | d9b9cfcff2b6ffa0dad86d645941f0d26a782b2498909f84f71673030f24f2dd |
lib/karafka/routing/consumer_group.rb | 100664 | 0 | 0 | | | 2.02 KB | e139917b7c91184fa9e302c7ac97eb4645060fe58d3bc270059797ff7f902d26 |
lib/karafka/routing/consumer_mapper.rb | 100664 | 0 | 0 | | | 1.25 KB | 576bf3cd95def1a77c3a72ca454755fd189162a557460033befafa4be6599814 |
lib/karafka/routing/proxy.rb | 100664 | 0 | 0 | | | 1.58 KB | 4230a20e0a49a6c5aad1e72118260b09972f7af1703660d09a0598893f42d650 |
lib/karafka/routing/router.rb | 100664 | 0 | 0 | | | 1.06 KB | 5b13d7a50ba287de04fd7fe3c830cdf6d80a5832c106ddbef625a07f9bef18c2 |
lib/karafka/routing/topic.rb | 100664 | 0 | 0 | | | 2.22 KB | 3a8309e5e17cadcf9f507b6d9fc41dda303ea86508b5a7e9c39774fbf4afe6e6 |
lib/karafka/routing/topic_mapper.rb | 100664 | 0 | 0 | | | 1.39 KB | 04f6462c094addf6ffbea03745e7f63465d0740cbe8979a2bfb686746bfe4ec1 |
lib/karafka/serialization/json/deserializer.rb | 100664 | 0 | 0 | | | 923 Bytes | 2c67803174ab4bc580c1019517098dae53dd64db28331e2cb0ba78d2ed3a904c |
lib/karafka/serialization/json/serializer.rb | 100664 | 0 | 0 | | | 1.32 KB | 8c992aa1119086aadc951c46baa3e96132f51c30801a816a6754dad087749289 |
lib/karafka/server.rb | 100664 | 0 | 0 | | | 3.09 KB | e771f3611354f883b364026c7fa18462527dd56d2db0b8c3634d6a867cb74a87 |
lib/karafka/setup/config.rb | 100664 | 0 | 0 | | | 13.2 KB | c8cbda9cc69e2d95e6b85a7ba2569dd6c020330778f96004b724914932caec1f |
lib/karafka/setup/configurators/water_drop.rb | 100664 | 0 | 0 | | | 1.23 KB | fa0850a52eda4afacaaa4c8b3690c914221378061f455d77d29975d8a46edb60 |
lib/karafka/setup/dsl.rb | 100664 | 0 | 0 | | | 555 Bytes | d9a93c794c071cda753465d9145dc657a8a2ab5d226e2fc0724e134c644f09ae |
lib/karafka/status.rb | 100664 | 0 | 0 | | | 710 Bytes | 35451f4aa3f4063b8502bce58ddd41c0ce73ec7d5e86cbacbb2b1c606d718f48 |
lib/karafka/templates/application_consumer.rb.erb | 100664 | 0 | 0 | | | 286 Bytes | 44a56710679e00a419831a79da526cbad4a0d15c95f2834ee09e03ed0185ee0f |
lib/karafka/templates/application_responder.rb.erb | 100664 | 0 | 0 | | | 424 Bytes | e5e72f544a4c0f28ac3eec2caf4a40b3552e50d2ca8631333c7b35ea3adc2a86 |
lib/karafka/templates/karafka.rb.erb | 100664 | 0 | 0 | | | 2.64 KB | cd8240f9962dbd901d0fb064535cd4541fb53de425bfe967bd5d769becc233fb |
lib/karafka/version.rb | 100664 | 0 | 0 | | | 123 Bytes | 508619cbcab09e1ab28bc36160438cb958d2460cc4448df0a3df5a4c945cb327 |
log/.gitkeep | 100664 | 0 | 0 | | | 0 Bytes | e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855 |