karafka-2.0.6

https://rubygems.org

karafka

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

source_code_uri
https://github.com/karafka/karafka
rubygems_mfa_required
true

id: 982994

number: 2.0.6

platform: ruby

spec_sha256: 5e1747bdc971c50a1e1678dccd7a1322ebb6f5ff6fcec40895de674706486b80

sha256: 13453e6c66a39aceda47cb9a19c79c10de6572f73ecbb85ec183db05125bf483

created_at: 2024-05-13 08:28:55 UTC

updated_at: 2024-06-11 22:09:42 UTC

position: 90

version_data_entries_count: 143

uploaded_at: 2022-09-02 16:56:15 UTC

indexed: true

has_extensions:

extensions:

Gem size: 112 KB

Version Data Entries

Total: 143

Unpacked size: 350 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
.coditsu/ci.yml10066400138 Bytese4ebfa4ad81dd12ffe492ff9168a0fb9c20d3e74e8bff0aa06f54c6c76cef711
.console_irbrc10066400336 Bytes4431d0fa2de6c2846d47a90a2f22d6c5dea9a41f097abf9160e05b2b81b30c6e
.diffend.yml10066400158 Bytesa49a2e6b3b48603cfe838d422d381d219a49d7593c72c9a82c5e10296e90b4b9
.github/ISSUE_TEMPLATE/bug_report.md100664001.3 KB49838cfbc9c1c052cc8cb1e8889276bee6caff8e24a270c49322f2d61e5dd7d2
.github/ISSUE_TEMPLATE/feature_request.md10066400593 Bytes739d98d20ac43aedb1aa0c34d93209a440fc0ff142037f76950c95888dc4cfeb
.github/workflows/ci.yml100664002.72 KBf5137ee15597390a6ef4e65b41528f368558a8814ebc1def7fee93be2f34ed68
.gitignore100664001023 Bytescfaaf830420e24157da66709f087a6f1c395deb5acf38a0bb162c3a77e6fb22f
.rspec1006640022 Bytes59cb44b82275dbbbe102e09ad72aaafa8a3b1f15ec35682f21c6741ca9d2c7b2
.ruby-gemset100664008 Bytes2afae0b89d0be84fbce9611eb5bdcf52d69396704dc429f68b6270ce56c8880c
.ruby-version100664006 Bytes905360921e63f419d6a111dd3216bf28402f367ab9aa69444d80e97419600d80
CHANGELOG.md1006640048.1 KB8961c744e65090401fd40d1a48572b3ac4a5cc4060f8373aae73b4f3654d4925
CODE_OF_CONDUCT.md100664003.14 KBc5be22a6783a9daf04a76f109d5695618c5e55638e2f5c5dc8821c3180ec88a3
CONTRIBUTING.md100664001.77 KB0bbe6d4e34b631d47439606f987678f5db1f64617e9776023155f134f07825c1
Gemfile10066400336 Bytes835cc2e99d2d7e7c9bedba273fa7d729deb4a04a823c49203262bc9f5f5a13e0
Gemfile.lock100664001.78 KB6a05e6bc6ac768d51953967e3ec8bd6735393c7967cad868654cebdd59d98c42
LICENSE10066400676 Bytese0ba5ff22408c4e5a0ee71b3ee8bfc68faa51b74fc36ee09eb454deceb5597d9
LICENSE-COMM1006640015.7 KB7ac2dc542b53f8a3913fdd2e930d9b5c1b4e1d11b2316dd61ddc6fe1ceb4fd07
LICENSE-LGPL100664007.47 KBda7eabb7bafdf7d3ae5e9f223aa5bdc1eece45ac569dc21b3b037520b4464768
README.md100664005 KB7a604407ee28756143c2e451046b0e4a30047258ec49f47eea931fcec115b228
bin/benchmarks100775002.46 KB58f01609998decbf1cb652e85187919df1e16ade206c5ce069f284478427bd1c
bin/create_token10077500586 Bytesa47a067dbf5cd47591d666fa9bb966d864d6114f700d3d21dce84dba86cb1533
bin/integrations100775007.32 KBaede448c1a4d7eaf1177c2aaa270db6c9ed9c1b1631b4fedfe0e17b7db413b37
bin/karafka100775001.01 KBf56d64f948004d9c3fffdfd2c52fc3edd0c03bab0fab1119669851233a57c138
bin/scenario100775001.03 KB84f9aa609a41eec4a40ca1a68769e9e628a0042bb37a5f78c4c94b81dcc90eb9
bin/stress_many10077500282 Bytesdae79a13c09041e24007bc94d05a63c102931b481637deca0d3872465df561ca
bin/stress_one10077500280 Bytese988ccb26b4b8881ba77a3b491a13be95f461b1eda601fd2a55a85299b3bd47f
certs/cert_chain.pem100664001.56 KB0e7b1f6d0c593954357a26b094ce8120234d38cdd69d0949033d92f3fb67cd74
certs/karafka-pro.pem10066400601 Bytes80e379259996ca2d52259405b21c86bb20306c53be5ce0e384b62546466dba4f
config/errors.yml100664002.7 KBf8a4e6c92ea1acbef4c895ce39ae623cd7d6f97ded1941c06e4512842dc08308
docker-compose.yml10066400654 Bytes61f2f1d182cb3abc652fdd669c423227e59e514dfcba9672d8cf498aa851e67c
karafka.gemspec100664001.36 KB8a9cfc0875284eb1659f14a960aef6211cc04dcc5cd9cfa35beb9bf32f156811
lib/active_job/karafka.rb10066400788 Bytesedf09ade1fa3778610e2d03d7014c7dcb35caf8012d38d857ab05aab5fdb110a
lib/active_job/queue_adapters/karafka_adapter.rb10066400869 Bytesc52274add31f1edf456c760fdd5543f38770d5a5c20877b57108843e8cadf1ab
lib/karafka.rb100664002.95 KB1b2cb4680b03f4f78d25d13e876d819633523d6827c62d1c0bc84dc45e30cc37
lib/karafka/active_job/consumer.rb10066400953 Bytesa79e64331eca5649c0fe87c4c26f9bbfaae92da90979a1532ef0104e135bc79f
lib/karafka/active_job/dispatcher.rb100664001017 Bytes6ac75aa3cf710a398071596db7cf8875e5d51ada32d1da84c4df43c2d4514cef
lib/karafka/active_job/job_extensions.rb100664001.01 KB727ff923dbc60f5a8e3c0af70c8cf3afb6484b7b5202ee1477b6f431eac8eeb7
lib/karafka/active_job/job_options_contract.rb10066400792 Bytes7d40635bf2ef622d8480bcc2c0bae80e43464eef1235444e8fd8340e49bff92a
lib/karafka/active_job/routing/extensions.rb100664001.03 KB822be748897dcb35b744775894b980def955099879f349615fb81e857f533c80
lib/karafka/admin.rb100664002.01 KB0641c02b3cf8d3e1d767d78cf1c54dd6dd341b380b1967e1fa41e8ad8d8cf5ea
lib/karafka/app.rb100664001.04 KB4bb04cfee68f1eded91575a6cd46562cfb3eb31c1b7edbf5dad6dc2795676177
lib/karafka/base_consumer.rb100664007.37 KB84ca56e62ae78c25448ef0b29eef1400aa7eab7403561d7b5b5af5cce4e92939
lib/karafka/cli.rb100664001.71 KB407a9c3973134847b28d2e7e89f7d9bbcd99ab2952cdb26e36ce0f5a1b0750c4
lib/karafka/cli/base.rb100664002.14 KBd3c869dc219ac1702d26ce14bde0d308793f5501377a9f57d701ee6b7ff43758
lib/karafka/cli/console.rb10066400781 Bytes2d2fc7986540e3dbb988b281620edd61f079ef74645e894ec74e461596639bd2
lib/karafka/cli/info.rb100664001.94 KB0aa97581d97740446f5df0fb1cbd47aa892ba40e21a733b672db1224da00c6b3
lib/karafka/cli/install.rb100664002.06 KB14960871686f547a5073b56c08dae8708d81b5ec761cdf7a4e7077e6d5d5009a
lib/karafka/cli/server.rb100664001.2 KB91a48764c1032a4853c949d48b3bcc81a11220e829b473047cd7894ad432e003
lib/karafka/connection/client.rb1006640014.8 KB3bbbcea072bbe2e81bb90d10972bb8b5375e05c53c50a130b166002421af26d5
lib/karafka/connection/listener.rb1006640011.2 KB21d88798ae93712b4523fd4b80529dcfe543a23eda8ca0ff60141d8d2c5df46b
lib/karafka/connection/listeners_batch.rb10066400623 Bytes43d833d4b47693882dbb029d3a2b58ff04497d7eae6e8c3d6bfba778d77a7b84
lib/karafka/connection/messages_buffer.rb100664002.91 KB2af33d3e5edea967d95031dd7ceacfce061f34a51f3edec131fd5c2938c86fc7
lib/karafka/connection/pauses_manager.rb100664001.39 KB11bce0cd67ea783e1eaca055e44933f92d1e279b397974e2707dc60371b3b000
lib/karafka/connection/raw_messages_buffer.rb100664003.48 KBb4c89b6ac4145d66e15b27b3d7770d3eb626f803d890fe8594b8bbf4b4dfb07b
lib/karafka/connection/rebalance_manager.rb100664002.71 KB4d9b6a0ed58305386dd5d012eb10026aacecf1dacc0cdbaa28906eebab3339ea
lib/karafka/contracts.rb10066400327 Bytes0a2b9ad7b94e44baacf04f81130eb9c68f21fbbcbccdbb7aa0f94a22ea8749e6
lib/karafka/contracts/base.rb10066400621 Bytesc1b2417c33ff3400d0ca5d768b4bf3297877d76916ac89257afe231e24bd2dea
lib/karafka/contracts/config.rb100664003.46 KB7141ae0014d6026b2daaa123a3e72352aba528af0b597a30a538eefa41095284
lib/karafka/contracts/consumer_group.rb100664001.13 KBfb0eae637cec33e0f4fb0921345410a1c6f1dcc3afbe08be2136c8c9a6e55ff4
lib/karafka/contracts/consumer_group_topic.rb100664001.54 KBfe7b30f58904b75baf6b1337fe8e66a0bc06c0379a6e690ed6dc6fe6a44a904e
lib/karafka/contracts/server_cli_options.rb100664001.01 KBaf83e4df06afbcf95e41d9f1eace67a90c896953329a64411324e963dd1bd311
lib/karafka/env.rb100664001.43 KB7c80157166da7eb037f8ad61d9436acb1ffa8d36aca62243732dc55f2451f282
lib/karafka/errors.rb100664002.16 KB8e95febe83ecf9af7602b02b50357a2ea0fc20800e7017cc867547bd31a4f237
lib/karafka/helpers/async.rb10066400957 Bytesdaff3dd9ad38faa862872d03bdfaacf06e27cb85e8cdb6d46bdb3e0c92fbf1fd
lib/karafka/helpers/colorize.rb10066400490 Bytes2291e781abdd116e9d1d45cba9fdadddd1d72f8386e99453f1bb987d767f01f9
lib/karafka/helpers/multi_delegator.rb10066400933 Bytesc472db16985b61622710a9fdb697d6d930d31ee02e512d8f47bec4e6ab4838d2
lib/karafka/instrumentation.rb10066400641 Bytes4751ae47b221c25da4f6ca89b78a8d3c62eb36ea56cfa5e48c6100510caf540e
lib/karafka/instrumentation/callbacks/error.rb100664001.55 KBc7e29b880e8276737ba95ae1a60099ed17989ab226769851ec8c1d7d925b544e
lib/karafka/instrumentation/callbacks/statistics.rb100664001.66 KBe1bf626d132c37fa1379c57ceef8150ec35eeb1df07ab1c7c162a71924d2cd5c
lib/karafka/instrumentation/logger.rb100664001.7 KB9c60d2e6106306243c2125fa7c7ebe4299d4d8e774a5f1df8a7b44db83180f9b
lib/karafka/instrumentation/logger_listener.rb100664005.77 KBf91dc1118e224649fb61a40d646a0b95479add624e9f2017d2f35187f7bac62f
lib/karafka/instrumentation/monitor.rb10066400761 Bytes33f962b4196acb949eec51099f7916c258f452161e20787b26aa6ccf4841d7b7
lib/karafka/instrumentation/notifications.rb100664001.84 KBe8f3f9bf193a723b36fdb9da13a6153ccac963a8a80c364fc91e7123a157e968
lib/karafka/instrumentation/proctitle_listener.rb100664001.08 KBc2fad9e22bccbc8e40d3e5f24156c132ae4ebe1acb8832dee435675c35dde5ef
lib/karafka/instrumentation/vendors/datadog/dashboard.json1006640014.2 KBbae755822da22fa1a886f9761640bf57991f455cc7c2d694c5818ea41b4228e3
lib/karafka/instrumentation/vendors/datadog/listener.rb100664008.54 KBcff8c6fb0bc4ee8ac4b23aaffcfbbb0357ca27318fe3b7db613d129a606438f0
lib/karafka/licenser.rb100664002.55 KB73e3230640db846af055ae9d373e61820df4c3f36179e18c8272a89ac953c7e3
lib/karafka/messages/batch_metadata.rb100664001.22 KBeb0dfc05706e79470564876dafef63fc0584a2914feaf53fe56691c42f8c81dd
lib/karafka/messages/builders/batch_metadata.rb100664001.58 KB2c90197bc45fc1f09dd242bd283b93b21dab6dcc382d2e90a9b05fd50f129b35
lib/karafka/messages/builders/message.rb100664001.45 KB5ce76835abad175061368eb06713e06407ac4f92e6adea45362b112c19b27923
lib/karafka/messages/builders/messages.rb100664001.14 KB31929dfe4b6f0fac2b556d0585de87fa2bbc2ffd442ce7bc2b048d38476ad2a8
lib/karafka/messages/message.rb100664001.47 KB0caa232df6b5079b4070a53d1ed8a1345c033c240ae019f8220b011d6fc0eceb
lib/karafka/messages/messages.rb100664001.85 KB4269d340d6d1dd198937d5e471d9a2b001d347a0f30a329f53da073bd40e43c0
lib/karafka/messages/metadata.rb10066400362 Bytes45159d2a186917f7350a4a0a22fe031603eb406f2c30c30a145ea412f56b1af5
lib/karafka/messages/seek.rb10066400270 Bytes1aeb13ee86e9afb829120c812531a72ed44e169146fa5608e14c544b99226de2
lib/karafka/patches/rdkafka/consumer.rb10066400666 Bytescd9dac1e860fa24c6acb8a47e2c9c53932573fcfe719afc528652cdfbcc474a1
lib/karafka/pro.rb10066400451 Bytes57ee351f4aafb1c151cd2863e30aa4684356440e7a74d35316f242ea5ae71237
lib/karafka/pro/active_job/consumer.rb100664001.71 KB5672c7f36850fd47d088daad821d2affc689ab72f98d838308dfeb2d44a4d3e9
lib/karafka/pro/active_job/dispatcher.rb100664002.13 KB29f73952e6bae6c3cb860b91b68bdcfcb52d1028550f9fece1a721ccc9ce96b6
lib/karafka/pro/active_job/job_options_contract.rb100664001.2 KB7d8ac84d46b863d894578b73a7c0e979eadc87caa766052adf4da10efa28cad4
lib/karafka/pro/base_consumer.rb100664004.62 KBc0b24946d10b6e5541a2c3d8abe10ee5a597144a9fb7e2972bc58eb3d460e74a
lib/karafka/pro/contracts/base.rb10066400684 Bytes2d8a46a8967142d259bd495b788a055ef01362fa9cbc8c8e557d6c706a253dba
lib/karafka/pro/contracts/consumer_group.rb100664001.04 KB24e280d530bedc0bfa1e0b4604db6dbf95d7cb76dc85d95de1f757ad791c3ba8
lib/karafka/pro/contracts/consumer_group_topic.rb100664001.05 KB1ac8425e16ef7d8862c81aeba2ec385c5093093929cd5275c7b8b8c733717522
lib/karafka/pro/loader.rb100664002.56 KB906def3c365486062f900248da2e24b8286f50e58667ce6d62bf037837ff078b
lib/karafka/pro/performance_tracker.rb100664002.75 KB506cf88a80a382d66d8dacb8bf3f45e12f8d22d761de694e293153f985c4cdf6
lib/karafka/pro/processing/coordinator.rb100664002.69 KB0013f63086663000d110bae584008dd4f03e8bc9ff6853c3f6917f2edf79fc40
lib/karafka/pro/processing/jobs/consume_non_blocking.rb100664001.46 KBc8a117df068106e5c8b280f3a123b845f623d458efab932b425c56229499030d
lib/karafka/pro/processing/jobs_builder.rb100664001.21 KBa39474783126be1020d824124042b4da83d640bea3d8392221f7690ac94be377
lib/karafka/pro/processing/partitioner.rb100664002.71 KB1bb5466534ea6107c2d50059cef4dee431ede0713617ef09df1f07e7bff73a8e
lib/karafka/pro/processing/scheduler.rb100664001.98 KBf3e445efa620f35aa471bf4bd2164c276bca8e7b06252d21247d2fb7814cbfaa
lib/karafka/pro/routing/builder_extensions.rb10066400984 Bytesb2e2f819712d3941cdaf5d3273178a29e997ce8c1ad4a9dc02b489c5727913e7
lib/karafka/pro/routing/topic_extensions.rb100664001.19 KB3f6e8bd967939c482d89deab82444c2f0d0484af5a16f441467e380801e554ec
lib/karafka/process.rb100664001.96 KB9404e81cf44766e4eb02ebaace9c9b0aad1a65a36c27eebf04d8a64c7bc1225c
lib/karafka/processing/coordinator.rb100664003.19 KB676c4f8441f1427431bc724cf38ec5b3eefe07172d50cf74cb60f0301aafe9fe
lib/karafka/processing/coordinators_buffer.rb100664001.95 KB3ace122b91164bebd202d674d1e27fc4e7dcba2720c1fd578a440a3d5eee7c3b
lib/karafka/processing/executor.rb100664004.81 KB015e258ca7dc0065a5c1eeb48f52aac20f1b5f1fb22b7099b4fcd618d98d397b
lib/karafka/processing/executors_buffer.rb100664002.96 KB5c5914cfe9fc81a829ba8de61838bf4ea0732a303c4fe5855ea329f5bb0bc007
lib/karafka/processing/jobs/base.rb100664001.88 KB23a92f019df4db97a6d027f60e3f163cdadf62a7b344a2a93c4cc32da4e4721f
lib/karafka/processing/jobs/consume.rb100664001.44 KBdaf14d3543789fd5dbeae5365d74b0bfeb8ca8457686b0d7b0c6f53a73e134f2
lib/karafka/processing/jobs/revoked.rb10066400561 Bytes7e2ddcbb18c88f9761943988cd70a4bf82e528b448adfa3391a3f3477a2ff829
lib/karafka/processing/jobs/shutdown.rb10066400596 Bytes60b136c19adc9f79982e65b0f167f42ff991446a0b3201f71c3dd5c6e7207899
lib/karafka/processing/jobs_builder.rb100664001.01 KB2ffd2e6e02792b16a9641b72798abb0491997ee2fb7d9efb135fc7e908b2cd7d
lib/karafka/processing/jobs_queue.rb100664005.46 KB9dbf7685ab7efa7ac5bd01db3531a7e5674c440754275e495db88f8c6b88fd7e
lib/karafka/processing/partitioner.rb10066400676 Bytes1eacbb8e1c06242594a9d0828b5b5d82e1347a96ba20c71049e8f9655c3ceb85
lib/karafka/processing/result.rb10066400920 Bytese26374d06b25119a3d1e8ebdc88699ec540a9f312d468396a71db206200f7ff5
lib/karafka/processing/scheduler.rb10066400718 Bytes9decebfc26fdec91c0d4c3e06ed122dccac1fb5e4b0546026786ae9550dc181e
lib/karafka/processing/worker.rb100664003.09 KBf5f4d4282260cb17edc399c6297b5ac1bf83bd6380f673cf3a9be65aac088641
lib/karafka/processing/workers_batch.rb10066400658 Bytes6a7a594eec5acbff165ddfbb74d930282b65721aa694f2e73fce851a2152c202
lib/karafka/railtie.rb100664004.43 KBdd630a56b1aef6910d5f1947e1144c506964028464bc0ca66e8c70fd4bf80f98
lib/karafka/routing/builder.rb100664002.66 KB56dc41c8051afe67554f497acefd99f121291ec17bd463684e611d225199e098
lib/karafka/routing/consumer_group.rb100664002.11 KBb922f441ef47d3231191af645d99da555dbe9e62b79956fca0ae2d490f9d3f91
lib/karafka/routing/consumer_mapper.rb100664001.18 KBbd42326c09dd22c60c49053a28a155fc0315565a241ac767d9091c15ed8a6d74
lib/karafka/routing/proxy.rb100664001.58 KB4230a20e0a49a6c5aad1e72118260b09972f7af1703660d09a0598893f42d650
lib/karafka/routing/router.rb100664001.06 KB99b9a1ed4f52bc72c89dc48a613c60be933c92627a906cb8dd6aba724b8b3225
lib/karafka/routing/subscription_group.rb100664001.79 KBf7e9594bac1bbd8d41306e4b5e0ea006be3025412b92b190ab9d568f145700f1
lib/karafka/routing/subscription_groups_builder.rb100664001.94 KB8477712a3e83c970361e5641f6766be239457a2946c1e04b1508a26f28eeeb5e
lib/karafka/routing/topic.rb100664003.6 KBc4ead7dd4bcc02392baf2dd77e1798f4e70d44bf3f4b23ec61ceb2c9e5f5261d
lib/karafka/routing/topics.rb100664001.03 KB3f57db0750359a3d42b06a7b108dd2700516d1f0bde8fec22696af6de4d60e7c
lib/karafka/runner.rb100664002 KBcb0c4fd8448529422f4ee225cfde2e07b94bd41b96fd97f5a35ba7a750b89b50
lib/karafka/serialization/json/deserializer.rb10066400609 Bytes25ca80fd3f8baacc2812ab41359494e62ff0fad0c1ec5214c1b143eba46f3387
lib/karafka/server.rb100664004.6 KBe0d40261924a1935cdb8d5d45aa2c8e74f2db4068dc8e312f96323acf0c02b42
lib/karafka/setup/config.rb100664009.5 KB808237e08bcbfa9870317fec9b5760c02fbe1967d1d3878b3388cf1bb1dad7e0
lib/karafka/setup/dsl.rb10066400555 Bytesd9a93c794c071cda753465d9145dc657a8a2ab5d226e2fc0724e134c644f09ae
lib/karafka/status.rb10066400816 Bytes8dd578522954fe622c01f560433dc525f6a058bd98ae21ef033c51bf61339fef
lib/karafka/templates/application_consumer.rb.erb10066400286 Bytes44a56710679e00a419831a79da526cbad4a0d15c95f2834ee09e03ed0185ee0f
lib/karafka/templates/example_consumer.rb.erb10066400369 Bytesec8631c779428e18877526c0a24d0c33c9140e3abe604a76f387742d84592c63
lib/karafka/templates/karafka.rb.erb100664001.79 KB6439784540828e25fe5d2da03c2e035766c47a03b34fd4eb89d41dddcd2d8be3
lib/karafka/time_trackers/base.rb10066400501 Bytes2f39990f90504428eb22d0e32d5285ee647da6d0838e3194ee824ae2fd9868a7
lib/karafka/time_trackers/pause.rb100664002.73 KBdb3c7e7201e10bfecebc6f15695dab6d98abe9aa66a1cbbb22e246ca06e23a2c
lib/karafka/time_trackers/poll.rb100664001.74 KB5b1e6aad553fbe16b4230f2435e6e88ac2d45595f14b6faceb43579793cff047
lib/karafka/version.rb10066400122 Bytes6e90f58e76ab00fd886a3d11373c2446d4f7ca358e83f10d0eb8311e52ad7484
log/.gitkeep100664000 Bytese3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855