karafka-2.0.20

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: 982969

number: 2.0.20

platform: ruby

spec_sha256: 659dd721af3aa27c64c20c06c859911edea600a519bfc144f2c11cc7c56716ef

sha256: 47200aa392e02994cad73e6400bc013661b9d8e5c27241769e6966308dbc4d08

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

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

position: 79

version_data_entries_count: 196

uploaded_at: 2022-11-24 17:22:29 UTC

indexed: true

has_extensions:

extensions:

Gem size: 135 KB

Version Data Entries

Total: 196

Unpacked size: 461 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
lib/karafka/cli/base.rb100664002.14 KBd3c869dc219ac1702d26ce14bde0d308793f5501377a9f57d701ee6b7ff43758
.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.yml100664002.95 KB07ac66c6169b16086fde6b1c07606714eb908a37ca215f1a53edd55bd4aefa79
.gitignore100664001023 Bytescfaaf830420e24157da66709f087a6f1c395deb5acf38a0bb162c3a77e6fb22f
.rspec10066400238 Bytes64727e60211dca3ec6afb2fc0acb3b5f77f6dc82f3da5ca9f602f7566bad2a32
.ruby-gemset100664008 Bytes2afae0b89d0be84fbce9611eb5bdcf52d69396704dc429f68b6270ce56c8880c
.ruby-version100664006 Bytes905360921e63f419d6a111dd3216bf28402f367ab9aa69444d80e97419600d80
CHANGELOG.md1006640057.3 KB51b57344db574a5aac72f59f8f84b1d8d36678db1c156182f78bf4c572625a40
CODE_OF_CONDUCT.md100664003.14 KBc5be22a6783a9daf04a76f109d5695618c5e55638e2f5c5dc8821c3180ec88a3
CONTRIBUTING.md100664001.77 KB0bbe6d4e34b631d47439606f987678f5db1f64617e9776023155f134f07825c1
Gemfile10066400336 Bytes835cc2e99d2d7e7c9bedba273fa7d729deb4a04a823c49203262bc9f5f5a13e0
Gemfile.lock100664001.77 KBc3254613ad5d9a978f42c193b2dc347b69ae8dcf4adcfb930c50a600627b452c
LICENSE10066400677 Bytes23dfaa51df3c89c77a0e7a88caceccfbfc40b93a4341115b1f32608877130487
LICENSE-COMM1006640015.7 KB7ac2dc542b53f8a3913fdd2e930d9b5c1b4e1d11b2316dd61ddc6fe1ceb4fd07
LICENSE-LGPL100664007.47 KBda7eabb7bafdf7d3ae5e9f223aa5bdc1eece45ac569dc21b3b037520b4464768
README.md100664005.23 KB457032a1dd513dfae1197777310db37c0d63dcd0f1ba4aad0850b5de120817b7
bin/benchmarks100775002.46 KB58f01609998decbf1cb652e85187919df1e16ade206c5ce069f284478427bd1c
bin/create_token10077500586 Bytesa47a067dbf5cd47591d666fa9bb966d864d6114f700d3d21dce84dba86cb1533
bin/integrations100775008.09 KBed880a0ab8ab245f3489b5e9a6d0b539d6b8c7e3815540e5b119ebb6b7b8aff8
bin/karafka100775001.01 KBf56d64f948004d9c3fffdfd2c52fc3edd0c03bab0fab1119669851233a57c138
bin/rspecs10077500122 Bytes5a7f187796e110233e461bfc4eece1a5467fadd8e0e707e56684178bf71d6a30
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.yml100664003.42 KB56e6236c7302c8796c87ba96c6577a239f01f6017e05320d15f44d2b16669ed3
docker-compose.yml10066400654 Bytes61f2f1d182cb3abc652fdd669c423227e59e514dfcba9672d8cf498aa851e67c
karafka.gemspec100664001.66 KBa67abf869571b00e2eb11d99ffa94bacf0aa6d8c9e6b26b0eed015269dfe718c
lib/active_job/karafka.rb10066400482 Bytes4dea0184240a1b8bae6bc97022365d48a5b03b34e73b88a23410ff89b57ceafc
lib/active_job/queue_adapters/karafka_adapter.rb10066400869 Bytesc52274add31f1edf456c760fdd5543f38770d5a5c20877b57108843e8cadf1ab
lib/karafka.rb100664003.24 KB7c0fbca64c25d7c29205f1a15ded1916607b226b0cc8c63a0ed07f2a56bff8cf
lib/karafka/active_job/consumer.rb100664001 KB584651f006541a5cccc11b7250e4218f7da5ec7f4b9433b80b345045898d630d
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/admin.rb100664002.11 KB700e50ca08b8b777473727dbb2fac4e3b0db58dace4f57bdec6b402ebb86519d
lib/karafka/app.rb100664001.1 KB20712fb0ec2b4c3468dca093d04d117661fd2db329b6b5093a409d95a469f07c
lib/karafka/base_consumer.rb100664007.72 KB3f89c7a29d8365a09ffa475d7901c7b7e741969c50ed84c3c7aa2666ca5b43d6
lib/karafka/cli.rb100664001.71 KB407a9c3973134847b28d2e7e89f7d9bbcd99ab2952cdb26e36ce0f5a1b0750c4
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.rb1006640015.8 KB0182fdbd9c23050700d1d50653937e60e942845412dd9b31f57cefd0bd49f3ef
lib/karafka/connection/consumer_group_coordinator.rb100664001.52 KB78f2f4b9355d372e4fefbe87090eb774a5df153cb582b92a40a072c81cb39c70
lib/karafka/connection/listener.rb1006640013.2 KB8916201d4b1932be1ca38f8157065fd4240ff14a92921da1ece3fc43923504ab
lib/karafka/connection/listeners_batch.rb10066400935 Bytes12fd5e7c65cf3e95b92a737d33e0fd3e3e91717a052de61185abc6d34e4a9cfc
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.rb10066400327 Bytes0a2b9ad7b94e44baacf04f81130eb9c68f21fbbcbccdbb7aa0f94a22ea8749e6
lib/karafka/contracts/base.rb10066400621 Bytesc1b2417c33ff3400d0ca5d768b4bf3297877d76916ac89257afe231e24bd2dea
lib/karafka/contracts/config.rb100664003.46 KB7141ae0014d6026b2daaa123a3e72352aba528af0b597a30a538eefa41095284
lib/karafka/contracts/consumer_group.rb10066400826 Bytes37f335a93ceef48e3f480bcd3d79054e375a0a11fb7720452bd30be38d93e2ec
lib/karafka/contracts/server_cli_options.rb100664001.01 KBaf83e4df06afbcf95e41d9f1eace67a90c896953329a64411324e963dd1bd311
lib/karafka/contracts/topic.rb100664001.43 KB3c0d92bb15373eaf398266ea23360a3fd751f290441729f67a36cc4ed0c734e2
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.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.rb100664007 KBe57274441326f115a5adc1cbd1e2fb58f24962e6dd7e89167126844e991ede8d
lib/karafka/instrumentation/monitor.rb10066400761 Bytes33f962b4196acb949eec51099f7916c258f452161e20787b26aa6ccf4841d7b7
lib/karafka/instrumentation/notifications.rb100664001.9 KB74490f142674f9a7b20fea125c090aef8c9eea6a60c937e28ffc008938a849f9
lib/karafka/instrumentation/proctitle_listener.rb100664001.08 KBc2fad9e22bccbc8e40d3e5f24156c132ae4ebe1acb8832dee435675c35dde5ef
lib/karafka/instrumentation/vendors/datadog/dashboard.json1006640016.3 KBc09105abeab5dfb332db4a26ab3e25c3d7acb97b2b4f6e37530f8598b110a3e0
lib/karafka/instrumentation/vendors/datadog/listener.rb100664009.88 KB96d99ed076ab5141b309854e8bd6a2d08ed371a9f249686254de3fcf72f9ae19
lib/karafka/instrumentation/vendors/datadog/logger_listener.rb100664005.37 KB34973cada9b3aa3c7b8dc78d3326ba107e6fdd18dbc2e2d0877a1082de11ac61
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/bindings.rb100664004.42 KB044a155a2499b39ad73d82c7015338136623c0526757b95e3d9bf8e5d496851c
lib/karafka/patches/rdkafka/consumer.rb10066400666 Bytescd9dac1e860fa24c6acb8a47e2c9c53932573fcfe719afc528652cdfbcc474a1
lib/karafka/pro.rb10066400451 Bytes57ee351f4aafb1c151cd2863e30aa4684356440e7a74d35316f242ea5ae71237
lib/karafka/pro/active_job/consumer.rb100664001.79 KB04f25168073ffacc0d48e858dfd145c3c730ce21b18e0bbb5d0adfea46f215df
lib/karafka/pro/active_job/dispatcher.rb100664002.21 KBd2ef82001cb51b423e5854dc10f13b228ac5978275493615dce000b258cc9a76
lib/karafka/pro/active_job/job_options_contract.rb100664001.28 KBb1a6ddeae78a17b42608644ab5570b171071c9efd46723e5d2ed1dae616fa452
lib/karafka/pro/base_consumer.rb10066400892 Bytes2846a56c760065b0781c8912674248b8883a0cc5fc7158aeea8ea5577dc3b422
lib/karafka/pro/loader.rb100664002.98 KB9af8655cd0b89686167bd73b48251db2d4651814319144363e08c4d2f99974c1
lib/karafka/pro/performance_tracker.rb100664002.9 KB5a64beda5ff6abe59d4c9e4b3d6b8b8fa42bfda85839fc969eb800f25c06d35a
lib/karafka/pro/processing/coordinator.rb100664003.1 KBe865f75584f1fc268b6f1833e0792cd9cd4bb9cfa7af5673cd777e3583e4af0c
lib/karafka/pro/processing/jobs/consume_non_blocking.rb100664001.54 KBefbd2ba05f1df290349b0f1f2ee0b0178b45eddcf715086aad551d9808dda72b
lib/karafka/pro/processing/jobs_builder.rb100664001.29 KBa24a2169f4791eea03eda6c643a9752fb5047cc22b5a6560c12ea976d156c60a
lib/karafka/pro/processing/partitioner.rb100664002.45 KBe90c38e0a5897eb74b973a20d5220db731edc70b4698ae6f32d96b97442dfa33
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_mom.rb100664002.34 KB489721935519a25d364402f55a916fa7c2dcb9b206ee1253c360d6c82a2232c3
lib/karafka/pro/processing/strategies/aj_lrj_mom.rb100664001021 Bytes259bbe02ea85ba289d59b535a4e972d72e5850705337c6567bc86c4ce6783aae
lib/karafka/pro/processing/strategies/aj_lrj_mom_vp.rb100664002.2 KB7466e86b05a369333bf26e21929e00fde2b0e57c5e70587200afe3e9e354bfb0
lib/karafka/pro/processing/strategies/aj_mom.rb10066400985 Bytes63692fd26f193ac7fbfa9694c73d366d95bc05fe98ad632147381b49d76e5bcd
lib/karafka/pro/processing/strategies/aj_mom_vp.rb100664002.06 KBe469e62166f6e7d8fff4c58493afc7768427c893cf3ba8c116a3726beef97e78
lib/karafka/pro/processing/strategies/base.rb10066400810 Bytes48bcdc0f84f4114594f510f66c538154a73a1aea07b39767c76471829f8e31e3
lib/karafka/pro/processing/strategies/default.rb100664001.95 KB502668fe8f73f9dc088e1d2e7ea3a7243f66f50d4cd6d24782b9d157dac73330
lib/karafka/pro/processing/strategies/dlq.rb100664003.61 KB17c7178937cdda386349545d6fa94ea925a5398b596b3624bce44dcee5f7fc99
lib/karafka/pro/processing/strategies/dlq_lrj.rb100664002.01 KB20ae74dd5397c07b2ee038d9bbaf05c02e0f7d588e9f34ee035f57d56916e588
lib/karafka/pro/processing/strategies/dlq_lrj_mom.rb100664001.92 KBd25a2824226a5cdaf2ba70d7de86166ebee6830f28534feae25a6402033db6c8
lib/karafka/pro/processing/strategies/dlq_mom.rb100664002.26 KBdf3ce982aea95416635f97b4fe4ac2a218176cceb46f0fc7361c0659d8c34035
lib/karafka/pro/processing/strategies/lrj.rb100664002.73 KB872ee3eeae9c8dc504caa870022a6558b4fec3049c9a4f2b3fb37de83d8024b9
lib/karafka/pro/processing/strategies/lrj_mom.rb100664002.17 KB6abbedee6f0bb1ae46d06bda651f4cb62281ec6f2be5c190055c0bde3d91a0f5
lib/karafka/pro/processing/strategies/lrj_vp.rb10066400957 Bytes3ab482d0d37c843602a7384976e6c9b2727c06d948c3d11401be173911626ba7
lib/karafka/pro/processing/strategies/mom.rb100664001.23 KB04ef91c9ffb5278c26e702ab3352f4a435e3662135b4dd13dae14e61067c0320
lib/karafka/pro/processing/strategies/vp.rb10066400996 Bytes45a00fb1b1f3afd8e47387802601a76c68853a613a983dcc9c0a2c84674feb47
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.78 KB87d4190e181041c54c4bdaaf152bb61d86d7bf23e854c1e89889b05147c7acc3
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.19 KB0688d4f64f2b69c7d94337783177476f35b4afca6e94668c287bafdf52e2fe6c
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.55 KB7cba1e2a4b7ca7d78ff4d8e3481fc771939c00d3358eb79a94c4628cec84eed6
lib/karafka/pro/routing/features/virtual_partitions/topic.rb100664002.17 KBea2cdc3695664c36b8f8f0a36670ec3d93eea90d47f231e1a09d4ec2c1dd5188
lib/karafka/process.rb100664002.26 KB8e420a0219259295a979a21c0de55976c880952d0624a3f32decc3d74f48326a
lib/karafka/processing/coordinator.rb100664003.94 KBf4245bfd328efa8b183d719b4facd95a6112ab48e3644b17dec72f7893b67fcd
lib/karafka/processing/coordinators_buffer.rb100664001.95 KB3ace122b91164bebd202d674d1e27fc4e7dcba2720c1fd578a440a3d5eee7c3b
lib/karafka/processing/executor.rb100664005.09 KBbeeb908519c3f71e8b93c3ca96ccdf23c86a95e787eba409163aba20ed91a11c
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.55 KB60ed3bd3e4d6295200764ce77f4a8ebb11cf0c4629188d7e75717f050951d1d0
lib/karafka/processing/partitioner.rb10066400676 Bytes1eacbb8e1c06242594a9d0828b5b5d82e1347a96ba20c71049e8f9655c3ceb85
lib/karafka/processing/result.rb10066400920 Bytese26374d06b25119a3d1e8ebdc88699ec540a9f312d468396a71db206200f7ff5
lib/karafka/processing/scheduler.rb10066400718 Bytes9decebfc26fdec91c0d4c3e06ed122dccac1fb5e4b0546026786ae9550dc181e
lib/karafka/processing/strategies/aj_dlq_mom.rb100664001.52 KB446269a9e6bb271db58a7bdab37fd8725e783ce80b3563e0dda5202fcde2a3cc
lib/karafka/processing/strategies/aj_mom.rb10066400461 Bytes5ee3917968cab8cde257fd8d9be9bc0cab310e992c8ae660f0b263c921e53f48
lib/karafka/processing/strategies/base.rb100664001.36 KBdecb421f12d9704ab42ca9d24ddb0e92a30fec5ec0e58569d70f9eb4fc8fbba7
lib/karafka/processing/strategies/default.rb100664001.46 KBa32d01ad0a0e401cf27ddab8d7d1375e66d300cf7f783c8ee740095a6584f83c
lib/karafka/processing/strategies/dlq.rb100664002.71 KBbdef38bf4c2dd1bd0f3a7ef8fde9aa796813d638de3d6a53a167a23376fa28eb
lib/karafka/processing/strategies/dlq_mom.rb100664001.39 KB0a7af1e0364e2303de5bdde734074f47d00ce3fdc74259d033435b213a60eafc
lib/karafka/processing/strategies/mom.rb10066400784 Bytesb0d79d6600c9abb740af437e906f5ab9d329254ce993888cd21af80e30d8cace
lib/karafka/processing/strategy_selector.rb100664001.07 KB5a4ad8cc73f75fe4e66e43823532584c27145da54f0336a09d08aec0b9bc38db
lib/karafka/processing/worker.rb100664003.09 KBf5f4d4282260cb17edc399c6297b5ac1bf83bd6380f673cf3a9be65aac088641
lib/karafka/processing/workers_batch.rb10066400658 Bytes6a7a594eec5acbff165ddfbb74d930282b65721aa694f2e73fce851a2152c202
lib/karafka/railtie.rb100664004.49 KBe843d7e820c8fc9628b5fc2062bfb890782c445941599b9a1b16dcbe51e85edd
lib/karafka/routing/builder.rb100664003.52 KBd1e70a450d0244acbc2c9c6f0c9541ae41b3a1f7049739c0bdd54e60754c0718
lib/karafka/routing/consumer_group.rb100664003.79 KB24401ef24efd72324bdaa818adc19b656512690876160c72f99472989302aab9
lib/karafka/routing/consumer_mapper.rb100664001.18 KBbd42326c09dd22c60c49053a28a155fc0315565a241ac767d9091c15ed8a6d74
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.42 KBbacd77bdf8215056806e88e5057ee7bac08f833c14243533c19d4c37ae1031b5
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.25 KB0a02d93fa22ef9c67a37cfb451bb64110408578b0a965532bde87e096867b2d8
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.rb10066400661 Bytes24ee05a45c5f115fbe1398165fe782b915a1819951f2be0d518355ec500efcca
lib/karafka/routing/features/manual_offset_management/topic.rb100664001.21 KBbe5c6be5e82e6805472700cae99d97991265d33b3c270c0831e76917af1add36
lib/karafka/routing/proxy.rb100664001.62 KBc050bc9e94d184b05cbc236841b5df24eafade2f8dcf3ea7803cbffc7a08bd25
lib/karafka/routing/router.rb100664001.06 KB99b9a1ed4f52bc72c89dc48a613c60be933c92627a906cb8dd6aba724b8b3225
lib/karafka/routing/subscription_group.rb100664002.75 KB5e7f7c993209ca8a8d711390ce0ac24638c91ce0f469adbb606f8a6f8ecd9c83
lib/karafka/routing/subscription_groups_builder.rb100664002.01 KBb16b6c3d45db9d49bf14d0bc7e380d7480fd11b06d46e460b6b0bd9e9daaa479
lib/karafka/routing/topic.rb100664003.41 KB06a598588cc820114be3be61483eb3bdcd3ce55bd1e22454f0dc95a853af13df
lib/karafka/routing/topics.rb100664001.03 KB3f57db0750359a3d42b06a7b108dd2700516d1f0bde8fec22696af6de4d60e7c
lib/karafka/runner.rb100664002 KBcb0c4fd8448529422f4ee225cfde2e07b94bd41b96fd97f5a35ba7a750b89b50
lib/karafka/serialization/json/deserializer.rb10066400683 Bytesb70bde3aca8a988b35fa76bfa1279f0ded5bd85cf9b504442d75ad39cb6ed1cb
lib/karafka/server.rb100664005.33 KB9edb5b5af07f10d137f55167118b24c84fb7775f257499285724e236fd252380
lib/karafka/setup/attributes_map.rb1006640010.1 KBb50fc5beb1bba6e3a824473b58e4c36e069160ab03438f3b0f448b5f114b2f5a
lib/karafka/setup/config.rb100664009.61 KB0837f3cddb44bdce9ca6302bb7bde9d27a4e399591ce97f2ef6137bb8feed3f1
lib/karafka/setup/dsl.rb10066400555 Bytesd9a93c794c071cda753465d9145dc657a8a2ab5d226e2fc0724e134c644f09ae
lib/karafka/status.rb10066400952 Bytesc8080473458a9bda09a9fb3cb7fde051151ad2839e6d7b2045e55b1ba58afda0
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.rb100664003.65 KB44030ed2380b7fe45140bd79b88450820b2b8a2cf8a3de88c30fe5abae7210c5
lib/karafka/time_trackers/poll.rb100664001.84 KBa47a7031e22a31eebc3a6609a1cd6bb05d1a69386a23974ba2a8f7234e044cfc
lib/karafka/version.rb10066400123 Bytesfd1293f1a7da51705438df73eb6d75198a5f10e5cdd88b4bb63e713b9bb437b4
log/.gitkeep100664000 Bytese3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855