karafka-2.0.33

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://github.com/karafka/karafka/blob/master/CHANGELOG.md
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: 982983

number: 2.0.33

platform: ruby

spec_sha256: 6ec3b65808e634269ff6f386454c8a6baba8680faab42c1d08b381bb6d92ae7d

sha256: 54655402008a522cf0dd52677952bf6f5d8c4c0dea3bd954532c8a05fa4a097c

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

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

position: 62

version_data_entries_count: 212

uploaded_at: 2023-02-24 15:45:35 UTC

indexed: true

has_extensions:

extensions:

Gem size: 138 KB

Version Data Entries

Total: 212

Unpacked size: 495 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
.coditsu/ci.yml10066400138 Bytese4ebfa4ad81dd12ffe492ff9168a0fb9c20d3e74e8bff0aa06f54c6c76cef711
.console_irbrc10066400336 Bytes4431d0fa2de6c2846d47a90a2f22d6c5dea9a41f097abf9160e05b2b81b30c6e
.diffend.yml10066400158 Bytesa49a2e6b3b48603cfe838d422d381d219a49d7593c72c9a82c5e10296e90b4b9
.github/FUNDING.yml1006640043 Bytesb38ea0e5490b04e13d6502ee2e9998dc9ecbd1dd4c3b366b7c8c4766792fefc2
.github/ISSUE_TEMPLATE/bug_report.md100664001.3 KB49838cfbc9c1c052cc8cb1e8889276bee6caff8e24a270c49322f2d61e5dd7d2
.github/ISSUE_TEMPLATE/feature_request.md10066400593 Bytes739d98d20ac43aedb1aa0c34d93209a440fc0ff142037f76950c95888dc4cfeb
.github/workflows/ci.yml100664003.98 KB38a266ba7f3affe9a7bb181e7beb3a8341bc25b89cda0cd94de557fb539cdbbd
.gitignore100664001023 Bytescfaaf830420e24157da66709f087a6f1c395deb5acf38a0bb162c3a77e6fb22f
.rspec10066400238 Bytes64727e60211dca3ec6afb2fc0acb3b5f77f6dc82f3da5ca9f602f7566bad2a32
.ruby-gemset100664008 Bytes2afae0b89d0be84fbce9611eb5bdcf52d69396704dc429f68b6270ce56c8880c
.ruby-version100664006 Bytes3822728783049fc2f22a56d1ee74d62352c49fbf81c6b54b50830d6f61c3af22
CHANGELOG.md1006640027.6 KB328360cefc749a1ed0e481e30c128eb03d3fd6da940400c0e72afb7907d24e54
CODE_OF_CONDUCT.md100664003.14 KBc5be22a6783a9daf04a76f109d5695618c5e55638e2f5c5dc8821c3180ec88a3
CONTRIBUTING.md100664001.77 KB0bbe6d4e34b631d47439606f987678f5db1f64617e9776023155f134f07825c1
Gemfile10066400336 Bytes835cc2e99d2d7e7c9bedba273fa7d729deb4a04a823c49203262bc9f5f5a13e0
Gemfile.lock100664001.78 KB508d19fbdda2e29a2380c3fefe2d60ecf726629d5d9bb175b626a83319d20ceb
LICENSE10066400677 Bytes23dfaa51df3c89c77a0e7a88caceccfbfc40b93a4341115b1f32608877130487
LICENSE-COMM1006640015.7 KB7ac2dc542b53f8a3913fdd2e930d9b5c1b4e1d11b2316dd61ddc6fe1ceb4fd07
LICENSE-LGPL100664007.47 KBda7eabb7bafdf7d3ae5e9f223aa5bdc1eece45ac569dc21b3b037520b4464768
README.md100664005.49 KB136ed3f27467f7f2611e721f961450ba7e0f2ce9816c46c920d2dcda30d01a35
bin/benchmarks100775002.46 KB58f01609998decbf1cb652e85187919df1e16ade206c5ce069f284478427bd1c
bin/create_token10077500586 Bytesa47a067dbf5cd47591d666fa9bb966d864d6114f700d3d21dce84dba86cb1533
bin/integrations100775008.24 KB24f18f7fcf49662f453d9653ca0b56fd4e5154caf22c46dc00b02cf93b1ca404
bin/karafka10077500252 Bytes88923d0d6fc29eb328800283db2fe2bd14271f1de9bdaf55bd7fb79351ee69b7
bin/rspecs10077500130 Bytesd3c41365806f1f3e0372fde43c94e5ddf195b374aef963f138e449e4f3e0a403
bin/scenario100775001.03 KB84f9aa609a41eec4a40ca1a68769e9e628a0042bb37a5f78c4c94b81dcc90eb9
bin/stress_many10077500282 Bytesdae79a13c09041e24007bc94d05a63c102931b481637deca0d3872465df561ca
bin/stress_one10077500280 Bytese988ccb26b4b8881ba77a3b491a13be95f461b1eda601fd2a55a85299b3bd47f
bin/verify_license_integrity100775001.04 KB5878d10203ab121c982bfe6a8b3b21e789695c93b061ff00f80bb83d440e1b01
certs/cert_chain.pem100664001.56 KB0e7b1f6d0c593954357a26b094ce8120234d38cdd69d0949033d92f3fb67cd74
certs/karafka-pro.pem10066400601 Bytes80e379259996ca2d52259405b21c86bb20306c53be5ce0e384b62546466dba4f
config/locales/errors.yml100664004.11 KBe187415715cbc64abd7c4d4bd15e5cd1299890e4a5c72ac0ed6f2f7346d4e342
config/locales/pro_errors.yml100664001.13 KBd13333cda16056c565fe174c9a17cb618164d999d7bc2db5b5742f9b5a9f5ca8
docker-compose.yml10066400703 Bytes774cb5c32a06fd6fa1d9aef48fce4b1a6f797013a209c7c0da1a20db19b88d12
karafka.gemspec100664001.75 KBed47d3357f25d16a27b79d3cfbddfbc86735400bf007dd10f568ac949dda8a80
lib/active_job/karafka.rb10066400482 Bytes4dea0184240a1b8bae6bc97022365d48a5b03b34e73b88a23410ff89b57ceafc
lib/active_job/queue_adapters/karafka_adapter.rb100664001.07 KB4a34f4985a036d36b3a203d10dfbf8ed36b313e8101b531c7a1cf9964e127580
lib/karafka.rb100664004.52 KB7096ff62338f9f1186367ce7fc5d7af36a33f8579225f572e400998a5d705aaa
lib/karafka/active_job/consumer.rb100664001.04 KB89f22c2b9d94f555edc0e8b30319449bc92760a2ed2b705eb6962507491d4009
lib/karafka/active_job/dispatcher.rb100664001.81 KB97ef31e5b0aac5cc0bd7d987fc33c1d95609ded7b820cd0db96089d02d3c5cac
lib/karafka/active_job/job_extensions.rb100664001.01 KB727ff923dbc60f5a8e3c0af70c8cf3afb6484b7b5202ee1477b6f431eac8eeb7
lib/karafka/active_job/job_options_contract.rb100664001000 Bytes9e627a98870a73f87cd05f5023a08d20af77025b7eb93ff9ea39c2076e02d22d
lib/karafka/admin.rb100664007.46 KB919b6b803a8bff4f4a8c0ad78ddc40a2788c959c5d3d118baf7bf46d5428bd89
lib/karafka/app.rb100664002.12 KB3531d6ce3cdb1fdb26277c8bf991aebea1f6cc22673a49df823cdeb8db74c301
lib/karafka/base_consumer.rb100664008.85 KB0f62e161b5ad9e0bc209219da5b517ff19f598d9e2cfd04148728ce203a3bce2
lib/karafka/cli.rb100664001.71 KB407a9c3973134847b28d2e7e89f7d9bbcd99ab2952cdb26e36ce0f5a1b0750c4
lib/karafka/cli/base.rb100664003.16 KB2369d00167f12af492b5debd8bd2524165072897ef5b46fb43aac858b0c6af3e
lib/karafka/cli/console.rb100664001.01 KBe6cef8adb07a433ab3c9d4d3a5c72b2878f5c440a8432e39cfbfc582a09b1323
lib/karafka/cli/info.rb100664002.03 KBd51c1682bd208348a5742c163680eff34164f26e933507a18065f3b005989395
lib/karafka/cli/install.rb100664002.06 KB14960871686f547a5073b56c08dae8708d81b5ec761cdf7a4e7077e6d5d5009a
lib/karafka/cli/server.rb100664002.54 KBfb21bd2cf0248f25e625e293f132d9918bd0f571cd9a37e18c6f1bc3876c55ba
lib/karafka/connection/client.rb1006640016.7 KBf749d56f667a78141ffc82736452ac44295758d41872e2281a2f8964d9356ea0
lib/karafka/connection/consumer_group_coordinator.rb100664001.67 KB64031ac7a72bf81e34e4ca7013f8014ae6d8ceb47c370df24a7cebe9bd13e8d3
lib/karafka/connection/listener.rb1006640013.4 KB0698419629aa564f00217f221ba71a4dbad1086d1e5c1a8383dc87e33445bd3a
lib/karafka/connection/listeners_batch.rb100664001.03 KB1a45c64cafaef6df7f2b8b24a4a57a6d9f5968722db621b86a4e8673b5ef27fb
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.86 KB66cb7225873fa6072e2fa4637feb5bfcddd45a055a0fa1c0bf15b913d09c08ad
lib/karafka/contracts.rb10066400331 Bytese23cf30da1bf460ce8315a4867f51e4dcd5c1b057b7d4ec1a86ac63fd088be55
lib/karafka/contracts/base.rb10066400621 Bytesc1b2417c33ff3400d0ca5d768b4bf3297877d76916ac89257afe231e24bd2dea
lib/karafka/contracts/config.rb100664003.47 KBace80bd20e0653011f96b275a1c33676d55daef893fe397ac09be26f88f7f2ea
lib/karafka/contracts/consumer_group.rb100664001.73 KB2003a1564568dbfffed97c7b3bd6751b8155cf4c8fa439a07bb60b389e4a6b20
lib/karafka/contracts/server_cli_options.rb100664002.97 KBeeeb43714bc436f832811d71d16ef016268fe97a22a19ce5e798f1e3fdcb1f3b
lib/karafka/contracts/topic.rb100664002.2 KB2ed391fea442d233400638798855afe1799f0d656eb0de0e90b3e9d66756d8b0
lib/karafka/embedded.rb100664001.01 KB4dcc066f6c66e20343e18083a702dd282c9558376a374bc850dc90bba05923b7
lib/karafka/env.rb100664001.43 KB7c80157166da7eb037f8ad61d9436acb1ffa8d36aca62243732dc55f2451f282
lib/karafka/errors.rb100664002.22 KB5167d1ff01f07aeeed4249e96ee449cd81862fd0bdc293e712a5192a488ed91f
lib/karafka/helpers/async.rb10066400957 Bytesdaff3dd9ad38faa862872d03bdfaacf06e27cb85e8cdb6d46bdb3e0c92fbf1fd
lib/karafka/helpers/colorize.rb10066400490 Bytes2291e781abdd116e9d1d45cba9fdadddd1d72f8386e99453f1bb987d767f01f9
lib/karafka/helpers/multi_delegator.rb10066400933 Bytesc472db16985b61622710a9fdb697d6d930d31ee02e512d8f47bec4e6ab4838d2
lib/karafka/instrumentation/callbacks/error.rb100664001.46 KB8a465edb8df302f78449a98a3b0bbb2d4f7a5ed56f2c5cf6310291984b429537
lib/karafka/instrumentation/callbacks/statistics.rb100664001.55 KBea5e84ffd6c673dfb6cd4d0f194c1cccd2b634521fd7c242f0a27a466f039422
lib/karafka/instrumentation/logger.rb100664001.7 KB9c60d2e6106306243c2125fa7c7ebe4299d4d8e774a5f1df8a7b44db83180f9b
lib/karafka/instrumentation/logger_listener.rb100664008.72 KBc99721a0caf50ed48730e6cb8a5612b983f4aa0a121d9af5b30fa35210b64358
lib/karafka/instrumentation/monitor.rb10066400761 Bytes33f962b4196acb949eec51099f7916c258f452161e20787b26aa6ccf4841d7b7
lib/karafka/instrumentation/notifications.rb100664002.09 KB2b6681e72875a4a7be635e4013947b0ca936870e1fd91cc148a4f6b9d0c13d89
lib/karafka/instrumentation/proctitle_listener.rb10066400723 Bytes89f2d269f24407336d1152955a92da2315e16583cb289ba1d59545b06e932eff
lib/karafka/instrumentation/vendors/datadog/dashboard.json1006640016.3 KBc09105abeab5dfb332db4a26ab3e25c3d7acb97b2b4f6e37530f8598b110a3e0
lib/karafka/instrumentation/vendors/datadog/listener.rb100664009.87 KB8a4ad7b9b465d8a5fd1a99e60822f69b1b1e11d918e23182fab1553572dbaeb6
lib/karafka/instrumentation/vendors/datadog/logger_listener.rb100664005.37 KB34973cada9b3aa3c7b8dc78d3326ba107e6fdd18dbc2e2d0877a1082de11ac61
lib/karafka/licenser.rb100664002.53 KBa62f7887c49f58505434cef02b75546c942f08bedc894d646a7dc5695b9f4627
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.91 KBa130518e88548f9f99a75d040959f0ad6190898a02947d8e95c91590843b61ac
lib/karafka/messages/messages.rb100664001.85 KB4269d340d6d1dd198937d5e471d9a2b001d347a0f30a329f53da073bd40e43c0
lib/karafka/messages/metadata.rb10066400362 Bytes45159d2a186917f7350a4a0a22fe031603eb406f2c30c30a145ea412f56b1af5
lib/karafka/messages/parser.rb10066400367 Bytes1e926457feba304da9ba3831b0e25091ed88567b102ccf4af60b8f4b716a8ef2
lib/karafka/messages/seek.rb10066400270 Bytes1aeb13ee86e9afb829120c812531a72ed44e169146fa5608e14c544b99226de2
lib/karafka/patches/rdkafka/bindings.rb100664004.42 KB044a155a2499b39ad73d82c7015338136623c0526757b95e3d9bf8e5d496851c
lib/karafka/patches/rdkafka/consumer.rb10066400666 Bytescd9dac1e860fa24c6acb8a47e2c9c53932573fcfe719afc528652cdfbcc474a1
lib/karafka/pro.rb10066400451 Bytes57ee351f4aafb1c151cd2863e30aa4684356440e7a74d35316f242ea5ae71237
lib/karafka/pro/active_job/consumer.rb100664001.94 KB8af9f87e0d23dc8a5cf56613c96f37e3ec2eadbc7961e07ba4cc12ab3b00f476
lib/karafka/pro/active_job/dispatcher.rb100664002.96 KB0a2b2aa4e125a3734f9f4afd0ef4a214fb37dce2a769e5ee3a714f98ce261c2a
lib/karafka/pro/active_job/job_options_contract.rb100664001.5 KB3ccdbc3beaef420f68a3ca0c740c73199db14ecaf7e769404c65432b3b3a0773
lib/karafka/pro/base_consumer.rb10066400892 Bytes2846a56c760065b0781c8912674248b8883a0cc5fc7158aeea8ea5577dc3b422
lib/karafka/pro/encryption.rb100664001.74 KB8ab8863644ef80bc89ef510974f2438fe57960ca51139108734cdd8f161faeac
lib/karafka/pro/encryption/cipher.rb100664001.91 KB873fb8b5dc1aeeacb1c8e137ef600e672e26d0ce4b1c39523e2e7c3bd2800f06
lib/karafka/pro/encryption/contracts/config.rb100664002.65 KBf361f58340b3d761dc9c85eb1cc82a408ede5f0ebb544efaaa96961ae552811b
lib/karafka/pro/encryption/errors.rb10066400828 Bytes5c22bcd3e7c8780ec1d3f2a15535fe129eae706fd5c677cd56c7dc68ac78379b
lib/karafka/pro/encryption/messages/middleware.rb100664001.52 KBe61d219788d374283eb9e86593f1e4ee171f940daca22a156b3330f83c6224e2
lib/karafka/pro/encryption/messages/parser.rb100664001.83 KBbbb183b320d3931d3e1969eef99fa6e9a7773946e5d40b58d195109d42598ff8
lib/karafka/pro/encryption/setup/config.rb100664001.78 KBe83cade1130b12e60e42a080781107381510a76082341c143b6693918bb80feb
lib/karafka/pro/loader.rb100664003.56 KBa2b1c54118984f3af750c91fa4f8a873ff37e7eb5e8e750aa896c84ff287438c
lib/karafka/pro/performance_tracker.rb100664002.9 KB5a64beda5ff6abe59d4c9e4b3d6b8b8fa42bfda85839fc969eb800f25c06d35a
lib/karafka/pro/processing/collapser.rb100664002.55 KB5f6c417f9318318412d295bf820baad6b0e8557685ff8e2acdaf1cd0f9f9f110
lib/karafka/pro/processing/coordinator.rb100664003.67 KB857c8c7643e8a984564b271b075822490fe1d88dff39519a51390e4a43a72ce1
lib/karafka/pro/processing/jobs/consume_non_blocking.rb100664001.49 KB748d7fb95febf31129dae0c6bec7e2a24ba1dd507c1b7e58dcabb0d6ce9d51cd
lib/karafka/pro/processing/jobs/revoked_non_blocking.rb100664001.39 KB947725de4211ead89c6d3a5affdda0abc96c4fe26e753c01d0f62e8de4e58dd2
lib/karafka/pro/processing/jobs_builder.rb100664001.79 KB7b24ee0ec660e614a5273b8c237a3d7b719340d78b2175d2c18d2fe52c5214d5
lib/karafka/pro/processing/partitioner.rb100664003.12 KBbd6bae312bc23e6eb1297552c9b515c82b9d01f4d52042a13fca5f611bbeb1fe
lib/karafka/pro/processing/scheduler.rb100664002.06 KBb4643c3fd6915b2a946e12f52311ab44f887c73b400019de130abb58189e67bb
lib/karafka/pro/processing/strategies/aj_dlq_lrj_mom.rb100664001.19 KB38e08a691bb7d78632ded6d0919e6d418e05c1ac9a7c58c248621593bae1fda4
lib/karafka/pro/processing/strategies/aj_dlq_lrj_mom_vp.rb100664002.39 KBfe9be73c0b67acc9dc3674867d65890622cd0f8a6069d09fdaf5c91eeb52ba7c
lib/karafka/pro/processing/strategies/aj_dlq_mom.rb100664002.34 KB2fbe95ee56c897d3013b96bc5e8713dab1fd95045798f0e9131aefd115e49e70
lib/karafka/pro/processing/strategies/aj_dlq_mom_vp.rb100664002.61 KBc12a1fcb09c671db75e706ca3da6ce6626a9ada05d4f2ec33a1a5d64a701564d
lib/karafka/pro/processing/strategies/aj_lrj_mom.rb100664001021 Bytes259bbe02ea85ba289d59b535a4e972d72e5850705337c6567bc86c4ce6783aae
lib/karafka/pro/processing/strategies/aj_lrj_mom_vp.rb100664002.39 KB8f77288c5df32cf9f4c16e6e8b4d29c9d06f22435f727ab16391162ae7dd169c
lib/karafka/pro/processing/strategies/aj_mom.rb10066400985 Bytes63692fd26f193ac7fbfa9694c73d366d95bc05fe98ad632147381b49d76e5bcd
lib/karafka/pro/processing/strategies/aj_mom_vp.rb100664002.2 KB3d5e4e18aa78b84ca684f7a152eec2cc849acd148bb1ffa4a59171cf1c835da5
lib/karafka/pro/processing/strategies/base.rb10066400810 Bytes48bcdc0f84f4114594f510f66c538154a73a1aea07b39767c76471829f8e31e3
lib/karafka/pro/processing/strategies/default.rb100664003.35 KBe40e4df220a7be7dca941085c0a771200ff57263047a28e55a477afdf1a701b1
lib/karafka/pro/processing/strategies/dlq.rb100664004.44 KB3fe2c6db8bdd19df9c3bb067f43becf38df94e7217e231e1f92e018aaff10f90
lib/karafka/pro/processing/strategies/dlq_lrj.rb100664002.05 KBcc83e24ea1ded1e5f35f20336245c015d41fa8b41032463d5d4d216a3e4a8013
lib/karafka/pro/processing/strategies/dlq_lrj_mom.rb100664001.91 KB8ddef8c30858e21855399586582d10eaf09316769925a699311d3ddcd8c9ab6c
lib/karafka/pro/processing/strategies/dlq_lrj_vp.rb100664001.07 KBbc99cf1571a2ea6ca6c441632008fa239509524b164ea8579261669b4da3c63d
lib/karafka/pro/processing/strategies/dlq_mom.rb100664002.26 KBd63f1e6453d97c73e4639e02927afeade69bf6a43c6bcdcf66a71a467a3d1f7c
lib/karafka/pro/processing/strategies/dlq_vp.rb100664001.17 KBb378be0c0d52778d07af58fdc06c748a59d84b1b36274fc00dd1abb1997b15fa
lib/karafka/pro/processing/strategies/lrj.rb100664002.96 KBb4f7b97a29b63afe43780e74ad347851cb20cefeb582cd5ac7f91620eef5a00a
lib/karafka/pro/processing/strategies/lrj_mom.rb100664002.35 KB57d1a446797c30ac6b3ed9f738a411f30190bd28b537f52e08a7ae708217c77d
lib/karafka/pro/processing/strategies/lrj_vp.rb10066400978 Bytes3554ddd5b21f262d265e793093c4e59daf650913ad311643dc32cb993a95ef70
lib/karafka/pro/processing/strategies/mom.rb100664001.22 KBdee7d50a8ceda502f75a8c3ac18dfbb126cb2e6d5927f78ba7babcd96ffc3304
lib/karafka/pro/processing/strategies/vp.rb100664001.14 KB722ca57f55ed7c5ba1c51522a9d8fc4627b206d13093b6354e137628c1e151bb
lib/karafka/pro/processing/strategy_selector.rb100664002.16 KB97bc9d141c34caa29bf8d4556f2b67a34015f7a1260cac4c59d650ade2304d1b
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/contract.rb100664001.84 KB94e3ea647acffcd18361055a9a619793e1729a4b00685f57bc8a4519065c9ec2
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/contract.rb100664001.2 KB34ba861e49beb62e0914f8ab323d1b7b37e0e057020dd48c33a6430cf61945ec
lib/karafka/pro/routing/features/long_running_job/topic.rb100664001.37 KB84f5afa798d7d3cc936d81752b1625911f7f15e558d72b49b93134f9865e9422
lib/karafka/pro/routing/features/virtual_partitions.rb10066400949 Bytesde50e6f5d24e8f44103e1d681572d19904dc77d5eef875b15059c8e42dbdf1ee
lib/karafka/pro/routing/features/virtual_partitions/config.rb10066400917 Bytes61295721eb0188b42666d4af29a13a3b20186e254a44e4948e98d909b313f05b
lib/karafka/pro/routing/features/virtual_partitions/contract.rb100664002.56 KBb890386e1726ab3acc57ab0a1919a2cb5293facf4f56fc4b61d70e9507e0ce84
lib/karafka/pro/routing/features/virtual_partitions/topic.rb100664002.17 KBea2cdc3695664c36b8f8f0a36670ec3d93eea90d47f231e1a09d4ec2c1dd5188
lib/karafka/process.rb100664002.44 KBb7ee1522ef34d00853672ca95b1272f1ea48397230e460cbdd4d6576abf2580c
lib/karafka/processing/coordinator.rb100664005 KB042d011b0d3f308b443ef00a4bb1d2bdbc1100161b8b6477ebb0b7a8e8db7b29
lib/karafka/processing/coordinators_buffer.rb100664001.95 KB3ace122b91164bebd202d674d1e27fc4e7dcba2720c1fd578a440a3d5eee7c3b
lib/karafka/processing/executor.rb100664005.1 KB8c4b2238b653902bcf373cbfb00bd095b3cdcad847e3fe8987a97175658f3c32
lib/karafka/processing/executors_buffer.rb100664002.96 KB5c5914cfe9fc81a829ba8de61838bf4ea0732a303c4fe5855ea329f5bb0bc007
lib/karafka/processing/jobs/base.rb100664001.88 KBb35d9e23f0c3206af5662ad886a8f9833f2bf4fa8cb4fd5023a185dba05bb917
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.54 KB8538ad937adf04f0704786e7b5739ceb09a9bddee524f176dd59aa861d838a21
lib/karafka/processing/partitioner.rb10066400824 Bytesa14757c248a5c733fcd7bfd1ff31e848f16f90ed66f83676853da4ed7b08a87d
lib/karafka/processing/result.rb10066400920 Bytese26374d06b25119a3d1e8ebdc88699ec540a9f312d468396a71db206200f7ff5
lib/karafka/processing/scheduler.rb10066400718 Bytes9decebfc26fdec91c0d4c3e06ed122dccac1fb5e4b0546026786ae9550dc181e
lib/karafka/processing/strategies/aj_dlq_mom.rb100664001.52 KB1ae6323cf95e6f27140bd20b3ef6b3d9f6ecfca4f52c6f2eebd2ff3d140e9e14
lib/karafka/processing/strategies/aj_mom.rb10066400461 Bytes5ee3917968cab8cde257fd8d9be9bc0cab310e992c8ae660f0b263c921e53f48
lib/karafka/processing/strategies/base.rb100664001.64 KB8d7022749c620f3b0ac7f16e1077a270c2c8dfef1579618527c018631a2ab24f
lib/karafka/processing/strategies/default.rb100664002.85 KB627b250a5003c9cf6e9527509bffac0e1f28e53cf7c290cdead13cb708705f47
lib/karafka/processing/strategies/dlq.rb100664002.76 KB58b1dff51dabf26f1255e115307dc58d53acedc2376a9316b704ed2eadbfb4fc
lib/karafka/processing/strategies/dlq_mom.rb100664001.39 KB88d7c9ddd33bea38464bb612e31aed2669d0a72b914467b609679b9449b6b0a7
lib/karafka/processing/strategies/mom.rb10066400771 Bytese79e3596a639247b0b9823a1615ec6516c7de50251017b47ed6961319246d567
lib/karafka/processing/strategy_selector.rb100664001.07 KB5a4ad8cc73f75fe4e66e43823532584c27145da54f0336a09d08aec0b9bc38db
lib/karafka/processing/worker.rb100664003.15 KB012ad1082a7d456c3f32b426d9648cb683868d0ab270649313cb10ee5ae4a9fa
lib/karafka/processing/workers_batch.rb10066400658 Bytes6a7a594eec5acbff165ddfbb74d930282b65721aa694f2e73fce851a2152c202
lib/karafka/railtie.rb100664004.75 KBb84e74ef048ae9ca5c67032e7d8c54f421aa8327a03d49f766279c8ad169a30e
lib/karafka/routing/activity_manager.rb100664002.36 KB8ed8dd07b21698fe6bfef31732bc970448bfe62a5ff24c8a9a8cf114496f5dbf
lib/karafka/routing/builder.rb100664003.52 KBb8cf8e3cd2ad45090a84784864289c7db829b61f9cc415435a8bfae0f13099a7
lib/karafka/routing/consumer_group.rb100664003.89 KBd9639982653c9173e9e9f51a25b3e63b912caca8b4c3f25bf5758f315772e9cf
lib/karafka/routing/consumer_mapper.rb10066400870 Bytes45210f00fb4409616bf0fe89e75cb14c6ddd2015242711ff04c8d1886d4f3b9d
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/contract.rb100664001.43 KBdc34925cf83d09056ee6a61f19eab1d66b27e4d38bfb40aec5d58f863a0888bc
lib/karafka/routing/features/active_job/topic.rb10066400993 Bytes4655606aede3ce4186ad736cc9311f5bf30238eeacb38d1d32f35f3d45b20a4e
lib/karafka/routing/features/base.rb100664001.13 KBbe026c535b73ac24bfd2a5dde1deb41bf272e5aa933c5d725edda15156a47e25
lib/karafka/routing/features/base/expander.rb100664001.54 KBf29f9fb4289bcebf26e0bc57c69a265b5019a5db3545c7b0ee12be29d6872c99
lib/karafka/routing/features/dead_letter_queue.rb10066400494 Bytes2ad5b4f2c4f77be2933586265cf5fe14141d3a3badf7a57c928709ca0a90c511
lib/karafka/routing/features/dead_letter_queue/config.rb10066400491 Bytesa8d1ba45fdaded04d8a720cd586f534ba77dc77796641112370fa1df7ac4acdb
lib/karafka/routing/features/dead_letter_queue/contract.rb100664001.26 KBce04d6a0d9e26baad7e577ca1289bd7f0e43afb8be4c6d8692aaef0c417dcf71
lib/karafka/routing/features/dead_letter_queue/topic.rb100664001.25 KB7c2ed9c449e9b3012c8766ced8a3873b0da8fbeb93bf4e9cc9abb78b69145be2
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/contract.rb10066400672 Bytesf1ed26a86587cdd7c72c5a87bb1772ed5ce5878dcde4313584f411ceacff05e6
lib/karafka/routing/features/manual_offset_management/topic.rb100664001.21 KBbe5c6be5e82e6805472700cae99d97991265d33b3c270c0831e76917af1add36
lib/karafka/routing/proxy.rb100664001.62 KBc050bc9e94d184b05cbc236841b5df24eafade2f8dcf3ea7803cbffc7a08bd25
lib/karafka/routing/router.rb100664001.49 KB1587b5c1816b611e9bb5cd54c8f105ec80dd30a7e1035f8e14a46ece04b898b1
lib/karafka/routing/subscription_group.rb100664003.48 KB58b4b6ba573f5a7583cf293bf87295bf33e6cfb156f2f58943898ee28adf7c47
lib/karafka/routing/subscription_groups_builder.rb100664002.01 KBb16b6c3d45db9d49bf14d0bc7e380d7480fd11b06d46e460b6b0bd9e9daaa479
lib/karafka/routing/topic.rb100664003.91 KBbd1eed886400550328a0c07606f9d63839c0299ef7125951f483f6817749fd9b
lib/karafka/routing/topics.rb100664001.23 KBcecd2287983c3109985443a2c05ed25d8b4c1ea2ab3d13f6ebd4d5296bad974f
lib/karafka/runner.rb100664002.05 KBc149f4752d311b98f70d20c2998847d5b51a540944e4e18fd0f521960c861244
lib/karafka/serialization/json/deserializer.rb10066400683 Bytesb70bde3aca8a988b35fa76bfa1279f0ded5bd85cf9b504442d75ad39cb6ed1cb
lib/karafka/server.rb100664005.72 KB208b4d83666b12764295abe015deb026fec3a297f61d1107635fb78f51c5eaea
lib/karafka/setup/attributes_map.rb1006640010.1 KBb50fc5beb1bba6e3a824473b58e4c36e069160ab03438f3b0f448b5f114b2f5a
lib/karafka/setup/config.rb1006640011 KB4fad6ce6f5cd5c1a5d85c254cad39f34c174161f3b92dc1291402302f26fc9d2
lib/karafka/setup/dsl.rb10066400555 Bytesd9a93c794c071cda753465d9145dc657a8a2ab5d226e2fc0724e134c644f09ae
lib/karafka/status.rb100664001.74 KBb2a8e17c08676f35064000c6f9ef5053fc77934b4aaae7cf027a88cad8de7acb
lib/karafka/templates/application_consumer.rb.erb10066400286 Bytes44a56710679e00a419831a79da526cbad4a0d15c95f2834ee09e03ed0185ee0f
lib/karafka/templates/example_consumer.rb.erb10066400369 Bytesec8631c779428e18877526c0a24d0c33c9140e3abe604a76f387742d84592c63
lib/karafka/templates/karafka.rb.erb100664002.01 KBdd0d2ecb8a797928c6c2ccc3f650187407dba51dc1c82f451d183ce994107a6e
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.rb10066400123 Bytes922841fe21b6bf717beb17cf5e2890a0e4eed1ceb3b2d94a2c5c947627d2dfe9
log/.gitkeep100664000 Bytese3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855