.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 | | | 3.04 KB | 7823711f2023f6b974bcdc5085663c57fd02a67fd4f79186ce03acd5663a40f5 |
.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 | b2f44d3b6e29f8b1b73ea4735f006affc4d198e1fd9c7d50e736159b1ef636c6 |
CHANGELOG.md | 100664 | 0 | 0 | | | 31.4 KB | f45e0ade9a140d5f25fb6e72c5f96f34e99cc208d7e0f3ee46e4b5b47494a7c6 |
CODE_OF_CONDUCT.md | 100664 | 0 | 0 | | | 3.14 KB | c5be22a6783a9daf04a76f109d5695618c5e55638e2f5c5dc8821c3180ec88a3 |
CONTRIBUTING.md | 100664 | 0 | 0 | | | 2.14 KB | ff116e17f4313236959a57a2f4b4f5d5a8cd1286c5db10b18d55a4f89a51dd93 |
Gemfile | 100664 | 0 | 0 | | | 336 Bytes | 835cc2e99d2d7e7c9bedba273fa7d729deb4a04a823c49203262bc9f5f5a13e0 |
Gemfile.lock | 100664 | 0 | 0 | | | 3.01 KB | 9154920dd2bbe683b80b0a1740a72d5b4029d16e8fcd9f051b46adf7241364a1 |
LICENSE | 100664 | 0 | 0 | | | 676 Bytes | e0ba5ff22408c4e5a0ee71b3ee8bfc68faa51b74fc36ee09eb454deceb5597d9 |
LICENSE-COMM | 100664 | 0 | 0 | | | 15.9 KB | 3c9a519e15e08855abb5237f90ebb38f06d2e86700c32f2bfeda2c7e7999714c |
LICENSE-LGPL | 100664 | 0 | 0 | | | 7.47 KB | da7eabb7bafdf7d3ae5e9f223aa5bdc1eece45ac569dc21b3b037520b4464768 |
README.md | 100664 | 0 | 0 | | | 3.95 KB | c842a99b598bd3c85723a040be43b327d768537895ebe3402f67bf7d1f22577a |
bin/benchmarks | 100775 | 0 | 0 | | | 2.46 KB | a44b426893921660a53bbc39745660a37bedcec9e21427e9d785120de0f35b38 |
bin/create_token | 100775 | 0 | 0 | | | 770 Bytes | aa93123ad7aaed1cda4f231bc6ef248a4856eb8671466791d38c43ba4022e872 |
bin/integrations | 100775 | 0 | 0 | | | 5.89 KB | ad2fa965e68377fc3ffce56715ffe25303daf8a47ba3c27bb574955cd4d9f0e4 |
bin/karafka | 100775 | 0 | 0 | | | 688 Bytes | 05b71a2e7ac0c9ffe7714e711a887ae8c235fbe59e71ce8339412080895d63e2 |
bin/stress | 100775 | 0 | 0 | | | 282 Bytes | 97e83a9c81ac8493a5bdf83391aeb69ca0b74323782dbe13dcbb65713cde5817 |
certs/karafka-pro.pem | 100664 | 0 | 0 | | | 601 Bytes | 80e379259996ca2d52259405b21c86bb20306c53be5ce0e384b62546466dba4f |
certs/mensfeld.pem | 100664 | 0 | 0 | | | 1.49 KB | 614c78ad388bdb72fbdfc27924283ec38e84fbaee7ba2f3f96b67bb69e3bec85 |
config/errors.yml | 100664 | 0 | 0 | | | 440 Bytes | f83b5454fd28d9487e812fb33e5f8ec8c43e32fe12874d30a6b34d507cbef417 |
docker-compose.yml | 100664 | 0 | 0 | | | 708 Bytes | 5013d23680d6776205d294f40d532a238f4d5194266074fc1d31943bb2c75def |
karafka.gemspec | 100664 | 0 | 0 | | | 1.42 KB | 7c7dd971417af76e8425cd1d3b55e372cadd13e2b852069f62f774bf869ef67b |
lib/active_job/karafka.rb | 100664 | 0 | 0 | | | 784 Bytes | c937d6b4d2be799e88d0f9c3499d3ae67f89dccb71ef6fd8eeecf97ee96cb377 |
lib/active_job/queue_adapters/karafka_adapter.rb | 100664 | 0 | 0 | | | 869 Bytes | c52274add31f1edf456c760fdd5543f38770d5a5c20877b57108843e8cadf1ab |
lib/karafka.rb | 100664 | 0 | 0 | | | 2.66 KB | 747c002a56865c5eb873aa849fd599072c313a4b8f70a03b5a8a762421188453 |
lib/karafka/active_job/consumer.rb | 100664 | 0 | 0 | | | 910 Bytes | 0621bde2cab10be137ac78901b3e25691d2b1374fd24ba9112f53fb639e87ab4 |
lib/karafka/active_job/dispatcher.rb | 100664 | 0 | 0 | | | 1017 Bytes | 6ac75aa3cf710a398071596db7cf8875e5d51ada32d1da84c4df43c2d4514cef |
lib/karafka/active_job/job_extensions.rb | 100664 | 0 | 0 | | | 1.01 KB | 727ff923dbc60f5a8e3c0af70c8cf3afb6484b7b5202ee1477b6f431eac8eeb7 |
lib/karafka/active_job/job_options_contract.rb | 100664 | 0 | 0 | | | 569 Bytes | 0634c9a8946b3ebaf9b1663344327c4398322c437fc434c16882e122f543fbc0 |
lib/karafka/active_job/routing_extensions.rb | 100664 | 0 | 0 | | | 535 Bytes | 538b238047dea47776b297d901dcdc90665f81a993798cbb20e880e06d557d31 |
lib/karafka/app.rb | 100664 | 0 | 0 | | | 1.03 KB | 4e8af3a226e74eec439dbcf08ccd4a200c4d07dd09d8d7ddcfe798428a93b11e |
lib/karafka/base_consumer.rb | 100664 | 0 | 0 | | | 3.83 KB | 16815755af376d1b03fc6be03347681e8c9ba7f8405329481a0dc2eb148b8420 |
lib/karafka/cli.rb | 100664 | 0 | 0 | | | 1.71 KB | 407a9c3973134847b28d2e7e89f7d9bbcd99ab2952cdb26e36ce0f5a1b0750c4 |
lib/karafka/cli/base.rb | 100664 | 0 | 0 | | | 2.14 KB | d3c869dc219ac1702d26ce14bde0d308793f5501377a9f57d701ee6b7ff43758 |
lib/karafka/cli/console.rb | 100664 | 0 | 0 | | | 781 Bytes | 2d2fc7986540e3dbb988b281620edd61f079ef74645e894ec74e461596639bd2 |
lib/karafka/cli/info.rb | 100664 | 0 | 0 | | | 2 KB | 74d998720ddea21bfa0c7c43c0eaca53141c22481fd4f6b14140e6edcb5c910d |
lib/karafka/cli/install.rb | 100664 | 0 | 0 | | | 1.76 KB | b40306c40abea6defe18e85f1b4744a65efcfde100d5f77a705d3cf9809fb423 |
lib/karafka/cli/server.rb | 100664 | 0 | 0 | | | 1.2 KB | 38d28ea3063213be37dd24d609877b15ca30d2fd7439ef0f6691d1e3377568cb |
lib/karafka/connection/client.rb | 100664 | 0 | 0 | | | 9.55 KB | 2fcc340d9afb5c76038bae59663131e6e7707687bce78e418b6ffc202a4cca16 |
lib/karafka/connection/listener.rb | 100664 | 0 | 0 | | | 6.56 KB | 6c66f7ce5eb20b7bd2372f6eae3a3f345e637acfd2987435925f8f865df20684 |
lib/karafka/connection/messages_buffer.rb | 100664 | 0 | 0 | | | 1.91 KB | 0ac54fb77e174c799a14db8246f7a156af17f5bd7800cecd5ede249fa71eb34f |
lib/karafka/connection/pauses_manager.rb | 100664 | 0 | 0 | | | 1.37 KB | 3878f8b063a7c6c0eba98076ae74dd1c497a0d21c8fec99650d9bf3b226e32ab |
lib/karafka/connection/rebalance_manager.rb | 100664 | 0 | 0 | | | 2.29 KB | c98654e528b579cb645ca1c94f42cd7a77e80a068bd3d97d1d8e2749b68bf6f6 |
lib/karafka/contracts.rb | 100664 | 0 | 0 | | | 327 Bytes | 0a2b9ad7b94e44baacf04f81130eb9c68f21fbbcbccdbb7aa0f94a22ea8749e6 |
lib/karafka/contracts/base.rb | 100664 | 0 | 0 | | | 778 Bytes | b9ce9d2f4ef2ee8515aa808fd92aa50cd37cacbebc1a0d7c681bb6caa67a05c1 |
lib/karafka/contracts/config.rb | 100664 | 0 | 0 | | | 2.04 KB | 31844a4bb8fc1546899ba8661921b5ca52db5e5940d5b2f0c8a6b96514cd828e |
lib/karafka/contracts/consumer_group.rb | 100664 | 0 | 0 | | | 997 Bytes | 87bf7ecd9633eb04439bf11de6366607f6584a6e2103822f6dac31a0347675d4 |
lib/karafka/contracts/consumer_group_topic.rb | 100664 | 0 | 0 | | | 1001 Bytes | 8266b66a68ddf5ed43dac664d288c4b5dda7dba573a61bfcc28bed3df95bf4a5 |
lib/karafka/contracts/server_cli_options.rb | 100664 | 0 | 0 | | | 674 Bytes | 76805fbcb467bddb5dc2b742d31ec5bc5d8e2360a4de0cf382f5011765d4ac6b |
lib/karafka/env.rb | 100664 | 0 | 0 | | | 1.43 KB | 7c80157166da7eb037f8ad61d9436acb1ffa8d36aca62243732dc55f2451f282 |
lib/karafka/errors.rb | 100664 | 0 | 0 | | | 2.19 KB | 474397e7477ef8def488bd592bc7fb566c6dc12e70e4274a0598a5c1f48a8746 |
lib/karafka/helpers/multi_delegator.rb | 100664 | 0 | 0 | | | 933 Bytes | c472db16985b61622710a9fdb697d6d930d31ee02e512d8f47bec4e6ab4838d2 |
lib/karafka/instrumentation.rb | 100664 | 0 | 0 | | | 641 Bytes | 4751ae47b221c25da4f6ca89b78a8d3c62eb36ea56cfa5e48c6100510caf540e |
lib/karafka/instrumentation/callbacks/error.rb | 100664 | 0 | 0 | | | 1.55 KB | c7e29b880e8276737ba95ae1a60099ed17989ab226769851ec8c1d7d925b544e |
lib/karafka/instrumentation/callbacks/statistics.rb | 100664 | 0 | 0 | | | 1.74 KB | fdb56dab19c3f2cb5e8dde264f29f9b456b3cce81bd94afbbfcfe029a723720d |
lib/karafka/instrumentation/logger.rb | 100664 | 0 | 0 | | | 1.7 KB | 9c60d2e6106306243c2125fa7c7ebe4299d4d8e774a5f1df8a7b44db83180f9b |
lib/karafka/instrumentation/monitor.rb | 100664 | 0 | 0 | | | 2.42 KB | 60f3138fe871b5047b14893957e3eb3323558b2ed5d93eb0adab3407789cc82f |
lib/karafka/instrumentation/proctitle_listener.rb | 100664 | 0 | 0 | | | 1.04 KB | d44fc85a9cc97a943a47838f1959ff8f2dbba976d3ba4be96d85e24e1396ba5b |
lib/karafka/instrumentation/stdout_listener.rb | 100664 | 0 | 0 | | | 4.07 KB | 76aed176836985822c061186f52d8d2695a347855d358071441cec046cbce5f0 |
lib/karafka/licenser.rb | 100664 | 0 | 0 | | | 2.57 KB | 1b38a42863eef0b1fce269d88ca500c19ea390d93350e14a5ebf607914961858 |
lib/karafka/messages/batch_metadata.rb | 100664 | 0 | 0 | | | 539 Bytes | 94066c2ca705277e49333bf426ee5aecaa02a9377ed4f63ad9c21460f9f38784 |
lib/karafka/messages/builders/batch_metadata.rb | 100664 | 0 | 0 | | | 2.1 KB | 6d4d6a6514a11f4dd28dd7deb253dd6c11a36891a633bb7413999a992341dbe9 |
lib/karafka/messages/builders/message.rb | 100664 | 0 | 0 | | | 1.36 KB | 8b9fb31af1a92d9aa34c4bec3b1d4f0752eb6fda8bb7b2031cbaf5fcc56225e9 |
lib/karafka/messages/builders/messages.rb | 100664 | 0 | 0 | | | 1.23 KB | 5e3dca1638d4c7018e8f0d630623153c906cc9f0e4ffbf759bc3395e33925581 |
lib/karafka/messages/message.rb | 100664 | 0 | 0 | | | 1.47 KB | 0caa232df6b5079b4070a53d1ed8a1345c033c240ae019f8220b011d6fc0eceb |
lib/karafka/messages/messages.rb | 100664 | 0 | 0 | | | 1.85 KB | 4269d340d6d1dd198937d5e471d9a2b001d347a0f30a329f53da073bd40e43c0 |
lib/karafka/messages/metadata.rb | 100664 | 0 | 0 | | | 362 Bytes | 45159d2a186917f7350a4a0a22fe031603eb406f2c30c30a145ea412f56b1af5 |
lib/karafka/messages/seek.rb | 100664 | 0 | 0 | | | 270 Bytes | 1aeb13ee86e9afb829120c812531a72ed44e169146fa5608e14c544b99226de2 |
lib/karafka/patches/rdkafka/consumer.rb | 100664 | 0 | 0 | | | 656 Bytes | 72ff89568105af60357f7926aa4108e56f1006b202193e9bdbd9e71030467605 |
lib/karafka/pro.rb | 100664 | 0 | 0 | | | 451 Bytes | 57ee351f4aafb1c151cd2863e30aa4684356440e7a74d35316f242ea5ae71237 |
lib/karafka/pro/active_job/dispatcher.rb | 100664 | 0 | 0 | | | 1.97 KB | e294119fee13e4d3a884a6443d66b99f5f362d89e1974816d9be22efdfa0352c |
lib/karafka/pro/active_job/job_options_contract.rb | 100664 | 0 | 0 | | | 901 Bytes | e9bc7bfc4991db65f5642b2a175ea0294891d95d2c5847f5be75101897bf7601 |
lib/karafka/pro/loader.rb | 100664 | 0 | 0 | | | 1.13 KB | f1636d0fc2585cf5dccbfc1ef89202bf80fb69675e108186393ed336fee1b03a |
lib/karafka/process.rb | 100664 | 0 | 0 | | | 1.94 KB | 1f0b779daa8e9825584a7f87e565de593b13118e89cdaec43edd91fb6bdee72f |
lib/karafka/processing/executor.rb | 100664 | 0 | 0 | | | 3.77 KB | 981cb327f9eb0a41b9b245371ff5bdc83ef7e524900402210a1e1a7213922c4f |
lib/karafka/processing/executors_buffer.rb | 100664 | 0 | 0 | | | 1.45 KB | 463c3ef707ad64cf3854dcc4be8b7ab4deb8e52dd8adeafadddbcd5c853c4710 |
lib/karafka/processing/jobs/base.rb | 100664 | 0 | 0 | | | 490 Bytes | ffed563082b866179eea0b3b88d4d24c739ceaeef42dc4d3d410eb9fcbb29b68 |
lib/karafka/processing/jobs/consume.rb | 100664 | 0 | 0 | | | 850 Bytes | 35278c44242e769ea2ca8aed1bd30e3afe5842806ceb6057d7eecb9941ffb7c7 |
lib/karafka/processing/jobs/revoked.rb | 100664 | 0 | 0 | | | 561 Bytes | 7e2ddcbb18c88f9761943988cd70a4bf82e528b448adfa3391a3f3477a2ff829 |
lib/karafka/processing/jobs/shutdown.rb | 100664 | 0 | 0 | | | 596 Bytes | 60b136c19adc9f79982e65b0f167f42ff991446a0b3201f71c3dd5c6e7207899 |
lib/karafka/processing/jobs_queue.rb | 100664 | 0 | 0 | | | 4.72 KB | 9ab0be63d8d08c6f6d852a4db47c50152946813b653dcdbc9fd7d93781a075ca |
lib/karafka/processing/worker.rb | 100664 | 0 | 0 | | | 1.62 KB | 2f2f30669d5d4104ac36c1cadc84bbf09b5f0d091cd947cf222dd88801a5d178 |
lib/karafka/processing/workers_batch.rb | 100664 | 0 | 0 | | | 555 Bytes | d3266b0a99343aa6988b949de43e37029eb42973af77e6e064e6f945fa99cfe9 |
lib/karafka/railtie.rb | 100664 | 0 | 0 | | | 3.14 KB | 19e2b8c46652901abbdaafbb8fc8b85b7ac6eacf9c58bd7493ebb198d8e047a4 |
lib/karafka/routing/builder.rb | 100664 | 0 | 0 | | | 2.66 KB | 56dc41c8051afe67554f497acefd99f121291ec17bd463684e611d225199e098 |
lib/karafka/routing/consumer_group.rb | 100664 | 0 | 0 | | | 2.09 KB | be7922921c758dbea7831cabd627d8a2b8da424ba39d7bf6dc3ebc856d572235 |
lib/karafka/routing/consumer_mapper.rb | 100664 | 0 | 0 | | | 1.18 KB | bd42326c09dd22c60c49053a28a155fc0315565a241ac767d9091c15ed8a6d74 |
lib/karafka/routing/proxy.rb | 100664 | 0 | 0 | | | 1.58 KB | 4230a20e0a49a6c5aad1e72118260b09972f7af1703660d09a0598893f42d650 |
lib/karafka/routing/router.rb | 100664 | 0 | 0 | | | 1.06 KB | 99b9a1ed4f52bc72c89dc48a613c60be933c92627a906cb8dd6aba724b8b3225 |
lib/karafka/routing/subscription_group.rb | 100664 | 0 | 0 | | | 1.78 KB | aa6eb1b283eeea42459516cf36f4ec5bce2d03455788d2e090dd93f70affc96e |
lib/karafka/routing/subscription_groups_builder.rb | 100664 | 0 | 0 | | | 1.84 KB | 694a57d8a75b83e81195c1101954e51157888183c153fc5eb94766c3acf3d54a |
lib/karafka/routing/topic.rb | 100664 | 0 | 0 | | | 2.88 KB | c5fa6bc47c20f0e4d039dfa9fc57feda0060a771436237eb7449ad33a7b09683 |
lib/karafka/runner.rb | 100664 | 0 | 0 | | | 2.09 KB | 372a7b8bc37610047ade2ef243ea4e5445f7317971cc6fd7a739bd3035cff91d |
lib/karafka/serialization/json/deserializer.rb | 100664 | 0 | 0 | | | 609 Bytes | 25ca80fd3f8baacc2812ab41359494e62ff0fad0c1ec5214c1b143eba46f3387 |
lib/karafka/server.rb | 100664 | 0 | 0 | | | 4.14 KB | ee913d829f1642edd49b37084a0a8d16749e905a3cf40d6f51e21d7bce51b622 |
lib/karafka/setup/config.rb | 100664 | 0 | 0 | | | 7.75 KB | f09f3a63377a00ea2bf690af79904d5be9382c10fd61b3829487b6f4a3c94e69 |
lib/karafka/setup/dsl.rb | 100664 | 0 | 0 | | | 555 Bytes | d9a93c794c071cda753465d9145dc657a8a2ab5d226e2fc0724e134c644f09ae |
lib/karafka/status.rb | 100664 | 0 | 0 | | | 977 Bytes | 85f49895adeb635da102a1ee39a66a59a4258b0f14baa9d5eef1b7a78a772680 |
lib/karafka/templates/application_consumer.rb.erb | 100664 | 0 | 0 | | | 286 Bytes | 44a56710679e00a419831a79da526cbad4a0d15c95f2834ee09e03ed0185ee0f |
lib/karafka/templates/example_consumer.rb.erb | 100664 | 0 | 0 | | | 375 Bytes | 4f443ec86a1a93a7d32ac84332e05b38a21e99b94d0eab1963d38edfd7bc0d86 |
lib/karafka/templates/karafka.rb.erb | 100664 | 0 | 0 | | | 1.86 KB | 1e86137b54444214371513b44a178437e676fd52c865fff5a70e63f17f7a62e5 |
lib/karafka/time_trackers/base.rb | 100664 | 0 | 0 | | | 501 Bytes | 2f39990f90504428eb22d0e32d5285ee647da6d0838e3194ee824ae2fd9868a7 |
lib/karafka/time_trackers/pause.rb | 100664 | 0 | 0 | | | 2.35 KB | f1631b1c4e69f0b5b5b00191325707f2cf2a97c7620088ad232f34cd9bc74561 |
lib/karafka/time_trackers/poll.rb | 100664 | 0 | 0 | | | 1.74 KB | 5b1e6aad553fbe16b4230f2435e6e88ac2d45595f14b6faceb43579793cff047 |
lib/karafka/version.rb | 100664 | 0 | 0 | | | 129 Bytes | a540dc3b957a1fbb31cd05242b2aecd93801575fa45abe3a0ece58acae8300d9 |
log/.gitkeep | 100664 | 0 | 0 | | | 0 Bytes | e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855 |