karafka-2.4.0.rc1

https://rubygems.org

karafka

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

funding_uri
https://karafka.io/#become-pro
homepage_uri
https://karafka.io
changelog_uri
https://karafka.io/docs/Changelog-Karafka
bug_tracker_uri
https://github.com/karafka/karafka/issues
source_code_uri
https://github.com/karafka/karafka
documentation_uri
https://karafka.io/docs
rubygems_mfa_required
true

id: 983040

number: 2.4.0.rc1

platform: ruby

spec_sha256: 366948620a0d832d890b0fbc8be6b30b46650bf35d001627c5c742f339a30c4f

sha256: a3055cd3a65ec831b0007b3cff72fe20604e0007ff43f7f0da23d41b66ee1381

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

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

position: 13

version_data_entries_count: 405

uploaded_at: 2024-04-18 08:14:19 UTC

indexed: true

has_extensions:

extensions:

Gem size: 264 KB

Version Data Entries

Total: 405

Unpacked size: 1.07 MB

Full NameModeUIDGIDMtimeLinknameSizeSHA
LICENSE-LGPL100664007.47 KBda7eabb7bafdf7d3ae5e9f223aa5bdc1eece45ac569dc21b3b037520b4464768
.coditsu/ci.yml10066400138 Bytese4ebfa4ad81dd12ffe492ff9168a0fb9c20d3e74e8bff0aa06f54c6c76cef711
.console_irbrc10066400336 Bytes4431d0fa2de6c2846d47a90a2f22d6c5dea9a41f097abf9160e05b2b81b30c6e
.diffend.yml10066400158 Bytesa49a2e6b3b48603cfe838d422d381d219a49d7593c72c9a82c5e10296e90b4b9
.github/FUNDING.yml1006640043 Bytesb38ea0e5490b04e13d6502ee2e9998dc9ecbd1dd4c3b366b7c8c4766792fefc2
.github/ISSUE_TEMPLATE/bug_report.md100664001.37 KB73e8605026be7a5ae4400c84258017d85ca30a564e7f7e8fc86f52a074409c6e
.github/ISSUE_TEMPLATE/feature_request.md10066400593 Bytes739d98d20ac43aedb1aa0c34d93209a440fc0ff142037f76950c95888dc4cfeb
.github/workflows/ci.yml100664005.8 KB33f98a63ee9b9e38f8b1f14e5c48352e89acde42324ed544035cbd8ccb666e3e
.gitignore100664001023 Bytescfaaf830420e24157da66709f087a6f1c395deb5acf38a0bb162c3a77e6fb22f
.rspec10066400311 Bytes19308d005f1740d1061cf145b4c599fec685c773f68561dc60217b08d1295f6e
.ruby-gemset100664008 Bytes2afae0b89d0be84fbce9611eb5bdcf52d69396704dc429f68b6270ce56c8880c
.ruby-version100664006 Bytes5eee6c0c5c6901f5e523f0a434bca4106e1ff7136deb451f982b0bb1a7b13716
CHANGELOG.md1006640058.3 KB8afa96771ce28fae46b05638c1fd1704e6a63484e3e0190a82bc981f571f414d
CODE_OF_CONDUCT.md100664003.14 KBc5be22a6783a9daf04a76f109d5695618c5e55638e2f5c5dc8821c3180ec88a3
CONTRIBUTING.md100664001.77 KB0bbe6d4e34b631d47439606f987678f5db1f64617e9776023155f134f07825c1
Gemfile10066400607 Bytes8e6c1673362ed1eb17bf92b8ccd1de39151266779eef8d39a8daca57e64475b7
Gemfile.lock100664002.36 KB05fdd31ded12be81acd695f75e1728e335b01f75b086dc131d250239c4ba398f
LICENSE10066400677 Bytes23dfaa51df3c89c77a0e7a88caceccfbfc40b93a4341115b1f32608877130487
LICENSE-COMM1006640015.7 KB7ac2dc542b53f8a3913fdd2e930d9b5c1b4e1d11b2316dd61ddc6fe1ceb4fd07
README.md100664005.54 KBcc0a6ba2f90045dd37b6adc9a94cad00803cc44e92fccabf7727ca151deb87bf
SECURITY.md100664001.37 KBdbe7c77ac440f6e65868ef3a7aff23c6a11a0f304767bcd371dcf7bb4a3b76f0
bin/benchmarks100775002.89 KBddd485a05f185b255d904fcaa541a555e0176639781433f1b2e8d23484f96e27
bin/create_token10077500586 Bytesa47a067dbf5cd47591d666fa9bb966d864d6114f700d3d21dce84dba86cb1533
bin/integrations100775008.95 KB328eb5f10819adcfff2878d9c441664712154733b4ae6cd7c22fda7225e5616e
bin/karafka10077500235 Bytescd1e04f7f42ee4f7572d07bc74bf9bf7c318812e92e63a4b7533324149c54fa1
bin/record_rss100775001.58 KB9b8f5fe70fadaadea6a5148407652c48558226d4781a48208a802eebc788c1d9
bin/rspecs10077500373 Bytes30da8748baf4507436d82edcec552afd613a346eb06df83ad1f6f39f198cf3d5
bin/scenario100775001.03 KB84f9aa609a41eec4a40ca1a68769e9e628a0042bb37a5f78c4c94b81dcc90eb9
bin/stress_many10077500282 Bytesdae79a13c09041e24007bc94d05a63c102931b481637deca0d3872465df561ca
bin/stress_one10077500280 Bytese988ccb26b4b8881ba77a3b491a13be95f461b1eda601fd2a55a85299b3bd47f
bin/verify_license_integrity100775001.04 KB5878d10203ab121c982bfe6a8b3b21e789695c93b061ff00f80bb83d440e1b01
bin/wait_for_kafka10077500492 Bytes2a796511dac86a070b4b2ade8a078066af694c20fa6d5f2200eb1eb2bf742887
certs/cert_chain.pem100664001.56 KBacf431d923515fb63c3b68d87b6215d96c108f171df711696b740f3cb24b2bf6
certs/karafka-pro.pem10066400601 Bytes80e379259996ca2d52259405b21c86bb20306c53be5ce0e384b62546466dba4f
config/locales/errors.yml100664008.71 KB0d8a3d3e10cff10be2fe804d66b65899765bb61625698d16fd324b40b833fae7
config/locales/pro_errors.yml100664005.65 KBefbe93ccc78c66ceb3edb5d13b58b7313a1782f50de1fe328e4a62092e305990
docker-compose.yml10066400993 Bytes1e28b6be02ce382f741d7a88dbe1a89bf6a2babafd0cb1a0355e912f49de8541
karafka.gemspec100664001.74 KB3ee0da7f1577bcb5349cc954304bbb0bfd042d1596c935d6065dd0fc72b3775c
lib/active_job/karafka.rb10066400482 Bytes4dea0184240a1b8bae6bc97022365d48a5b03b34e73b88a23410ff89b57ceafc
lib/active_job/queue_adapters/karafka_adapter.rb100664001.16 KB93825ec0b82afbf209ce889c066fd789dd796c82cbf04ae99b64fd958c1528d2
lib/karafka.rb100664004.87 KB712d8e01f619f8f25d06c4679e927bde139fb500f9e66bff13338af1635931b0
lib/karafka/active_job/consumer.rb100664001.77 KB67e7421415d225d2276257091ff2c1e6dfa0c4d96a7adef28434c90e670c345b
lib/karafka/active_job/current_attributes.rb100664001.61 KB82ce0e5448eae1b0cafe7bb8eea67157805e901a2d303063c177605aa3847cbd
lib/karafka/active_job/current_attributes/loading.rb10066400940 Bytes420b26093949a1a26d83cb1f3bd6eee63410ffcc420c6aa57f35e7176d036475
lib/karafka/active_job/current_attributes/persistence.rb10066400708 Bytes345a2b11f67b308f62a97976c2fc5f82a0807f8783ced99935130d25d1b1eb4c
lib/karafka/active_job/dispatcher.rb100664001.98 KBc571dc7f388d5ee52f0ee9be55f66d34aeca1cef0e9e2777b63712d2efb82801
lib/karafka/active_job/job_extensions.rb100664001.01 KB727ff923dbc60f5a8e3c0af70c8cf3afb6484b7b5202ee1477b6f431eac8eeb7
lib/karafka/active_job/job_options_contract.rb100664001000 Bytes9e627a98870a73f87cd05f5023a08d20af77025b7eb93ff9ea39c2076e02d22d
lib/karafka/admin.rb1006640021.7 KBa10f47fa0ac3a907f8b6125746ac150c82dbc7b5d838eaf7d3f792bfaedf831d
lib/karafka/admin/acl.rb1006640013 KB8e466b6b7c0d7ba3c10ab7fcefd4f08d8e0ef6c5c806678e0a8fc1f91de9dd8f
lib/karafka/admin/configs.rb100664003.74 KB5595f91b635c3bcdd82a0181fc000775d89587d3e3cf727cf223fc9765ecec3a
lib/karafka/admin/configs/config.rb100664002.59 KB93061376ccad0ce44a1c609cb87c800bcff60bddb23470b480f32223969f07a5
lib/karafka/admin/configs/resource.rb100664003.07 KB1240149e01191872863e9160c895ab27e065b6bafb18d1a58e71b3ebf183768f
lib/karafka/app.rb100664003.16 KB4bc16a1dfab7d9247d5e3aec3cb3c5e0e5fbdf2809ff8ec05db2aa5a6e7df782
lib/karafka/base_consumer.rb1006640010.7 KBf398ae196a47e3ffa737d57a15acc96cfb3abfef464b34b4468fb76851ed2c31
lib/karafka/cli.rb100664001.77 KB3b8a37121b1744f464dcc2a29a4aada023887a4c464d4af662396e0e3d4a296f
lib/karafka/cli/base.rb100664004.13 KBa3cefa3b4886caffddeabafb7e6cd5ee2443daeecf8c77dfdd3c24709faf1359
lib/karafka/cli/console.rb100664001 KBb32191328d2aa82e50bbdfcb743b953bc583da6a2d552499536f0986f5d8f81d
lib/karafka/cli/help.rb10066400645 Bytes748f300d7930e3ee4740061d5466cb43df685102a55e7ba9a78b0ba7c3b38ec3
lib/karafka/cli/info.rb100664002.06 KB8e5153859d07e6520d42eaf5aadf00e765f08b40a5298ff7237d00ffbf7fa815
lib/karafka/cli/install.rb100664001.99 KBfbd5e4ad14b34051259cd4189e0b90bd8f6f8129154dcea32216733d92972a9b
lib/karafka/cli/server.rb100664002.76 KB7eed404c60d297f0acab1a8fde0cc7884ae9c5681171a06415b30d42033ddc6b
lib/karafka/cli/swarm.rb10066400766 Bytes440cbc4bd73076736528e332da395230f971ccab740edccd5fea20b3195383ff
lib/karafka/cli/topics.rb10066400931 Bytes0c256f8b7faac1f237f5ff90bfb8cae94e74a7fa4884122bdf6b183df558de83
lib/karafka/cli/topics/align.rb100664003.83 KB557de2e1560a5454188bffc7ee9484e07f297356a2980511c7d5f1179816df14
lib/karafka/cli/topics/base.rb100664002.22 KB8bce1464f88b1e1f38d178eecc316037edc42b0b33d8ea1b4754b81516a195f8
lib/karafka/cli/topics/create.rb10066400985 Bytesdc872ce8bb6daaee9d6982b49ffa85ba644a814c39b6f7abf9c109628ccd428b
lib/karafka/cli/topics/delete.rb10066400776 Bytes14259ef3850bce0997240d42464f023e5cbc6cb5227ea1a3073d51049c3c4225
lib/karafka/cli/topics/migrate.rb10066400691 Bytesc41b405fff3aaf46da728531b7ffee9a58bacf6a0f93632c93a12bc21ee6b13b
lib/karafka/cli/topics/plan.rb100664005.58 KB212d703f00ba033612e314b53c0f1459d89fcd0d02995cb9e1a9c4279970c0fd
lib/karafka/cli/topics/repartition.rb100664001.44 KBa7852df8356ad86487830c88b4cca0eacf3bdee61ccfb117d3d19ff1f8c92017
lib/karafka/cli/topics/reset.rb10066400380 Bytes7c6e99accee98528b19212f480392e4899fadf77a0b3fb9592d619af6dcfda73
lib/karafka/connection/client.rb1006640028.5 KB7c87ced41b1b312b891de0ba370fd559f6c643761280843ef77270badaeb2ab4
lib/karafka/connection/conductor.rb100664001012 Bytes43843ac67de5d75d3bda05c474fb60e30954a25d8ac9c6f087df4e408569411f
lib/karafka/connection/listener.rb1006640019.5 KB2ebc1dffa1337791446fc8e8692486060fe1db4a44caf542bd9f636e04ce40f8
lib/karafka/connection/listeners_batch.rb100664001.14 KB1193ab461f6853043359d463761bfee2f72a9f20249cc2ab07a5f5daceed7ca0
lib/karafka/connection/manager.rb100664002.6 KB3a2e74f7d6f1b0bc55899927de016b99435c6c3fac62fdcd836ebcd8d72134c0
lib/karafka/connection/messages_buffer.rb100664003.37 KBcfbda70dec8093815d5c2fd43fc64886e84867323a5c5fa2e10b0f705c2a32f3
lib/karafka/connection/pauses_manager.rb100664001.37 KB48308ac4d96b120532a411b526c87b06a2f74902f64f33d129aa9fca27743965
lib/karafka/connection/proxy.rb100664007.52 KB236792a27de054a1cb7416e19fbdc2996783621a6e18751749bc56f9b65abc9a
lib/karafka/connection/raw_messages_buffer.rb100664003.48 KBb4c89b6ac4145d66e15b27b3d7770d3eb626f803d890fe8594b8bbf4b4dfb07b
lib/karafka/connection/rebalance_manager.rb100664003.98 KB4db0875e2af6bf3b89cb2a85815fade506910d9932bb60d84a5b088d26619b84
lib/karafka/connection/status.rb100664002.44 KB3120f086a27ef3f993dd94f213c8b74264fcddc689813037cd797741686c251a
lib/karafka/constraints.rb100664001.6 KB3200970e2130d5afb2971fcbc0901dcf6654056a35ebf0e450d1ec0c634e5359
lib/karafka/contracts.rb10066400331 Bytese23cf30da1bf460ce8315a4867f51e4dcd5c1b057b7d4ec1a86ac63fd088be55
lib/karafka/contracts/base.rb10066400621 Bytesc1b2417c33ff3400d0ca5d768b4bf3297877d76916ac89257afe231e24bd2dea
lib/karafka/contracts/config.rb100664007.94 KB5df2fd1f434eb31ec278f2f830ce04e2cffa7af7fb2f63ebe4a91f7cb5987fc0
lib/karafka/contracts/consumer_group.rb100664001.95 KB32de03a00cd3a0675874f6563e7a880b5dd887894c7cc052c2ae235c787eaea9
lib/karafka/contracts/server_cli_options.rb100664002.97 KBeeeb43714bc436f832811d71d16ef016268fe97a22a19ce5e798f1e3fdcb1f3b
lib/karafka/contracts/topic.rb100664002.24 KBd0fc395e573d7abcc5a270540d42d29a275a8ed3e9e568783474289f7776cb77
lib/karafka/deserializers/headers.rb10066400385 Bytesdf5242482ad1d31a786e3d65b09484eb022b33fc64e12cf27370ecbcc7a78616
lib/karafka/deserializers/key.rb10066400403 Bytes5c31e17955dcf34babccab32ed28e4595b494ad86f3049ce0a2f3e4b18444664
lib/karafka/deserializers/payload.rb10066400566 Bytese4e8cd90b1a3a84765ac4f409d36806fb5914c040228d2f873e60339af5abb70
lib/karafka/embedded.rb100664001.15 KB7be7ba6901b87c5e02d3226ecad20fe21e4c73cdee1289c030405c91a1172b06
lib/karafka/env.rb100664001.43 KB7c80157166da7eb037f8ad61d9436acb1ffa8d36aca62243732dc55f2451f282
lib/karafka/errors.rb100664004.46 KBc5290e93ca82ca3d754961b7815d2e85d11c28393bf2ce6ecd1182ebeb1651d1
lib/karafka/helpers/async.rb100664001.36 KB861708cedd662c6d3d664ee39363f489e28c7c420b9e6907a1dc66d4e63a1947
lib/karafka/helpers/colorize.rb10066400836 Bytes8576b60ac437a6a2eecfff4403f6801cc4efdd0cc76614f3b61d76ff482b81dc
lib/karafka/helpers/config_importer.rb10066400948 Bytes05a3ca06a7f72451891cad7f838014c48a9b60160e147768f4e2d7779c265e0c
lib/karafka/helpers/interval_runner.rb100664001.3 KB814cbafb7114daf94ed1ca043415b36d53679c3de57c704f9421bdf95077cd99
lib/karafka/helpers/multi_delegator.rb10066400933 Bytesc472db16985b61622710a9fdb697d6d930d31ee02e512d8f47bec4e6ab4838d2
lib/karafka/instrumentation/assignments_tracker.rb100664003.02 KBfb8576bffbd24c5bdb8a491d3d1ed93a2327b3637d6389e77694adf1494eefc2
lib/karafka/instrumentation/callbacks/error.rb100664001.46 KB8a465edb8df302f78449a98a3b0bbb2d4f7a5ed56f2c5cf6310291984b429537
lib/karafka/instrumentation/callbacks/oauthbearer_token_refresh.rb10066400917 Bytes25f65f973b76a384835173e9601887e67a9694cd1570a89569d69413fb46c11b
lib/karafka/instrumentation/callbacks/rebalance.rb100664002.31 KBee27b08764ae1e7620202cc86996cfc21382a59fe7ece9d2ae060079e8dec87d
lib/karafka/instrumentation/callbacks/statistics.rb100664002.09 KBdbeb8a4efa55fdb80937d7b095ce32fc339ced484a55f7ba1cf83b1bffc2fafc
lib/karafka/instrumentation/logger.rb100664001.7 KB9c60d2e6106306243c2125fa7c7ebe4299d4d8e774a5f1df8a7b44db83180f9b
lib/karafka/instrumentation/logger_listener.rb1006640012.8 KB0c1c2152015a887db8a844df70cb6e8e724b188e50264a77e161dc3cafc01b79
lib/karafka/instrumentation/monitor.rb10066400761 Bytes33f962b4196acb949eec51099f7916c258f452161e20787b26aa6ccf4841d7b7
lib/karafka/instrumentation/notifications.rb100664003.21 KB3b26c01742d0a6100b58d6f46d3cf4b4f4517efb14c415d8d134bd68910c7b1e
lib/karafka/instrumentation/proctitle_listener.rb10066400723 Bytes89f2d269f24407336d1152955a92da2315e16583cb289ba1d59545b06e932eff
lib/karafka/instrumentation/vendors/appsignal/base.rb10066400736 Bytesd9f5b3ffdbb9a218a1ebbcc1f3dd6320de95cdb7092d92f7e3fc3c9292c7035e
lib/karafka/instrumentation/vendors/appsignal/client.rb100664004.62 KBc39e937451d1a56b7399a3fb0ce9c2bb68400ada67e947c9a78b98f5b75206f7
lib/karafka/instrumentation/vendors/appsignal/dashboard.json100664004.73 KB303b775ac4a597d912c38e57282141a9fda589ddca141a6948cd31f0be9068bf
lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb10066400788 Bytes94c0f08f46ccb6d1d686b8d74fe62e7074c01eb712b6ded97b51ca91e364c8a2
lib/karafka/instrumentation/vendors/appsignal/metrics_listener.rb1006640012.2 KB0751ab9cea180f803cc9724dd784a171197ebdc3ac06e30631aa690ace1e24b6
lib/karafka/instrumentation/vendors/datadog/dashboard.json1006640016.3 KBc09105abeab5dfb332db4a26ab3e25c3d7acb97b2b4f6e37530f8598b110a3e0
lib/karafka/instrumentation/vendors/datadog/logger_listener.rb100664006.23 KB4a4a2e6534443ea93ba5aa0a3446e364b932fc4977a2ad3aa9dfe1b4784e8bc1
lib/karafka/instrumentation/vendors/datadog/metrics_listener.rb1006640011.4 KBf0268cea07b7e21f141249383bc14c29a34d5fc2e3276e96dddabe1091068d50
lib/karafka/instrumentation/vendors/kubernetes/base_listener.rb100664001.94 KB76a60e4548dbe854cd9cff566caac38fbafc1a4f08c34bd4e9b914bbfa998475
lib/karafka/instrumentation/vendors/kubernetes/liveness_listener.rb100664006.23 KB2041014d718d59c50b299f293b9651342f259fc089e371a6ce0756f3bc922eda
lib/karafka/instrumentation/vendors/kubernetes/swarm_liveness_listener.rb100664001.89 KBb9765c7b3a03b8596b0fd1129a51e1c15de4dc9a0590a604074f6856879c9546
lib/karafka/licenser.rb100664002.53 KBa62f7887c49f58505434cef02b75546c942f08bedc894d646a7dc5695b9f4627
lib/karafka/messages/batch_metadata.rb100664001.53 KB3356e321fe33415523553e1b6672950bec6c79d6c630e476e31ece40d2bfa670
lib/karafka/messages/builders/batch_metadata.rb100664002.56 KBe1902dfa26d876bbcbafedeec3378fcd09640d291802b160293a4b431c562026
lib/karafka/messages/builders/message.rb100664001.7 KB9e97d57d359c2affbb3b646887831f652e13399f519085692dc168934a724044
lib/karafka/messages/builders/messages.rb100664001.25 KBd4fc0af2584665d4f67153a789fae62b90229faefca0db7759742501a0ba66b3
lib/karafka/messages/message.rb100664002.03 KB6b8dc6810b89bb08d124868cecb1942beb5936e5d8319259cd99e61a9558c9c3
lib/karafka/messages/messages.rb100664002 KB846f17fd9f01d11b25c2e7f781f00ae007d2ea18a35db1a6c05aef48ca2cbf81
lib/karafka/messages/metadata.rb10066400808 Bytes9c7aad6b4881c5033cee493f5d6b9a1a06caa544485da53dffc06ed3bf9bccd5
lib/karafka/messages/parser.rb10066400376 Bytese69d075c6f07fdb38c79ba4ac662116df21f77ac253e0c9f4a796cb08ee5e5de
lib/karafka/messages/seek.rb10066400386 Bytes8813b74a471e13c6aa42bd9b11e50e76e2a2ab1996c6e3c913c8e1b83e38c542
lib/karafka/patches/rdkafka/bindings.rb100664004.44 KB53bc99672418355824557bcadcff421c426778d824b92f2a2f274463fc4488dd
lib/karafka/patches/rdkafka/opaque.rb100664001.13 KB2b4e150978c5d97241c4d29b210e371e6f0ca4e45b72d91a5624e98d9f6af6cc
lib/karafka/pro.rb10066400451 Bytes57ee351f4aafb1c151cd2863e30aa4684356440e7a74d35316f242ea5ae71237
lib/karafka/pro/active_job/consumer.rb100664001.86 KB0d2ed0620d2bbf33f209a53adc00b9ac58b72cd56c8d2129624c6b6c50ee5157
lib/karafka/pro/active_job/dispatcher.rb100664002.97 KB702e760f0fbd966bc9b966fce57eeb80ba7df2e8e63baf3fcbd19d4f6d4c3cd6
lib/karafka/pro/active_job/job_options_contract.rb100664001.51 KB29414eb0a2669042a0f7017058b6943d0654717875c3cb37db9912977edad702
lib/karafka/pro/base_consumer.rb100664002.31 KBd1efd524f606cd9ebfc5972ccf7d42917e6f4690af448b98a00211d24d9ddcd5
lib/karafka/pro/cleaner.rb100664001.54 KB02e2a5254dd64b818021a4d02b9da529501de0bcad397e1b8e86a5a2c5172410
lib/karafka/pro/cleaner/errors.rb10066400906 Bytes6db257b433ffa56b5733d9e1a10d2cdcddf0f32534cf1bc728f0b7ebc30e1143
lib/karafka/pro/cleaner/messages/message.rb100664001.64 KBb15406b0c8380aa44560694c88133b19c23034bd35b44157619ffb890eb3865d
lib/karafka/pro/cleaner/messages/messages.rb100664001.54 KBd21a322ffa728e67974b5962c4d5df32605c081512b2f10442dd096c19b3595f
lib/karafka/pro/connection/manager.rb1006640011.2 KB6bf673557d029d1b028323e46d09cbf9b9fc905c033147605534009b3a7b4bbc
lib/karafka/pro/connection/multiplexing/listener.rb100664001.34 KB61bd320a8abef9e6525b175dad689c5332b30935a85a22b49a2ce3d400fec242
lib/karafka/pro/contracts/base.rb10066400790 Bytes043cab88c86d6fda6c1f90200393d9ad030113be5c26c0c461f88a035b2b0c33
lib/karafka/pro/contracts/server_cli_options.rb100664004.08 KB8497192b4f724bbceadc8eb6c8d43f00d959ed357f466b81c187e5b576905914
lib/karafka/pro/encryption.rb100664001.74 KB8ab8863644ef80bc89ef510974f2438fe57960ca51139108734cdd8f161faeac
lib/karafka/pro/encryption/cipher.rb100664001.96 KB30f9b998fb56df9b27ea7bd700d451970f634c7ed12f2a71034fa5f871a068ef
lib/karafka/pro/encryption/contracts/config.rb100664002.74 KB5d5d819936961210398fc0cd422cb09ee911bf3f6cbaef2301188d6e8ce28ea3
lib/karafka/pro/encryption/errors.rb100664001.05 KB4d0e1aa0043c150e6f464417c53892db4a7bbbf4ca6b7a96289714e581a2141f
lib/karafka/pro/encryption/messages/middleware.rb100664001.65 KB82941f350f9dca9b777e7cc7f4d45599f3c1b803fa3ffa226881b3697f0e11cf
lib/karafka/pro/encryption/messages/parser.rb100664002.05 KB02ecab56143f91a6a0253a077e3ec92ba7cde3aafc43bb6a832734579722ad56
lib/karafka/pro/encryption/setup/config.rb100664002.05 KB6eac401cd3abac34cd6e8cb225c70598966e00cc4217b1bbe57dbbbd2ddbec10
lib/karafka/pro/instrumentation/performance_tracker.rb100664002.96 KBf19808831a3756bd481f334818f98dee066346668b0764f1c7fe0d2f83971ec9
lib/karafka/pro/iterator.rb100664007.2 KB184d073a27ccd7924b3507729f7d0cb729092228b3b1c0b7d6ef7c8fb9e34530
lib/karafka/pro/iterator/expander.rb100664003.93 KB8674a8d6b13d12cea2c84a7a7b56e67561120a5f5a3f4da09ab2c9e173489bd8
lib/karafka/pro/iterator/tpl_builder.rb100664007.75 KB34a2d6728a63c17eec72d438d95b2dff770e3b3f0a6dafb582a5a5df9efbd779
lib/karafka/pro/loader.rb100664004.62 KB671e8cdb491ef6dd81288ef1dce9bb87c557745ee4bdab07680de5b049169402
lib/karafka/pro/processing/collapser.rb100664002.55 KB5f6c417f9318318412d295bf820baad6b0e8557685ff8e2acdaf1cd0f9f9f110
lib/karafka/pro/processing/coordinator.rb100664006.41 KBd7929c87ca2298603b043e5fe565f49201e038636f7834289ca3082be1ae4385
lib/karafka/pro/processing/coordinators/errors_tracker.rb100664002.09 KB8c112779c18d5dedad5fb165b4ad358a89acd2f1e8f8f3fd08585239d4bb7cb0
lib/karafka/pro/processing/coordinators/filters_applier.rb100664004.18 KBe756268ad2362134c8b2b3835d89c3c0f12349eee25117517ba4204d7cfc5c7a
lib/karafka/pro/processing/coordinators/virtual_offset_manager.rb100664007.09 KBf8418a4e7eda35dfebb37786239dbb39b61e897f02ae5cc0c807b1c0fa3c0bde
lib/karafka/pro/processing/executor.rb100664001.43 KBedb280726a6311c13f6effa046992464dfd2b08bf325dc3e77c3a679f13e655a
lib/karafka/pro/processing/expansions_selector.rb100664001.34 KB8a73bb590442e181c74e40f77681c3df7ac5b7bf09471487933fe60e28bb40ad
lib/karafka/pro/processing/filters/base.rb100664002.08 KB2f1c0f3c1058e26b577c2ee865ba4a0712b6a5852ed33faef31ae7b613da0499
lib/karafka/pro/processing/filters/delayer.rb100664002.01 KB65fb9604da73926e5676987ad540c842545ce01edf302afdf756d51f9ab68b47
lib/karafka/pro/processing/filters/expirer.rb100664001.53 KB926cc6d57b87b8f3bf570f0a555a6c6f26240b724234889dd0d77439fbda3423
lib/karafka/pro/processing/filters/inline_insights_delayer.rb100664002.58 KBad90b16a9ecd46621f7ec8e20612b40f503555a40da8bcc782c0c7566b406d76
lib/karafka/pro/processing/filters/throttler.rb100664003.1 KBedb2ef3291f81a810cf48c990f834cbd77ebd903e4d95e505908b1a18bb79518
lib/karafka/pro/processing/filters/virtual_limiter.rb100664001.86 KBe62432bdfdd28c671bb0971ca199fbba3ef15930a2c0c07ad953305dd14a3cef
lib/karafka/pro/processing/jobs/consume_non_blocking.rb100664001.49 KB748d7fb95febf31129dae0c6bec7e2a24ba1dd507c1b7e58dcabb0d6ce9d51cd
lib/karafka/pro/processing/jobs/periodic.rb100664001.28 KB7fef3f0fd6bb4cdc75eb2a768d283f704318d7072ebed3116f87e85cef778984
lib/karafka/pro/processing/jobs/periodic_non_blocking.rb100664001.17 KB76171bce41fe8922dbd76215fab55eb74fa5164e19c66dd0f8faf17a58de8d37
lib/karafka/pro/processing/jobs/revoked_non_blocking.rb100664001.39 KB947725de4211ead89c6d3a5affdda0abc96c4fe26e753c01d0f62e8de4e58dd2
lib/karafka/pro/processing/jobs_builder.rb100664002.25 KB5c82fc0a937a79dbcb93c129eedcc29f005da08c96fc1a6cc068a1258fcadca1
lib/karafka/pro/processing/jobs_queue.rb100664008 KBe87c1bda871886d62a471bc150225ea69ac056abdba04635802e8f87be91f77c
lib/karafka/pro/processing/offset_metadata/consumer.rb100664001.98 KB206bee85d6afb0dbe417256834da4cc3f9f790a584cf91fc0ab21716f68aac95
lib/karafka/pro/processing/offset_metadata/fetcher.rb100664005.7 KB40f3ac43082feb9f2496bfbe656b89ba1fc8083c52185f81ae9d9170caca1df8
lib/karafka/pro/processing/offset_metadata/listener.rb100664001.88 KBee8faadaff6f875afc668c9798920f170fa39687a2522ca3e018375af9bb4e1a
lib/karafka/pro/processing/partitioner.rb100664003.12 KBbd6bae312bc23e6eb1297552c9b515c82b9d01f4d52042a13fca5f611bbeb1fe
lib/karafka/pro/processing/periodic_job/consumer.rb100664002.51 KBb0a6dd865e0adc243a7acfe271d01f862d84c5e536b22684a99c82544b6e5de6
lib/karafka/pro/processing/piping/consumer.rb100664004.97 KB852a31b621cd48af33a3e2555e842f271ce7ad67ac9b935675949b9b043b8e1e
lib/karafka/pro/processing/schedulers/base.rb100664004.92 KBe024ea6b28f574e135958aee5713fad5b91e5e437afb26a634975df2aa71e6c5
lib/karafka/pro/processing/schedulers/default.rb100664003.87 KB0725df462ab204ec6bac137fdf97fee06ae257a86b75ea359f151c8f76ada63f
lib/karafka/pro/processing/strategies.rb10066400688 Bytesd2f94105d0bebb5a934f79013342600b89d27a52142f84364e31a7181e038036
lib/karafka/pro/processing/strategies/aj/dlq_ftr_lrj_mom.rb100664002.21 KB3a200b170b4bba8354d8815b11ddb2458744a313bd5847c57dbf0602eeb2c500
lib/karafka/pro/processing/strategies/aj/dlq_ftr_lrj_mom_vp.rb100664002.56 KB6505076074b0fc4e399bca3bae8d054270ad850e840a3fdaff6fc8598416303e
lib/karafka/pro/processing/strategies/aj/dlq_ftr_mom.rb100664002.57 KB473843aed9d8c887ff007f192b956b02b71c9a05a3717f1f77b8b6aca9eb36e4
lib/karafka/pro/processing/strategies/aj/dlq_ftr_mom_vp.rb100664002.17 KB3cacd22298b500cec59a2804379062e54950418ddd728f278937865d2985a067
lib/karafka/pro/processing/strategies/aj/dlq_lrj_mom.rb100664002.13 KB9348c5b311fd361577a4e64ff96aec9a47ef92e0d1413d4b2593ba5a0a327831
lib/karafka/pro/processing/strategies/aj/dlq_lrj_mom_vp.rb100664002.43 KBfdfc5cfa172272a66367a567510c9848aa75323dcc95a7b8c8720fff257f5cf4
lib/karafka/pro/processing/strategies/aj/dlq_mom.rb100664002.3 KB9420125c9f408d26bc8a1cb81fc5263895ddf54f891bb42ef0062c80813473ac
lib/karafka/pro/processing/strategies/aj/dlq_mom_vp.rb100664002.49 KB5870ba1d0c8192ec80e83df8c333945c9bc56d92bc5902d8777ecd14ced32079
lib/karafka/pro/processing/strategies/aj/ftr_lrj_mom.rb100664001.08 KB90842b8dcd44b527a2c99f283ba02daefc641b43be776d6b4f6fbe8625bf50da
lib/karafka/pro/processing/strategies/aj/ftr_lrj_mom_vp.rb100664002.1 KB042b62a915adf5fbad60463c10ebf9c40146bf1129048c77f42a286ff8d5a6aa
lib/karafka/pro/processing/strategies/aj/ftr_mom.rb100664001.1 KBc8e6ff9b61a32a574903ff5c72ea572d03268117f59cb909366e15da28b96656
lib/karafka/pro/processing/strategies/aj/ftr_mom_vp.rb100664001.73 KBe81d29e1785711f0d5ea94a5cebb93196b16436cc6f9ae2e18b8ed9d3a4b6f5c
lib/karafka/pro/processing/strategies/aj/lrj_mom.rb100664001.07 KBf5bff6e6e5655e992978b7e512f6d41d99f90dd41e617be0c5c282331f6ab4f0
lib/karafka/pro/processing/strategies/aj/lrj_mom_vp.rb100664002.76 KBc4ca5e7b4b7eb01697d18dc3d867b3cf75c91472b15e1e93166a797f9c0d06da
lib/karafka/pro/processing/strategies/aj/mom.rb100664001.08 KB4ee0427391674c25623867fdc1e20eac34780a4bce618d9e4a5ac3bce4fd1568
lib/karafka/pro/processing/strategies/aj/mom_vp.rb100664001.5 KBb99f5434109ed3a772053cdde5bc75113e8fbfe7f64fed89d651e515b0452575
lib/karafka/pro/processing/strategies/base.rb10066400810 Bytes48bcdc0f84f4114594f510f66c538154a73a1aea07b39767c76471829f8e31e3
lib/karafka/pro/processing/strategies/default.rb1006640011.9 KBfdc3f52b7c5769c0e3572da462ce6959196b14cd310f6762de69bf84328ca10a
lib/karafka/pro/processing/strategies/dlq/default.rb100664009.68 KB9f927e87dd18e9572b8b53ec66515dc5efaf3f141562ef7ef1ca5d50b11f3ce2
lib/karafka/pro/processing/strategies/dlq/ftr.rb100664001.66 KB51c82b9ebcf8028ee016314feed87a7c349e53e18ae6ee4148b49e4b58f75e9e
lib/karafka/pro/processing/strategies/dlq/ftr_lrj.rb100664002.38 KBb7c949797926ce258cce6a50fff4461fa53824cc6d937330147ede90132af78c
lib/karafka/pro/processing/strategies/dlq/ftr_lrj_mom.rb100664002.09 KBbe8ca3012b1ede290f1d62d9051ed92fd2d1d5bcd2b451b0527d0e13def0d788
lib/karafka/pro/processing/strategies/dlq/ftr_lrj_mom_vp.rb100664001.26 KB88ef6c998946be73d89604f54a31d7be8092e6da8cdaa227e7fa7167c5b6034c
lib/karafka/pro/processing/strategies/dlq/ftr_lrj_vp.rb100664001.24 KBf62c29ce2ff69eacd99019d3f969b3faadec6771084f06d33c2e3eb737ec7b4d
lib/karafka/pro/processing/strategies/dlq/ftr_mom.rb100664001.74 KBc92f003970d98b55a8a77675be15ee0a4c81ac36aed1a7074652e59f5a317884
lib/karafka/pro/processing/strategies/dlq/ftr_mom_vp.rb100664001.18 KB740bed2de7fb068b462db91508cd7fc4926d8fd54aacc1be578816cd898726ac
lib/karafka/pro/processing/strategies/dlq/ftr_vp.rb100664001.11 KB449f38465231b0bd99375a06a02dcbf870a19e99a41e5726c31efb30c540b3f9
lib/karafka/pro/processing/strategies/dlq/lrj.rb100664001.86 KB14135456bf85f51bdc27f4bd954ea1ea71dc2ae2dea30519d06e5d384c711dcd
lib/karafka/pro/processing/strategies/dlq/lrj_mom.rb100664002 KBd93426f4ba02c250c662f06c1d4e8ecd2eef2db200d3317407a68e938220fe74
lib/karafka/pro/processing/strategies/dlq/lrj_mom_vp.rb100664001.07 KB24c50be1e7d8edfec422dac33c7496e2d19cee1f5a300aba1b67f544b736f592
lib/karafka/pro/processing/strategies/dlq/lrj_vp.rb100664001.2 KBf9df7e2848db87a5f5672a0bdc69bfc95a7a52bbee7b9b4bf3c4bdba19a8c228
lib/karafka/pro/processing/strategies/dlq/mom.rb100664002.14 KBa22e91cdf76a2adf7921a87892d107e6470e064b4f6bed5bdc9bebfeae563f11
lib/karafka/pro/processing/strategies/dlq/mom_vp.rb100664001.06 KBb049ae5b236e2bd977f86c3cb627d8d52ab78bce60a329d5cacfdff1c9b17c26
lib/karafka/pro/processing/strategies/dlq/vp.rb100664001.37 KB70648edfe8acba629f0d85ac0e6ec93c28aeb4bedf5387b01c212853315779f6
lib/karafka/pro/processing/strategies/ftr/default.rb100664003.91 KB36e3d470625fff9059bd624ab4968bac080f0c896d8744b35816e17e6bddb86c
lib/karafka/pro/processing/strategies/ftr/vp.rb100664001.24 KB103871c2efad9385a508c4e79b1da52e8623e9cd2d804168df3a803a728fa453
lib/karafka/pro/processing/strategies/lrj/default.rb100664003.59 KBfdc8d77451c818b72e6234641dd53dc37a3e60921db489cfc8c52edd572d9059
lib/karafka/pro/processing/strategies/lrj/ftr.rb100664002.49 KB11d3afdae4c76eab0a5656e8c0f239655130260c5cdbfa98e1a8dde49014f69e
lib/karafka/pro/processing/strategies/lrj/ftr_mom.rb100664002.38 KB10d7a884a1668f01ab0d21ebbc3f3b22da71389c40e7ad235370c754ee326eb6
lib/karafka/pro/processing/strategies/lrj/ftr_mom_vp.rb100664001.14 KB4424e0c1a7457bb1668b1c28fe2aacf4ceae65688e860d9c252021c4a6f6a569
lib/karafka/pro/processing/strategies/lrj/ftr_vp.rb100664001.15 KB959eacf793f09bc3c5384fb52178f32a58775dc256cf0c4867265cefd4214f21
lib/karafka/pro/processing/strategies/lrj/mom.rb100664002.5 KB1d5654149886c8fd50d1e0b01edd8f42378b617c82e1b72129da6135f2e8fc90
lib/karafka/pro/processing/strategies/lrj/mom_vp.rb100664001.14 KBd18a8ff5ffc5ec07fe986465dbba4b31322a104f7f5c599d5437c6605bb6a8f7
lib/karafka/pro/processing/strategies/lrj/vp.rb100664001.05 KBfc9ab6370b508868e89a6ac3695a0dc007e8514938de5cbaf8faf7e73ea2664e
lib/karafka/pro/processing/strategies/mom/default.rb100664001.35 KB0c8716cfdf0bf009bac299ef4c839f771c5b7022185cc352385f8e68c46d662a
lib/karafka/pro/processing/strategies/mom/ftr.rb100664001.55 KB06d3916e6f5fccf3498e927cede7d49399e1c5e610262b6de4fe3718fbca11b2
lib/karafka/pro/processing/strategies/mom/ftr_vp.rb100664001.03 KB51f2e06c71cb2d82c4577a1a27451751104cdaadfef8e5b2da477604b3e5dd04
lib/karafka/pro/processing/strategies/mom/vp.rb100664001010 Bytes8012aed6a8b82aeac15a0540323f1d67a6402cb2427f6eb6c904890bcff05206
lib/karafka/pro/processing/strategies/vp/default.rb100664008.02 KBd46bf0c0f055bad694a0bf367fa301b351e8b3bb76430f8110abb9f8aac046b7
lib/karafka/processing/strategies/dlq_mom.rb100664001.8 KBb55b667f041c123e42ea3dd7a7a37b828ddfdd52244bd273019f7f72cec1a2b5
lib/karafka/pro/processing/strategy_selector.rb100664002.57 KB2ade97fcad239f1529cea686406d0fd18ee57366495af48cc5866a6a14abfec0
lib/karafka/pro/processing/subscription_groups_coordinator.rb100664001.93 KBd9dcda2158e893c21e3fc3180c5dbbc1e58b6f2c4be31ea25e6081a14a91d5cc
lib/karafka/pro/routing/features/active_job.rb10066400909 Bytes4a42b2453042f662ca0b6bb317e02c2c22c6424ca557b2ebca419bcc340a03f7
lib/karafka/pro/routing/features/active_job/builder.rb100664001.64 KBb3dbcd1411f27f378216babaa54db4c187af77f74ff3f94cfbb3d5ed1238d924
lib/karafka/pro/routing/features/base.rb10066400751 Bytes7d824d04e6d8f7536885f3d9791833e88acdf5c06b0604d8ce807bcabe2a559e
lib/karafka/pro/routing/features/dead_letter_queue.rb10066400870 Bytes2e58fa50e0e4b951b5089e4c8c4b3e81a2e9dc571d35dd800248561bf4e0e4de
lib/karafka/pro/routing/features/dead_letter_queue/contracts/topic.rb100664002.26 KB3815ee94869bcb5dfc58a93b9364aefca4c418b58a2d3297e37d783fe55949d0
lib/karafka/pro/routing/features/dead_letter_queue/topic.rb100664001.39 KBbd9f0db96811bf1d2f9011189e240518ac1279e754c7ffeebeb94f9809aa4060
lib/karafka/pro/routing/features/delaying.rb100664001.06 KB14dcfb46334453ab8da31b5449b3fcab457f1590d6b25a53f66e3ba07678ccec
lib/karafka/pro/routing/features/delaying/config.rb10066400851 Bytes1ed5136643c000eaad7c2faeadf606e687fb18cdc1d7b0604f4927920a1e8f53
lib/karafka/pro/routing/features/delaying/contracts/topic.rb100664001.41 KBd9edb7f00e6a78ca718ee8b9cb8bf3497b4111dc65ad367f38f21507ec6ebc67
lib/karafka/pro/routing/features/delaying/topic.rb100664001.78 KBbddb918a98ab5bd887470635a414a29e90232dd661a6e48c92442a8258f6533e
lib/karafka/pro/routing/features/direct_assignments.rb10066400874 Bytes41ae3c6133ca22cbf6e2fa880256ad9f596b4a6593025fe0f4843dbf5c6f0dd2
lib/karafka/pro/routing/features/direct_assignments/config.rb10066400875 Bytes793236af7aec1018712d2914f53fea1ec60ea2bc0af3df7dfc8688173e399f0e
lib/karafka/pro/routing/features/direct_assignments/contracts/consumer_group.rb100664001.77 KB178368d9e2798b15de76aedd3c943434b94fb1c4ac55afd6a8c4cc19a3be17d3
lib/karafka/pro/routing/features/direct_assignments/contracts/topic.rb100664004.04 KBcab77fe817f5e7e28098b1acab08c898d615d51cd17ba24f6c3f48f321e8fbe2
lib/karafka/pro/routing/features/direct_assignments/subscription_group.rb100664003.07 KB4e0bb7641e0b25bf265a0a2538f18cb901e57d1c82ebf53d77cdce031cf7f543
lib/karafka/pro/routing/features/direct_assignments/topic.rb100664002.48 KBea65857abef9b014c82df34784cbd596f412891b4facf2a62ac973f14b8aa33f
lib/karafka/pro/routing/features/expiring.rb100664001011 Bytes53f8cff399779ccccea1908ae48ac58e08e523be8d832b3d88b17b72da405d21
lib/karafka/pro/routing/features/expiring/config.rb10066400849 Bytes383b750cce7da98af94f4f5b6870f44709288966f0a755f92cb8added75ed53a
lib/karafka/pro/routing/features/expiring/contracts/topic.rb100664001.41 KB3650983e5a46b7bc81bba5fa29ba9f0559fad4f374f35e1dd8fd4bb31c3b7f7b
lib/karafka/pro/routing/features/expiring/topic.rb100664001.77 KBcf92d8ff1001baac51f977c85b82e4f59f6d98a820fc07d1ebd616c8fb6b37dd
lib/karafka/pro/routing/features/filtering.rb10066400917 Bytes9f38b1477f7bc4acfb2310b6d3175c9f63e65e8d8fab73f92b8c662cc0a51900
lib/karafka/pro/routing/features/filtering/config.rb100664001.22 KBffe3e6422a883b211a95b06774a90d0c0b3fba3e0023acae0bb8056f5a2c6cc9
lib/karafka/pro/routing/features/filtering/contracts/topic.rb100664001.48 KBf3c96bdbaddf7778ea2061835dc4c7160bc7e24fcc37b7d14265bcccf6b54f3a
lib/karafka/pro/routing/features/filtering/topic.rb100664001.68 KB8e829521e53f1c0787281ca13dee90bf3a3690c4c4afc34d55836d3224965fef
lib/karafka/pro/routing/features/inline_insights.rb10066400859 Bytes3ae20de517b8912eed2e1f99ebb8fa1325fa552ae8c5969cb6e8420818b35f25
lib/karafka/pro/routing/features/inline_insights/config.rb10066400947 Bytesd36c01053331a35a38b5650c0ad6d4b1a57f316e0a6a53cf75605df21f8c220e
lib/karafka/pro/routing/features/inline_insights/contracts/topic.rb100664001.39 KB62c8130d9348a9d95860e5ff74dbd44ca5dc278ee4f545f479ce555beb7ea833
lib/karafka/pro/routing/features/inline_insights/topic.rb100664001.83 KBf1aa12ffffa92c9e22473add0520b1949b22f3650f4fcf0080760c10140095e0
lib/karafka/pro/routing/features/long_running_job.rb10066400938 Bytes1829c9bf0e6f65a888e59980c8250e4f3822d60c3a2f38d9d648fb58fcfd4254
lib/karafka/pro/routing/features/long_running_job/config.rb10066400861 Bytes0bbc0e893369eb2e4b01fdce1d50c949c5e71c2214b91b5d2f8a45ab5629101d
lib/karafka/pro/routing/features/long_running_job/contracts/topic.rb100664001.3 KB6f6d75846f6735dcc1cf2e9114191d456422bfb9cd1ac6b8cc70c1b32ffe4814
lib/karafka/pro/routing/features/long_running_job/topic.rb100664001.41 KBb869123c5b13cca808205cf883c1ff9c4fb295df60fd8bc8ab35d0586dd4da25
lib/karafka/pro/routing/features/multiplexing.rb100664002.41 KBb33a9d83a11dda7ae2789cd7386ab312b5c84ef63e96821edcda61326d51a482
lib/karafka/pro/routing/features/multiplexing/config.rb100664001.05 KB8f84e34e70fd777544b68d92141b97f07d3ba95198959c21ecf7f1fdaabd155b
lib/karafka/pro/routing/features/multiplexing/contracts/topic.rb100664004.08 KB2fb878e758c8cee886c44342a1bce8c6a08aebcd07ff5c31e0a8f5548000430e
lib/karafka/pro/routing/features/multiplexing/patches/contracts/consumer_group.rb100664001.33 KB1bcd7c58af4fae8cfe7bcaafb8451ddb21c4005fc2d615311110eed1cdbd639c
lib/karafka/pro/routing/features/multiplexing/proxy.rb100664001.47 KB9b82b0a4a4c0c0c1a366bcaa168962c997261e76338eb06b377abc4c7fa1d130
lib/karafka/pro/routing/features/multiplexing/subscription_group.rb100664001.35 KBe93380f779731eb310ca60f817f7191b7da0dfaa0951909786751b6a91151f03
lib/karafka/pro/routing/features/multiplexing/subscription_groups_builder.rb100664001.42 KB0139fa2de68ffd80ee450f60e8c91089636155440e654fd0ab67c00bcda8690a
lib/karafka/pro/routing/features/non_blocking_job.rb100664001.42 KBeb871e49457a0b65b08af87ba266184c7f78a29b3a78ece8720e43d525d03855
lib/karafka/pro/routing/features/non_blocking_job/topic.rb100664001001 Bytes8d53be7194dcd6950f33b9e07650f4b7461c7d5c0bbd20d47d853890afd7ff57
lib/karafka/pro/routing/features/offset_metadata.rb100664001.41 KB40d9219fefc8595902170db86e7c2af592db69b18f330fb6cfdb218c3264cc3f
lib/karafka/pro/routing/features/offset_metadata/config.rb10066400977 Bytes7c2e0cd30b26f2b794751328c785200f7a687b653273cfc42cf57e3e09e80cff
lib/karafka/pro/routing/features/offset_metadata/contracts/topic.rb100664001.47 KB5e9a30576bbe84de945b472ea50ccf0899c21190f5d90cb48e56f9c72922009b
lib/karafka/pro/routing/features/offset_metadata/topic.rb100664002.44 KBb5be42d67eb92eb3c051df4a61d1320f650b5d39e33f0a4765beee86894d0d89
lib/karafka/pro/routing/features/patterns.rb100664001.22 KB65b651fa8284f28ace503ad2535782bb2cbb7f0a402c520bff087a74b67dc4bc
lib/karafka/pro/routing/features/patterns/builder.rb100664001.35 KBc1aaf29e335d88c1a7fec1c40d9a8b670453bf3832120332e59ffbac8d8c4a0c
lib/karafka/pro/routing/features/patterns/config.rb100664001.73 KBb7077485f396fa2d3a6a37159bde16ec93a56a47736cb96cd0f192befd5de2f1
lib/karafka/pro/routing/features/patterns/consumer_group.rb100664002.91 KBc8bdd48d65343b10afc97f200474de6594891972928ffdd242d473ec03cdf1bd
lib/karafka/pro/routing/features/patterns/contracts/consumer_group.rb100664002.36 KB7d9bc2dac203527fa52d00aa5088c0d5bd596e92d9bccf5d0ed9214264410a03
lib/karafka/pro/routing/features/patterns/contracts/pattern.rb100664001.53 KBa6fe7c75520d276b68e8a40b187ae7548081455d78324807bfb2eaa010b32746
lib/karafka/pro/routing/features/patterns/contracts/topic.rb100664001.41 KB4791dbc7f65020e0bb586fbdde174a1cf201e4a20ee149f3377a5b2197a84237
lib/karafka/pro/routing/features/patterns/detector.rb100664003.21 KBd088e00a2fad3e8ec7e9efaab9787e3c68d377b6cb2b7154aea6b2a7e26f2855
lib/karafka/pro/routing/features/patterns/pattern.rb100664004.03 KBd1933110eaa04424ec81535b2377980d2f342edd93eb98b119610a8b4654c0f3
lib/karafka/pro/routing/features/patterns/patterns.rb100664001.29 KB4187fdd1de30cf803c8961356bc13a4da93b0a2896afc506568bf2ad9e958162
lib/karafka/pro/routing/features/patterns/topic.rb100664001.77 KBfdb645db12f10ee3e52f6d1a2db4afb92d5b4fc8edc456889024be0493df52e6
lib/karafka/pro/routing/features/patterns/topics.rb100664002.26 KB6e43be3a2cfaabaf116b7468b3dec76d9d0e5762d9f3c7425d6d3622475a9510
lib/karafka/pro/routing/features/pausing.rb10066400851 Bytes3620fee01f87cd1a9d7411b655191d29e7586c648d05fcabdf37779dda1014ad
lib/karafka/pro/routing/features/pausing/contracts/topic.rb100664001.85 KBdf68eb57f25eee08b1ae96992eddd98ee6a6ad669fb4c524c78a3aa92c1def8b
lib/karafka/pro/routing/features/pausing/topic.rb100664001.75 KB0a8fb3085cfb6384da69b7f70eaf08b5ac8057996500c31f391c9b7a4e7e9b40
lib/karafka/pro/routing/features/periodic_job.rb10066400983 Bytes3d5ddd6d390137afd89fbd771040f6425af53642d6a0d222dc8c6ad38486b56f
lib/karafka/pro/routing/features/periodic_job/config.rb100664001.13 KBc42629c703bff97c9caa5f246e958c9647ab8ded25cb0d8e9582565b7d92f33e
lib/karafka/pro/routing/features/periodic_job/contracts/topic.rb100664001.64 KBfaad59c36a88c6e9e8c22b7fde46f2c9f21032206803aae92b506712bc24e09c
lib/karafka/pro/routing/features/periodic_job/topic.rb100664003.95 KBe97f18efbc5c6ee30a380a25554baadee6fe98547883e4467d3a6c6d32c51859
lib/karafka/pro/routing/features/swarm.rb100664001.29 KBd7d5945569040e67d13343e28ad5b79d8944606a0ef5d14508f2a4e6674bfcfa
lib/karafka/pro/routing/features/swarm/config.rb10066400893 Bytes67e989485586baf34b94c52d31cc62ed59150c3f437b3d4874f6a9db2151607d
lib/karafka/pro/routing/features/swarm/contracts/routing.rb100664002.69 KB7cbd2207cbbb839b5c7333322a3e7f1124607d52f5e00c71ae3d0dd4747cf924
lib/karafka/pro/routing/features/swarm/contracts/topic.rb100664002.91 KBa4fc9977cfb42962f00ffa8b0ea01503245a4979ca9e01680c574bbde89a6fad
lib/karafka/pro/routing/features/swarm/topic.rb100664002.59 KBfa26dc7643b85f3fde8b92ca01802554abf9f875a5abaa5afb653f4a8d9c0724
lib/karafka/pro/routing/features/throttling.rb100664001.13 KBecd91dbc95f1cac69b6926077b648948164b51c7182a141bee01f50e40f78a0b
lib/karafka/pro/routing/features/throttling/config.rb10066400926 Bytese1790267ef775682c0205d36fd25f7d25899d311a8c539536342f7a09016fc1e
lib/karafka/pro/routing/features/throttling/contracts/topic.rb100664001.51 KB1f2b428bf418fd31c76eebc3a651a46e3577712648b563ce46459ecce2b22a5e
lib/karafka/pro/routing/features/throttling/topic.rb100664002.2 KB7bc8909af23e2b419e8d3f922898c3ef3e801c4c2cd83fb63a288380668fb8e6
lib/karafka/pro/routing/features/virtual_partitions.rb10066400949 Bytesde50e6f5d24e8f44103e1d681572d19904dc77d5eef875b15059c8e42dbdf1ee
lib/karafka/pro/routing/features/virtual_partitions/config.rb10066400956 Bytes70a03cf568ec93c7e76d84f8e9bcc33822be90c2afaab8886306f47ee2f78eca
lib/karafka/pro/routing/features/virtual_partitions/contracts/topic.rb100664002.04 KBd2f80f347fffc86d049f07faa794a0ed5bf721f97406f00918e6316220432669
lib/karafka/pro/routing/features/virtual_partitions/topic.rb100664002.53 KBe475e1c267daf6566255077c21bab8dbd87944b4eba9bf48bb0c04bb3a649672
lib/karafka/pro/swarm/liveness_listener.rb100664006.46 KB83528467c3f57349a7c1fe5862721c4992440631301a983c5006ea3f9ec72eee
lib/karafka/process.rb100664003.25 KB5232f16c57a3dc7ed72ae1a0001824b8446ceaed21689710f889c2e127d684b9
lib/karafka/processing/coordinator.rb100664007.57 KB2aac1c2be5661b76abf26e5d79c36189df0b01544eaa38d38a00316bb6c444df
lib/karafka/processing/coordinators_buffer.rb100664002.23 KB221969afd3e7fb45632e0096b9bf359dbff6bb63ca04f7ae609432944e9fa31b
lib/karafka/processing/executor.rb100664007.43 KBb97193ac6c967dd3789aa781be425d0043217df5888b1101a48fbf9dff110d65
lib/karafka/processing/executors_buffer.rb100664003.22 KB1e32cde5e794fcd27f7f79edf7b70cd82076d0686add76d9cbe5cc4b02def1e7
lib/karafka/processing/expansions_selector.rb10066400819 Bytes3eeb757181c1403142e5063dda41fd9031951354801d220a16fb8b0eda695c76
lib/karafka/processing/inline_insights/consumer.rb100664001.79 KB788bf99dc2e5bab8e5ba28516ac2f15146e92df18a5f24af93df69c9b4c0a3a2
lib/karafka/processing/inline_insights/listener.rb10066400480 Bytes032892bd4096fb0979d46682ce94d642f1c170dfcbbe41db5873f564a71d4396
lib/karafka/processing/inline_insights/tracker.rb100664005.36 KB4c5f4c3e928d9be312758fdfc9aa6438c143e3c85b3537af3619353e6bccdc02
lib/karafka/processing/jobs/base.rb100664002.54 KB2146f530be646e6e575d93aa3a42f6a54e686c76419ed694f6de4e0cca788735
lib/karafka/processing/jobs/consume.rb100664001.31 KB3cf0fd156970d422a813558c1d45ae4820923ff9ddc7e39c915782aeba874e2e
lib/karafka/processing/jobs/idle.rb10066400787 Bytes775ebc191282090107deb98d537c7e6f4a08864a108230c5495dc79f72c412d7
lib/karafka/processing/jobs/revoked.rb10066400702 Bytes5ff67d63d0e79c08eed418b2d1dc7ea54beb8dbf6f41dbfeda79f69c48177ad9
lib/karafka/processing/jobs/shutdown.rb10066400739 Bytes781893e07107ee2191d822efaa876bdff2322019e6a533337f2a1415d0ce3abc
lib/karafka/processing/jobs_builder.rb10066400945 Bytes00d79cb98b1f7ecc7cf741f3fa46426c05e650d0f948850e8ab6bc352827c8e0
lib/karafka/processing/jobs_queue.rb100664007.46 KBe53e94ed9c92669b9a9e2896818f795b9cc9ea62b17d43e55206896755dbc31e
lib/karafka/processing/partitioner.rb10066400824 Bytesa14757c248a5c733fcd7bfd1ff31e848f16f90ed66f83676853da4ed7b08a87d
lib/karafka/processing/result.rb100664001020 Bytes65f48cf2a034d16c4338fca3557d87e899956a037ccb0b3feb1548be97735a86
lib/karafka/processing/schedulers/default.rb100664001.28 KBf2183b4eb17f815f5bb65899c34b8b866b1be1c4a45581d2163d6ef9b03498e6
lib/karafka/processing/strategies/aj_dlq_mom.rb100664001.53 KBb51cf93449a31ee3abb7ff0023eab95ff1ff7b01d876d2579f3898e78168b5d7
lib/karafka/processing/strategies/aj_mom.rb10066400461 Bytes5ee3917968cab8cde257fd8d9be9bc0cab310e992c8ae660f0b263c921e53f48
lib/karafka/processing/strategies/base.rb100664001.96 KB7962e0178c4e56c71d021522ac9a9067e685c4c4c1d94b562177933af2af9457
lib/karafka/processing/strategies/default.rb100664006.67 KB19179eb81ddb65aa480ab86b24a307282c8fc68f22ff418a4773d0a8e825d4ff
lib/karafka/processing/strategies/dlq.rb100664005.46 KB51c7dbb242c4a6d3e3898087437b2d17938b212c73cc0402ddbd66667d241965
lib/karafka/processing/strategies/mom.rb10066400771 Bytese79e3596a639247b0b9823a1615ec6516c7de50251017b47ed6961319246d567
lib/karafka/processing/strategy_selector.rb100664001.26 KB52a4025bea77fd7f2768d18244937e58f60e761943c1183bdb549bb2ffac0c1d
lib/karafka/processing/timed_queue.rb100664001.6 KBaf0a131fdd96d5a5849c15f0bd7c633ae65f9b3a8b39114af83ca4a735670640
lib/karafka/processing/worker.rb100664003.19 KB12d6f240cb9bce8d79d23553d52ba7c5f36e8f26147d8d9a4642c8b21e164ef4
lib/karafka/processing/workers_batch.rb10066400735 Bytes1c2d88a4b8eacf1425d38419aec1ffb261d85276e0631a5aaa8a1da6a40c528c
lib/karafka/railtie.rb100664005.37 KB7aeb77ffd201a2b9378aed224690c759f3b4acd1ee740bf6f1507ca8be9e785a
lib/karafka/routing/activity_manager.rb100664002.36 KB8ed8dd07b21698fe6bfef31732bc970448bfe62a5ff24c8a9a8cf114496f5dbf
lib/karafka/routing/builder.rb100664004.67 KB609f797874680eeb4901b7375ca23e54fc4b403fadaa778b51245ee68e76d3db
lib/karafka/routing/consumer_group.rb100664004.17 KBb6e5f4da2440ea904df1b10974f0789dda06fca0628d5048741fad512fbf7bad
lib/karafka/routing/features/active_job.rb10066400338 Bytes30f236cad4b9bfae9cc952a289851d6c01e06f059962fc2424b753c5cefcd7cf
lib/karafka/routing/features/active_job/builder.rb100664001.05 KB98ffc36fcc07f8e04b5d01f52fae747994e12f99934597b3351f54159b22da10
lib/karafka/routing/features/active_job/config.rb10066400299 Bytes488a9d1a6c48d59e3d0f833d8fe9423cfd2bd677e247bedb2ecd6218ea633c1d
lib/karafka/routing/features/active_job/contracts/topic.rb100664001.57 KB9744cff83a3bd4a7a1f481a1c17ce8e32d7490f2e232544c3c6eb1e79fb7db77
lib/karafka/routing/features/active_job/proxy.rb10066400248 Bytes3947778773d6a4f2e873470181eded98000665ba3517a91761e7e9394117aeee
lib/karafka/routing/features/active_job/topic.rb10066400993 Bytes4655606aede3ce4186ad736cc9311f5bf30238eeacb38d1d32f35f3d45b20a4e
lib/karafka/routing/features/base.rb100664003.51 KBae1dc417cf9f920402e4d7b1857b4c7041017539fbfc54db24ac53c7319fb141
lib/karafka/routing/features/base/expander.rb100664001.82 KBd38f48e308823049cb9a6ad8212f75fa9c5a38ee456c3e9f3a779cc07bd3aa77
lib/karafka/routing/features/dead_letter_queue.rb10066400494 Bytes2ad5b4f2c4f77be2933586265cf5fe14141d3a3badf7a57c928709ca0a90c511
lib/karafka/routing/features/dead_letter_queue/config.rb100664001.13 KB010f19046de2228143a924405e5fd47a3aa89c6c303b853ca18fd44a7389db98
lib/karafka/routing/features/dead_letter_queue/contracts/topic.rb100664001.85 KBf5b14740f7f52b79d97ba2a28fc4d67bccd2cfa9fec06a8e939456509a446058
lib/karafka/routing/features/dead_letter_queue/topic.rb100664002.27 KBd50cadace72905376446faa05b5155cb61a017544ad3ba478a9a34ec5f4820bc
lib/karafka/routing/features/declaratives.rb10066400472 Bytese032c26efb9f4414ffb32e3f8e76e56e8c723df585de3d9cecafc4323b7eded6
lib/karafka/routing/features/declaratives/config.rb10066400387 Bytes881fae53261fe894be5638cdbb12f6114bb60bbc8c8df341dd9a3317f6511c94
lib/karafka/routing/features/declaratives/contracts/topic.rb100664001.07 KBdad1a7360a91ceb58289621f806b3ddbc0cea3d9f7a55797827b7cc507260e32
lib/karafka/routing/features/declaratives/topic.rb100664001.28 KB1335f455c5310c24752b383370b6bd5eaeb5f0eba48673d40c9cfed2aba13399
lib/karafka/routing/features/deserializers.rb10066400239 Bytescc4b2a483bb8d83bcb0210739b53a08991528876515414ccf61eb929ef83c149
lib/karafka/routing/features/deserializers/config.rb10066400355 Bytes6fa82aa4be6ad32880414d4b9f31b74d3e83ef25304338e44e53e8ef54839c42
lib/karafka/routing/features/deserializers/contracts/topic.rb10066400981 Bytes6b495f35817945afd8eef767c75f9fccabd61eeee0707a054793ad78a700b1ae
lib/karafka/routing/features/deserializers/topic.rb100664001.71 KBd606c9fa4c930739861c67d4e1890dfd384d24b8688db77afab04f87da0b7494
lib/karafka/routing/features/inline_insights.rb100664001.61 KB22727dea16d23c35e4086b8ae74f0b68661f70868d089e67d2a60fbba0d33495
lib/karafka/routing/features/inline_insights/config.rb10066400300 Bytes85141f03e948a45ff1ccc6b1f8d22d3f5053658ac0c6db6c1df5e01aaf282129
lib/karafka/routing/features/inline_insights/contracts/topic.rb10066400772 Bytes08a572812b58d4161820efea23b149cecd7d1fb79bdac5241441090d46d7bce0
lib/karafka/routing/features/inline_insights/topic.rb10066400757 Bytes7a4f174ddb9155cc21fc52f7c0dd7cca837edf79de37f642dafcb9e4615590a8
lib/karafka/routing/features/manual_offset_management.rb10066400642 Bytes3ae42fa14515bb195bdd5b6da90b595146b1589c39c6b7e0d21ac88c64bfc1a6
lib/karafka/routing/features/manual_offset_management/config.rb10066400329 Bytes1e7419d90d72315f281ed7818fac3f627226c8ce8896548b2f02d8ba2d5807c9
lib/karafka/routing/features/manual_offset_management/contracts/topic.rb10066400785 Bytes6b69ab2c89a8f4f75c13fff0120abb0c35c99978c2546b560606cb2f46a05646
lib/karafka/routing/features/manual_offset_management/topic.rb100664001.21 KBbe5c6be5e82e6805472700cae99d97991265d33b3c270c0831e76917af1add36
lib/karafka/routing/proxy.rb100664001.64 KBe2abcb3e4a4c62683f8fd93471d8822066d4d8374c4be1605d520812edb954bb
lib/karafka/routing/router.rb100664001.98 KB4f4fb1d64f15b0b01d8ee976770e23615af94d205094eb3c2dee089d3f339d82
lib/karafka/routing/subscription_group.rb100664006.04 KBaa16f481cbdc0480ca31ebbaa912771db0d0fb3926e94588bd45a316337ae59d
lib/karafka/routing/subscription_groups_builder.rb100664002.62 KBa159bc6ddb2346211ab5882871240a590c78f5251f044e0affa199e384873048
lib/karafka/routing/topic.rb100664004.28 KBf9ac4dc2d610e7290ec63c0cbc724b27f9576e1ac6bbb02a1385d9647b0f3e9e
lib/karafka/routing/topics.rb100664001.26 KB69fad8453faacaa7e4c34a7125bb617ad9b0dd8735f90339ed961897b03f9a7e
lib/karafka/runner.rb100664002.5 KB8d8d1666f64c6821bf3b75cc64a8f3491a218fd227a6c0943569dcfa6df9c0e5
lib/karafka/server.rb100664005.52 KBbc643e365fc1c8f4e07e1f7575c125c4c7afc51ffbaeef2b40541980456bf89a
lib/karafka/setup/attributes_map.rb1006640010.2 KB21640785d330a2b85418aee2ee459df36e60ad15a31da5bd402ee15026feeb6b
lib/karafka/setup/config.rb1006640021 KB14ec5446319a813d993573eade58c73d0321be0a85c21da358b89b5e12e88681
lib/karafka/setup/dsl.rb10066400555 Bytesd9a93c794c071cda753465d9145dc657a8a2ab5d226e2fc0724e134c644f09ae
lib/karafka/status.rb100664002.47 KB4b0ecbc85ffba585dbd6eac90d94100829e6c33e739672b985a61d077b2e0d87
lib/karafka/swarm.rb10066400795 Bytesde8961f7cf26d555508579d88aecc5deb37acaf5c38ac25dbf348454184d1404
lib/karafka/swarm/liveness_listener.rb100664001.61 KBdaf3cf1422bcd0e296bcfaecb63881b3c66e070fb7ae11ee10c9b9598928ac51
lib/karafka/swarm/manager.rb100664007.48 KBcb992beeace4d90c02f5c4dbed023986f2a1b297b5a4519b4a70c792c081adcd
lib/karafka/swarm/node.rb100664005.39 KB6432385c1b9d15fb2fec40050840ff125c220229d270092ab7aaf0514b91a2a2
lib/karafka/swarm/pidfd.rb100664004.3 KBd88dcc882017946a860622ba82cf4c47c32d4d5f2308b6df576371c9508de8f7
lib/karafka/swarm/supervisor.rb100664006.69 KBfb16167f466d2341d422264529ac9e2807849571080a8de77bcc095e82e0d5e2
lib/karafka/templates/application_consumer.rb.erb10066400286 Bytes44a56710679e00a419831a79da526cbad4a0d15c95f2834ee09e03ed0185ee0f
lib/karafka/templates/example_consumer.rb.erb10066400369 Bytesec8631c779428e18877526c0a24d0c33c9140e3abe604a76f387742d84592c63
lib/karafka/templates/karafka.rb.erb100664003.66 KB9f0a5e0df242619a98fd2aa97041d48ed2cdf539183942273076f59d6a1e3110
lib/karafka/time_trackers/base.rb10066400387 Bytes49b0470d8031ae5b30aad7c9294376b8ce777da4a25eb9f4d037851068a43913
lib/karafka/time_trackers/pause.rb100664003.75 KB1e3d27300f63fc2910e358cbc6d8c7eb60b8851594cb93f5a61901e4b1ee7168
lib/karafka/time_trackers/poll.rb100664002.07 KBa1f5688f32f6901a93ebb913c0676703f22ff33da0aa377100bda155f6312d16
lib/karafka/version.rb10066400126 Bytes36488d0ca1405435cfc85aa40beeca60bb4db977d7ea155fa719e87d1f39419d
log/.gitkeep100664000 Bytese3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
renovate.json10066400159 Bytes37f6199435407485a4fb924c3283710f2c938adf69489aaeb5ab208bf5f4229d