karafka-2.2.12

https://rubygems.org

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

number: 2.2.12

platform: ruby

spec_sha256: b54e8961af6e699fb33d5f44f847ab15ed0810d6e6b0b04a28ae44ca8692d626

sha256: 98aedafe24c242218bad35e8c642592830834bf41df4280d18059a9cf48caec0

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

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

position: 25

version_data_entries_count: 326

uploaded_at: 2023-11-09 12:03:27 UTC

indexed: true

has_extensions:

extensions:

Gem size: 198 KB

Version Data Entries

Total: 326

Unpacked size: 799 KB

Full Name	Mode	Size	SHA
.coditsu/ci.yml	100664	138 Bytes	e4ebfa4ad81dd12ffe492ff9168a0fb9c20d3e74e8bff0aa06f54c6c76cef711
.console_irbrc	100664	336 Bytes	4431d0fa2de6c2846d47a90a2f22d6c5dea9a41f097abf9160e05b2b81b30c6e
.diffend.yml	100664	158 Bytes	a49a2e6b3b48603cfe838d422d381d219a49d7593c72c9a82c5e10296e90b4b9
.github/FUNDING.yml	100664	43 Bytes	b38ea0e5490b04e13d6502ee2e9998dc9ecbd1dd4c3b366b7c8c4766792fefc2
.github/ISSUE_TEMPLATE/bug_report.md	100664	1.37 KB	73e8605026be7a5ae4400c84258017d85ca30a564e7f7e8fc86f52a074409c6e
.github/ISSUE_TEMPLATE/feature_request.md	100664	593 Bytes	739d98d20ac43aedb1aa0c34d93209a440fc0ff142037f76950c95888dc4cfeb
.github/workflows/ci.yml	100664	5.81 KB	c35c66a2f56a2a68da751951c304ed602f01bcd4a4fe9469e00b25e355290345
.gitignore	100664	1023 Bytes	cfaaf830420e24157da66709f087a6f1c395deb5acf38a0bb162c3a77e6fb22f
.rspec	100664	238 Bytes	64727e60211dca3ec6afb2fc0acb3b5f77f6dc82f3da5ca9f602f7566bad2a32
.ruby-gemset	100664	8 Bytes	2afae0b89d0be84fbce9611eb5bdcf52d69396704dc429f68b6270ce56c8880c
.ruby-version	100664	6 Bytes	79b9fb49a71869140833837e3a27ae1722a41faf59746519fde5e1346f9dd5b8
CHANGELOG.md	100664	48.4 KB	d97fd1659c356cac48556a85b27bf58b5a585627fef199895a4424d7b1bc9599
CODE_OF_CONDUCT.md	100664	3.14 KB	c5be22a6783a9daf04a76f109d5695618c5e55638e2f5c5dc8821c3180ec88a3
CONTRIBUTING.md	100664	1.77 KB	0bbe6d4e34b631d47439606f987678f5db1f64617e9776023155f134f07825c1
Gemfile	100664	376 Bytes	cf1df31fade1bb25257fbf33a6638808b85046f696978b7f8a31f7b8ef1d2716
Gemfile.lock	100664	2.24 KB	82ba133e7761ab227f51982fe1d4fbf205325e37afca2624d7f6df61765bd8b9
LICENSE	100664	677 Bytes	23dfaa51df3c89c77a0e7a88caceccfbfc40b93a4341115b1f32608877130487
LICENSE-COMM	100664	15.7 KB	7ac2dc542b53f8a3913fdd2e930d9b5c1b4e1d11b2316dd61ddc6fe1ceb4fd07
LICENSE-LGPL	100664	7.47 KB	da7eabb7bafdf7d3ae5e9f223aa5bdc1eece45ac569dc21b3b037520b4464768
README.md	100664	5.49 KB	cd678b98c8aff75161be33d956944c3b0e58bebfd58aa6390f283083fec4eafe
bin/benchmarks	100775	2.89 KB	ddd485a05f185b255d904fcaa541a555e0176639781433f1b2e8d23484f96e27
bin/create_token	100775	586 Bytes	a47a067dbf5cd47591d666fa9bb966d864d6114f700d3d21dce84dba86cb1533
bin/integrations	100775	8.89 KB	fb402b2ef9321c157551c5132a805a1eb24b1e2b23067781ecfb59b37dac127b
bin/karafka	100775	235 Bytes	cd1e04f7f42ee4f7572d07bc74bf9bf7c318812e92e63a4b7533324149c54fa1
bin/record_rss	100775	1.58 KB	9b8f5fe70fadaadea6a5148407652c48558226d4781a48208a802eebc788c1d9
bin/rspecs	100775	130 Bytes	d3c41365806f1f3e0372fde43c94e5ddf195b374aef963f138e449e4f3e0a403
bin/scenario	100775	1.03 KB	84f9aa609a41eec4a40ca1a68769e9e628a0042bb37a5f78c4c94b81dcc90eb9
bin/stress_many	100775	282 Bytes	dae79a13c09041e24007bc94d05a63c102931b481637deca0d3872465df561ca
bin/stress_one	100775	280 Bytes	e988ccb26b4b8881ba77a3b491a13be95f461b1eda601fd2a55a85299b3bd47f
bin/verify_license_integrity	100775	1.04 KB	5878d10203ab121c982bfe6a8b3b21e789695c93b061ff00f80bb83d440e1b01
bin/wait_for_kafka	100775	492 Bytes	2a796511dac86a070b4b2ade8a078066af694c20fa6d5f2200eb1eb2bf742887
certs/cert_chain.pem	100664	1.56 KB	acf431d923515fb63c3b68d87b6215d96c108f171df711696b740f3cb24b2bf6
certs/karafka-pro.pem	100664	601 Bytes	80e379259996ca2d52259405b21c86bb20306c53be5ce0e384b62546466dba4f
config/locales/errors.yml	100664	5.7 KB	6f8973d02cc26f4d477c93964bc0d4cc36dcf567c952ce6213ca9832f2fe6456
config/locales/pro_errors.yml	100664	2.81 KB	13c1f32939bb7ac018e3c356db1c1f9c091ff08601a7c4ddeea15c0579a64211
docker-compose.yml	100664	851 Bytes	7946ffad5538aa36436e643f5212a8c09a68c9b0ebc4b3591740f796c9ed4285
karafka.gemspec	100664	1.69 KB	3ed2c62cb09097734a2abd9ed6e203a68f235f9060683121b783a4a1422445f4
lib/active_job/karafka.rb	100664	482 Bytes	4dea0184240a1b8bae6bc97022365d48a5b03b34e73b88a23410ff89b57ceafc
lib/active_job/queue_adapters/karafka_adapter.rb	100664	1.07 KB	4a34f4985a036d36b3a203d10dfbf8ed36b313e8101b531c7a1cf9964e127580
lib/karafka.rb	100664	4.89 KB	c8c70ac54c9b763b50f5c2ae1a1dcb83132816dbcdab374bc78833e12821f91f
lib/karafka/active_job/consumer.rb	100664	1.77 KB	67e7421415d225d2276257091ff2c1e6dfa0c4d96a7adef28434c90e670c345b
lib/karafka/active_job/current_attributes.rb	100664	1.61 KB	82ce0e5448eae1b0cafe7bb8eea67157805e901a2d303063c177605aa3847cbd
lib/karafka/active_job/current_attributes/loading.rb	100664	940 Bytes	420b26093949a1a26d83cb1f3bd6eee63410ffcc420c6aa57f35e7176d036475
lib/karafka/active_job/current_attributes/persistence.rb	100664	708 Bytes	345a2b11f67b308f62a97976c2fc5f82a0807f8783ced99935130d25d1b1eb4c
lib/karafka/active_job/dispatcher.rb	100664	1.98 KB	c571dc7f388d5ee52f0ee9be55f66d34aeca1cef0e9e2777b63712d2efb82801
lib/karafka/active_job/job_extensions.rb	100664	1.01 KB	727ff923dbc60f5a8e3c0af70c8cf3afb6484b7b5202ee1477b6f431eac8eeb7
lib/karafka/active_job/job_options_contract.rb	100664	1000 Bytes	9e627a98870a73f87cd05f5023a08d20af77025b7eb93ff9ea39c2076e02d22d
lib/karafka/admin.rb	100664	12.2 KB	a04b287d2cff30af40db9c6935b0819abb62da9f049fd5005ee7d96e4b56b2a1
lib/karafka/app.rb	100664	2.32 KB	30ba063af3b334ab483ba44016a410f451d69fc31351fdef7d04d76eff0872be
lib/karafka/base_consumer.rb	100664	9.83 KB	575fc9bfae6dbc960e07015ee681c89edc08ec25547e6d9be550013eef61e88b
lib/karafka/cli.rb	100664	1.77 KB	3b8a37121b1744f464dcc2a29a4aada023887a4c464d4af662396e0e3d4a296f
lib/karafka/cli/base.rb	100664	3.69 KB	5e318333b20d1ee9b0200983c0008dd7fe3b6beec7f6bb2f86b59341cfcb5e9c
lib/karafka/cli/console.rb	100664	1 KB	b32191328d2aa82e50bbdfcb743b953bc583da6a2d552499536f0986f5d8f81d
lib/karafka/cli/help.rb	100664	645 Bytes	748f300d7930e3ee4740061d5466cb43df685102a55e7ba9a78b0ba7c3b38ec3
lib/karafka/cli/info.rb	100664	2.02 KB	b070597db3dfc5d2e3b9c2e70e8c83fe2a09a3e304ecea156828bd4a8fd50992
lib/karafka/cli/install.rb	100664	1.99 KB	fbd5e4ad14b34051259cd4189e0b90bd8f6f8129154dcea32216733d92972a9b
lib/karafka/cli/server.rb	100664	2.96 KB	ee79ae6c00b46ee3529b3b8881b1367f7e9f03da4ba0b199f351b49b06a75c20
lib/karafka/cli/topics.rb	100664	4.64 KB	f2c688aaf5f362af79620b0c16da85142a2e1ddd0e858ef1eff268ce7683c369
lib/karafka/connection/client.rb	100664	26.2 KB	981d7e69183f95c3224998fae68bacb6fb6ab392534ba0af97f2398295778534
lib/karafka/connection/consumer_group_coordinator.rb	100664	1.67 KB	64031ac7a72bf81e34e4ca7013f8014ae6d8ceb47c370df24a7cebe9bd13e8d3
lib/karafka/connection/listener.rb	100664	14.5 KB	abfef6c1a660fd91474d6db22738a9cdaa3894486d961c144db1baf883829f69
lib/karafka/connection/listeners_batch.rb	100664	1.03 KB	1a45c64cafaef6df7f2b8b24a4a57a6d9f5968722db621b86a4e8673b5ef27fb
lib/karafka/connection/messages_buffer.rb	100664	2.91 KB	2af33d3e5edea967d95031dd7ceacfce061f34a51f3edec131fd5c2938c86fc7
lib/karafka/connection/pauses_manager.rb	100664	1.37 KB	48308ac4d96b120532a411b526c87b06a2f74902f64f33d129aa9fca27743965
lib/karafka/connection/proxy.rb	100664	3.51 KB	c6b939d756091d566db4e47ffe0bf60e6b10e2412d84b572ba3c123f9f823102
lib/karafka/connection/raw_messages_buffer.rb	100664	3.48 KB	b4c89b6ac4145d66e15b27b3d7770d3eb626f803d890fe8594b8bbf4b4dfb07b
lib/karafka/connection/rebalance_manager.rb	100664	3.98 KB	4db0875e2af6bf3b89cb2a85815fade506910d9932bb60d84a5b088d26619b84
lib/karafka/contracts.rb	100664	331 Bytes	e23cf30da1bf460ce8315a4867f51e4dcd5c1b057b7d4ec1a86ac63fd088be55
lib/karafka/contracts/base.rb	100664	621 Bytes	c1b2417c33ff3400d0ca5d768b4bf3297877d76916ac89257afe231e24bd2dea
lib/karafka/contracts/config.rb	100664	5.3 KB	8d33e4c9ca96da8912936d59c9f76e86205acf7e03694db4eb7798586bb16d5b
lib/karafka/contracts/consumer_group.rb	100664	1.73 KB	2003a1564568dbfffed97c7b3bd6751b8155cf4c8fa439a07bb60b389e4a6b20
lib/karafka/contracts/server_cli_options.rb	100664	2.97 KB	eeeb43714bc436f832811d71d16ef016268fe97a22a19ce5e798f1e3fdcb1f3b
lib/karafka/contracts/topic.rb	100664	2.21 KB	4a03e80f9be88bb950534c2c662f93c6a319b3a481b7e484ea1e1cce55acaa1d
lib/karafka/embedded.rb	100664	1.1 KB	ad2961e26d33e5c8a5ec6ad4c51be5e69d5d9c76d01e729fcbc4880a04570f91
lib/karafka/env.rb	100664	1.43 KB	7c80157166da7eb037f8ad61d9436acb1ffa8d36aca62243732dc55f2451f282
lib/karafka/errors.rb	100664	2.82 KB	963f95dfeb0cda98826497504cc966179cdf7b38a19bb54f90764bd637e44963
lib/karafka/helpers/async.rb	100664	957 Bytes	daff3dd9ad38faa862872d03bdfaacf06e27cb85e8cdb6d46bdb3e0c92fbf1fd
lib/karafka/helpers/colorize.rb	100664	666 Bytes	d22bead69b76010c2a2ba647094fd0926fc8eb5156887e51315f9a0988463c88
lib/karafka/helpers/interval_runner.rb	100664	1.3 KB	814cbafb7114daf94ed1ca043415b36d53679c3de57c704f9421bdf95077cd99
lib/karafka/helpers/multi_delegator.rb	100664	933 Bytes	c472db16985b61622710a9fdb697d6d930d31ee02e512d8f47bec4e6ab4838d2
lib/karafka/instrumentation/callbacks/error.rb	100664	1.46 KB	8a465edb8df302f78449a98a3b0bbb2d4f7a5ed56f2c5cf6310291984b429537
lib/karafka/instrumentation/callbacks/rebalance.rb	100664	2.15 KB	dd6514d904f367e752f8a32bee9cfda70c993eecfc24dc1bb8cc3e3ece363890
lib/karafka/instrumentation/callbacks/statistics.rb	100664	2.09 KB	dbeb8a4efa55fdb80937d7b095ce32fc339ced484a55f7ba1cf83b1bffc2fafc
lib/karafka/instrumentation/logger.rb	100664	1.7 KB	9c60d2e6106306243c2125fa7c7ebe4299d4d8e774a5f1df8a7b44db83180f9b
lib/karafka/instrumentation/logger_listener.rb	100664	11 KB	04ae148076ba53b2fc3fee2b57dc0e22ae4ef868a3e96011d5b47b233839646f
lib/karafka/instrumentation/monitor.rb	100664	761 Bytes	33f962b4196acb949eec51099f7916c258f452161e20787b26aa6ccf4841d7b7
lib/karafka/instrumentation/notifications.rb	100664	2.44 KB	394f662f2f60be16a3500b5208a36205f16333900bc493968b9e4d56d16fa6dc
lib/karafka/instrumentation/proctitle_listener.rb	100664	723 Bytes	89f2d269f24407336d1152955a92da2315e16583cb289ba1d59545b06e932eff
lib/karafka/instrumentation/vendors/appsignal/base.rb	100664	736 Bytes	d9f5b3ffdbb9a218a1ebbcc1f3dd6320de95cdb7092d92f7e3fc3c9292c7035e
lib/karafka/instrumentation/vendors/appsignal/client.rb	100664	3.97 KB	a79e9ec18b1fbbba9f921c68219b6ecddbe741c0d4013b198d338973d689fd0b
lib/karafka/instrumentation/vendors/appsignal/dashboard.json	100664	4.73 KB	303b775ac4a597d912c38e57282141a9fda589ddca141a6948cd31f0be9068bf
lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb	100664	788 Bytes	94c0f08f46ccb6d1d686b8d74fe62e7074c01eb712b6ded97b51ca91e364c8a2
lib/karafka/instrumentation/vendors/appsignal/metrics_listener.rb	100664	12.1 KB	c788c623488e4c5a92f561b7a5f5a72ce7077d48aa5f13d64a181f7d63be71d4
lib/karafka/instrumentation/vendors/datadog/dashboard.json	100664	16.3 KB	c09105abeab5dfb332db4a26ab3e25c3d7acb97b2b4f6e37530f8598b110a3e0
lib/karafka/instrumentation/vendors/datadog/logger_listener.rb	100664	5.47 KB	e16db7c2141e7291a55029bc0ea24e5297d81170726f5b1002681c2693cf68fd
lib/karafka/instrumentation/vendors/datadog/metrics_listener.rb	100664	10.2 KB	f0da8e3525033c7f992f9e9ec22a60acefc6dac39b9e8c801f07e715f296b8ea
lib/karafka/instrumentation/vendors/kubernetes/liveness_listener.rb	100664	5.67 KB	b894e3f68a822cbb16a858e1b7e5de198c9abc0481e802a5626a10050cfa1583
lib/karafka/licenser.rb	100664	2.53 KB	a62f7887c49f58505434cef02b75546c942f08bedc894d646a7dc5695b9f4627
lib/karafka/messages/batch_metadata.rb	100664	1.53 KB	daea11bdc9522c92809c28cd2eeb91c0b2e2c393af8f49de0059b53f91d03597
lib/karafka/messages/builders/batch_metadata.rb	100664	2.56 KB	ed2412a9e5909c228f4de0459c09c2837ff942a05a4c8c50ccb20b4ee181a053
lib/karafka/messages/builders/message.rb	100664	1.54 KB	a166a02cff9409f6d3f283b6ac64309f9ab2977f186cef491ec12c9d47ebbe65
lib/karafka/messages/builders/messages.rb	100664	1.25 KB	d4fc0af2584665d4f67153a789fae62b90229faefca0db7759742501a0ba66b3
lib/karafka/messages/message.rb	100664	1.91 KB	a130518e88548f9f99a75d040959f0ad6190898a02947d8e95c91590843b61ac
lib/karafka/messages/messages.rb	100664	2 KB	846f17fd9f01d11b25c2e7f781f00ae007d2ea18a35db1a6c05aef48ca2cbf81
lib/karafka/messages/metadata.rb	100664	362 Bytes	45159d2a186917f7350a4a0a22fe031603eb406f2c30c30a145ea412f56b1af5
lib/karafka/messages/parser.rb	100664	367 Bytes	1e926457feba304da9ba3831b0e25091ed88567b102ccf4af60b8f4b716a8ef2
lib/karafka/messages/seek.rb	100664	386 Bytes	8813b74a471e13c6aa42bd9b11e50e76e2a2ab1996c6e3c913c8e1b83e38c542
lib/karafka/patches/rdkafka/bindings.rb	100664	4.44 KB	53bc99672418355824557bcadcff421c426778d824b92f2a2f274463fc4488dd
lib/karafka/patches/rdkafka/opaque.rb	100664	1.13 KB	2b4e150978c5d97241c4d29b210e371e6f0ca4e45b72d91a5624e98d9f6af6cc
lib/karafka/pro.rb	100664	451 Bytes	57ee351f4aafb1c151cd2863e30aa4684356440e7a74d35316f242ea5ae71237
lib/karafka/pro/active_job/consumer.rb	100664	1.86 KB	0d2ed0620d2bbf33f209a53adc00b9ac58b72cd56c8d2129624c6b6c50ee5157
lib/karafka/pro/active_job/dispatcher.rb	100664	2.97 KB	702e760f0fbd966bc9b966fce57eeb80ba7df2e8e63baf3fcbd19d4f6d4c3cd6
lib/karafka/pro/active_job/job_options_contract.rb	100664	1.5 KB	3ccdbc3beaef420f68a3ca0c740c73199db14ecaf7e769404c65432b3b3a0773
lib/karafka/pro/cleaner.rb	100664	1.54 KB	02e2a5254dd64b818021a4d02b9da529501de0bcad397e1b8e86a5a2c5172410
lib/karafka/pro/cleaner/errors.rb	100664	906 Bytes	6db257b433ffa56b5733d9e1a10d2cdcddf0f32534cf1bc728f0b7ebc30e1143
lib/karafka/pro/cleaner/messages/message.rb	100664	1.64 KB	b15406b0c8380aa44560694c88133b19c23034bd35b44157619ffb890eb3865d
lib/karafka/pro/cleaner/messages/messages.rb	100664	1.54 KB	d21a322ffa728e67974b5962c4d5df32605c081512b2f10442dd096c19b3595f
lib/karafka/pro/contracts/base.rb	100664	790 Bytes	043cab88c86d6fda6c1f90200393d9ad030113be5c26c0c461f88a035b2b0c33
lib/karafka/pro/contracts/server_cli_options.rb	100664	4.08 KB	8497192b4f724bbceadc8eb6c8d43f00d959ed357f466b81c187e5b576905914
lib/karafka/pro/encryption.rb	100664	1.74 KB	8ab8863644ef80bc89ef510974f2438fe57960ca51139108734cdd8f161faeac
lib/karafka/pro/encryption/cipher.rb	100664	1.91 KB	873fb8b5dc1aeeacb1c8e137ef600e672e26d0ce4b1c39523e2e7c3bd2800f06
lib/karafka/pro/encryption/contracts/config.rb	100664	2.65 KB	f361f58340b3d761dc9c85eb1cc82a408ede5f0ebb544efaaa96961ae552811b
lib/karafka/pro/encryption/errors.rb	100664	915 Bytes	5bd7d4ee9bfdd0768ee23f7690002b0c0228678f787bb97e79ec698b21ab9023
lib/karafka/pro/encryption/messages/middleware.rb	100664	1.52 KB	e61d219788d374283eb9e86593f1e4ee171f940daca22a156b3330f83c6224e2
lib/karafka/pro/encryption/messages/parser.rb	100664	1.83 KB	bbb183b320d3931d3e1969eef99fa6e9a7773946e5d40b58d195109d42598ff8
lib/karafka/pro/encryption/setup/config.rb	100664	1.78 KB	e83cade1130b12e60e42a080781107381510a76082341c143b6693918bb80feb
lib/karafka/pro/iterator.rb	100664	6.28 KB	d4d17301fd04fc92b6d7d287ccd3829c20e8d8c7e009324b742b6b2a21136b34
lib/karafka/pro/iterator/expander.rb	100664	3.75 KB	dbf078db52c68bb261a3db945fb86c438000d10afe6bdc7a77b8895d8ae5ec2f
lib/karafka/pro/iterator/tpl_builder.rb	100664	6.19 KB	ad127adf02ae448b61b9f85900ee41b66321e9e69c247898f5f8fa403bee33f0
lib/karafka/pro/loader.rb	100664	3.75 KB	d76b16e020b2098d616cab8ca08a6060d3b805841671bad293cfb26a2693f806
lib/karafka/pro/performance_tracker.rb	100664	2.9 KB	5a64beda5ff6abe59d4c9e4b3d6b8b8fa42bfda85839fc969eb800f25c06d35a
lib/karafka/pro/processing/collapser.rb	100664	2.55 KB	5f6c417f9318318412d295bf820baad6b0e8557685ff8e2acdaf1cd0f9f9f110
lib/karafka/pro/processing/coordinator.rb	100664	4.53 KB	00ecb45ba6020fd47acebf22d2842398a48b6413413691e1121c64b1e6e2646f
lib/karafka/pro/processing/filters/base.rb	100664	2.08 KB	2f1c0f3c1058e26b577c2ee865ba4a0712b6a5852ed33faef31ae7b613da0499
lib/karafka/pro/processing/filters/delayer.rb	100664	2.01 KB	65fb9604da73926e5676987ad540c842545ce01edf302afdf756d51f9ab68b47
lib/karafka/pro/processing/filters/expirer.rb	100664	1.53 KB	926cc6d57b87b8f3bf570f0a555a6c6f26240b724234889dd0d77439fbda3423
lib/karafka/pro/processing/filters/inline_insights_delayer.rb	100664	2.58 KB	ad90b16a9ecd46621f7ec8e20612b40f503555a40da8bcc782c0c7566b406d76
lib/karafka/pro/processing/filters/throttler.rb	100664	3.1 KB	edb2ef3291f81a810cf48c990f834cbd77ebd903e4d95e505908b1a18bb79518
lib/karafka/pro/processing/filters/virtual_limiter.rb	100664	1.86 KB	e62432bdfdd28c671bb0971ca199fbba3ef15930a2c0c07ad953305dd14a3cef
lib/karafka/pro/processing/filters_applier.rb	100664	4 KB	bae9992e780de2ea0f0dd594a36b0aa82e47f181d44c5e846bc76eaa1c4043f7
lib/karafka/pro/processing/jobs/consume_non_blocking.rb	100664	1.49 KB	748d7fb95febf31129dae0c6bec7e2a24ba1dd507c1b7e58dcabb0d6ce9d51cd
lib/karafka/pro/processing/jobs/revoked_non_blocking.rb	100664	1.39 KB	947725de4211ead89c6d3a5affdda0abc96c4fe26e753c01d0f62e8de4e58dd2
lib/karafka/pro/processing/jobs_builder.rb	100664	1.85 KB	87fc650b98e2a4497b36d3272c606a23cdcfc4254cff2cfc51f5afbf3814e27c
lib/karafka/pro/processing/partitioner.rb	100664	3.12 KB	bd6bae312bc23e6eb1297552c9b515c82b9d01f4d52042a13fca5f611bbeb1fe
lib/karafka/pro/processing/scheduler.rb	100664	2.76 KB	27b40874c13197bc0e444fbe794dbf2020475cc5fb9997b02b2d948d795eaabf
lib/karafka/pro/processing/strategies.rb	100664	688 Bytes	d2f94105d0bebb5a934f79013342600b89d27a52142f84364e31a7181e038036
lib/karafka/pro/processing/strategies/aj/dlq_ftr_lrj_mom.rb	100664	2.38 KB	517ad52b59d3287a910bd3c464bac95a7476254d5c7d7f41d7399e9f274fa03c
lib/karafka/pro/processing/strategies/aj/dlq_ftr_lrj_mom_vp.rb	100664	2.73 KB	cbf28e6403a1f31251ce81154ae88ccbf8aff363440bc9997330d4dc3f83eacb
lib/karafka/pro/processing/strategies/aj/dlq_ftr_mom.rb	100664	2.73 KB	545cc1d56071059dd258b2fa2825d5242ab61b43b6f38cde3b0ae7706f9bf881
lib/karafka/pro/processing/strategies/aj/dlq_ftr_mom_vp.rb	100664	2.76 KB	a7ed2b2a100a9c66e4bc61f190798355ac601c1bdba6a64844189c6e8242ad55
lib/karafka/pro/processing/strategies/aj/dlq_lrj_mom.rb	100664	2.3 KB	d9932994f954c6930bc588ca585c0d9968d83dabe5646567730cc6052017a8ed
lib/karafka/pro/processing/strategies/aj/dlq_lrj_mom_vp.rb	100664	2.59 KB	7d99a1cd74e7fa85e287ef01826bc14834c1c794b83f024a15d3fb433f56ea8c
lib/karafka/pro/processing/strategies/aj/dlq_mom.rb	100664	2.46 KB	edd9f1edae49e7c719d414df0eac7dd224ebb9cad01048c990c460e9f76a86bd
lib/karafka/pro/processing/strategies/aj/dlq_mom_vp.rb	100664	2.65 KB	456da64dda34e43ea4a28b8720bdea49d9683bf09d16f72f5696a6b8518503b4
lib/karafka/pro/processing/strategies/aj/ftr_lrj_mom.rb	100664	1.08 KB	90842b8dcd44b527a2c99f283ba02daefc641b43be776d6b4f6fbe8625bf50da
lib/karafka/pro/processing/strategies/aj/ftr_lrj_mom_vp.rb	100664	2.1 KB	042b62a915adf5fbad60463c10ebf9c40146bf1129048c77f42a286ff8d5a6aa
lib/karafka/pro/processing/strategies/aj/ftr_mom.rb	100664	1.1 KB	c8e6ff9b61a32a574903ff5c72ea572d03268117f59cb909366e15da28b96656
lib/karafka/pro/processing/strategies/aj/ftr_mom_vp.rb	100664	1.73 KB	e81d29e1785711f0d5ea94a5cebb93196b16436cc6f9ae2e18b8ed9d3a4b6f5c
lib/karafka/pro/processing/strategies/aj/lrj_mom.rb	100664	1.07 KB	f5bff6e6e5655e992978b7e512f6d41d99f90dd41e617be0c5c282331f6ab4f0
lib/karafka/pro/processing/strategies/aj/lrj_mom_vp.rb	100664	2.69 KB	27b8154ff420c280d58c1ae3c673744587780d3d9fdd2fb8925ac76802d3b11b
lib/karafka/pro/processing/strategies/aj/mom.rb	100664	1.08 KB	4ee0427391674c25623867fdc1e20eac34780a4bce618d9e4a5ac3bce4fd1568
lib/karafka/pro/processing/strategies/aj/mom_vp.rb	100664	1.5 KB	b99f5434109ed3a772053cdde5bc75113e8fbfe7f64fed89d651e515b0452575
lib/karafka/pro/processing/strategies/base.rb	100664	810 Bytes	48bcdc0f84f4114594f510f66c538154a73a1aea07b39767c76471829f8e31e3
lib/karafka/pro/processing/strategies/default.rb	100664	3.35 KB	e40e4df220a7be7dca941085c0a771200ff57263047a28e55a477afdf1a701b1
lib/karafka/pro/processing/strategies/dlq/default.rb	100664	5.64 KB	f78eac97dded0d1c9719e343c1532b160fb262a105fd0a7995af0b1ca67cc359
lib/karafka/pro/processing/strategies/dlq/ftr.rb	100664	1.97 KB	a40b8e81cac63ec06da796ba42ad83e53d9ce3adda24812a399871c9f70a6042
lib/karafka/pro/processing/strategies/dlq/ftr_lrj.rb	100664	2.69 KB	2678b96280dd4320d4c1cfb0899bd9ee17f92144cb455d1e787ab64ff8d1e6a8
lib/karafka/pro/processing/strategies/dlq/ftr_lrj_mom.rb	100664	2.26 KB	57ac049f91ace58de9d9554c1804568adeaf62955d90a34e0626e7e1486c8080
lib/karafka/pro/processing/strategies/dlq/ftr_lrj_mom_vp.rb	100664	1.26 KB	88ef6c998946be73d89604f54a31d7be8092e6da8cdaa227e7fa7167c5b6034c
lib/karafka/pro/processing/strategies/dlq/ftr_lrj_vp.rb	100664	1.24 KB	f62c29ce2ff69eacd99019d3f969b3faadec6771084f06d33c2e3eb737ec7b4d
lib/karafka/pro/processing/strategies/dlq/ftr_mom.rb	100664	2.43 KB	9ddd9ef89e428795f63282d9b0b577eef6bfceb63f054f389b0fafd3da4defa8
lib/karafka/pro/processing/strategies/dlq/ftr_mom_vp.rb	100664	1.18 KB	740bed2de7fb068b462db91508cd7fc4926d8fd54aacc1be578816cd898726ac
lib/karafka/pro/processing/strategies/dlq/ftr_vp.rb	100664	1.11 KB	449f38465231b0bd99375a06a02dcbf870a19e99a41e5726c31efb30c540b3f9
lib/karafka/pro/processing/strategies/dlq/lrj.rb	100664	2.16 KB	2a9f994a3c7b9c8a118ed26191862fadb57a7c1e4b5a98e0238b104c0b2dfb0a
lib/karafka/pro/processing/strategies/dlq/lrj_mom.rb	100664	2.17 KB	24e9e3740e98cd6330311fcb2aade692d231c2a582c41cf3747240cba2a2860d
lib/karafka/pro/processing/strategies/dlq/lrj_mom_vp.rb	100664	1.07 KB	24c50be1e7d8edfec422dac33c7496e2d19cee1f5a300aba1b67f544b736f592
lib/karafka/pro/processing/strategies/dlq/lrj_vp.rb	100664	1.2 KB	f9df7e2848db87a5f5672a0bdc69bfc95a7a52bbee7b9b4bf3c4bdba19a8c228
lib/karafka/pro/processing/strategies/dlq/mom.rb	100664	2.82 KB	b0d5c7570f617aa3c736e0f761e1192cbb20405c636b50425a97c77fa3d5b00e
lib/karafka/pro/processing/strategies/dlq/mom_vp.rb	100664	1.06 KB	b049ae5b236e2bd977f86c3cb627d8d52ab78bce60a329d5cacfdff1c9b17c26
lib/karafka/pro/processing/strategies/dlq/vp.rb	100664	1.37 KB	70648edfe8acba629f0d85ac0e6ec93c28aeb4bedf5387b01c212853315779f6
lib/karafka/pro/processing/strategies/ftr/default.rb	100664	3.91 KB	36e3d470625fff9059bd624ab4968bac080f0c896d8744b35816e17e6bddb86c
lib/karafka/pro/processing/strategies/ftr/vp.rb	100664	1.24 KB	103871c2efad9385a508c4e79b1da52e8623e9cd2d804168df3a803a728fa453
lib/karafka/pro/processing/strategies/lrj/default.rb	100664	3.08 KB	e0740f6f88e6f67ac74037eddaeda641c76875f31ae8e9fa6dcbefdec3bbe33a
lib/karafka/pro/processing/strategies/lrj/ftr.rb	100664	2.49 KB	11d3afdae4c76eab0a5656e8c0f239655130260c5cdbfa98e1a8dde49014f69e
lib/karafka/pro/processing/strategies/lrj/ftr_mom.rb	100664	2.38 KB	10d7a884a1668f01ab0d21ebbc3f3b22da71389c40e7ad235370c754ee326eb6
lib/karafka/pro/processing/strategies/lrj/ftr_mom_vp.rb	100664	1.14 KB	4424e0c1a7457bb1668b1c28fe2aacf4ceae65688e860d9c252021c4a6f6a569
lib/karafka/pro/processing/strategies/lrj/ftr_vp.rb	100664	1.15 KB	959eacf793f09bc3c5384fb52178f32a58775dc256cf0c4867265cefd4214f21
lib/karafka/pro/processing/strategies/lrj/mom.rb	100664	2.43 KB	1267b17dc1c6498a609a39022e9ab03305ee5a96d2fcd7be37201d4317597bcd
lib/karafka/pro/processing/strategies/lrj/mom_vp.rb	100664	1.14 KB	d18a8ff5ffc5ec07fe986465dbba4b31322a104f7f5c599d5437c6605bb6a8f7
lib/karafka/pro/processing/strategies/lrj/vp.rb	100664	1.05 KB	fc9ab6370b508868e89a6ac3695a0dc007e8514938de5cbaf8faf7e73ea2664e
lib/karafka/pro/processing/strategies/mom/default.rb	100664	1.35 KB	0c8716cfdf0bf009bac299ef4c839f771c5b7022185cc352385f8e68c46d662a
lib/karafka/pro/processing/strategies/mom/ftr.rb	100664	1.55 KB	06d3916e6f5fccf3498e927cede7d49399e1c5e610262b6de4fe3718fbca11b2
lib/karafka/pro/processing/strategies/mom/ftr_vp.rb	100664	1.03 KB	51f2e06c71cb2d82c4577a1a27451751104cdaadfef8e5b2da477604b3e5dd04
lib/karafka/pro/processing/strategies/mom/vp.rb	100664	1010 Bytes	8012aed6a8b82aeac15a0540323f1d67a6402cb2427f6eb6c904890bcff05206
lib/karafka/pro/processing/strategies/vp/default.rb	100664	5.12 KB	c99b5d7aaac6fdf4526c1a4839ee39d1997943faf5b21238208e6276da2af6ba
lib/karafka/pro/processing/strategy_selector.rb	100664	2.57 KB	2ade97fcad239f1529cea686406d0fd18ee57366495af48cc5866a6a14abfec0
lib/karafka/pro/processing/virtual_offset_manager.rb	100664	5.21 KB	93221df993d4b462d686049cb15932144bd969ea643530b6ab9dafc753b1261b
lib/karafka/pro/routing/features/active_job.rb	100664	909 Bytes	4a42b2453042f662ca0b6bb317e02c2c22c6424ca557b2ebca419bcc340a03f7
lib/karafka/pro/routing/features/active_job/builder.rb	100664	1.64 KB	b3dbcd1411f27f378216babaa54db4c187af77f74ff3f94cfbb3d5ed1238d924
lib/karafka/pro/routing/features/base.rb	100664	751 Bytes	7d824d04e6d8f7536885f3d9791833e88acdf5c06b0604d8ce807bcabe2a559e
lib/karafka/pro/routing/features/dead_letter_queue.rb	100664	870 Bytes	2e58fa50e0e4b951b5089e4c8c4b3e81a2e9dc571d35dd800248561bf4e0e4de
lib/karafka/pro/routing/features/dead_letter_queue/contracts/topic.rb	100664	1.97 KB	acdb4efe72843c4703d718d66f2ed80ed44e27e59c4d47b1c0c213c59cdd3fae
lib/karafka/pro/routing/features/delaying.rb	100664	1.06 KB	14dcfb46334453ab8da31b5449b3fcab457f1590d6b25a53f66e3ba07678ccec
lib/karafka/pro/routing/features/delaying/config.rb	100664	851 Bytes	1ed5136643c000eaad7c2faeadf606e687fb18cdc1d7b0604f4927920a1e8f53
lib/karafka/pro/routing/features/delaying/contracts/topic.rb	100664	1.41 KB	d9edb7f00e6a78ca718ee8b9cb8bf3497b4111dc65ad367f38f21507ec6ebc67
lib/karafka/pro/routing/features/delaying/topic.rb	100664	1.78 KB	bddb918a98ab5bd887470635a414a29e90232dd661a6e48c92442a8258f6533e
lib/karafka/pro/routing/features/expiring.rb	100664	1011 Bytes	53f8cff399779ccccea1908ae48ac58e08e523be8d832b3d88b17b72da405d21
lib/karafka/pro/routing/features/expiring/config.rb	100664	849 Bytes	383b750cce7da98af94f4f5b6870f44709288966f0a755f92cb8added75ed53a
lib/karafka/pro/routing/features/expiring/contracts/topic.rb	100664	1.41 KB	3650983e5a46b7bc81bba5fa29ba9f0559fad4f374f35e1dd8fd4bb31c3b7f7b
lib/karafka/pro/routing/features/expiring/topic.rb	100664	1.77 KB	cf92d8ff1001baac51f977c85b82e4f59f6d98a820fc07d1ebd616c8fb6b37dd
lib/karafka/pro/routing/features/filtering.rb	100664	917 Bytes	9f38b1477f7bc4acfb2310b6d3175c9f63e65e8d8fab73f92b8c662cc0a51900
lib/karafka/pro/routing/features/filtering/config.rb	100664	1.22 KB	ffe3e6422a883b211a95b06774a90d0c0b3fba3e0023acae0bb8056f5a2c6cc9
lib/karafka/pro/routing/features/filtering/contracts/topic.rb	100664	1.48 KB	f3c96bdbaddf7778ea2061835dc4c7160bc7e24fcc37b7d14265bcccf6b54f3a
lib/karafka/pro/routing/features/filtering/topic.rb	100664	1.68 KB	8e829521e53f1c0787281ca13dee90bf3a3690c4c4afc34d55836d3224965fef
lib/karafka/pro/routing/features/inline_insights.rb	100664	859 Bytes	3ae20de517b8912eed2e1f99ebb8fa1325fa552ae8c5969cb6e8420818b35f25
lib/karafka/pro/routing/features/inline_insights/config.rb	100664	947 Bytes	d36c01053331a35a38b5650c0ad6d4b1a57f316e0a6a53cf75605df21f8c220e
lib/karafka/pro/routing/features/inline_insights/contracts/topic.rb	100664	1.39 KB	62c8130d9348a9d95860e5ff74dbd44ca5dc278ee4f545f479ce555beb7ea833
lib/karafka/pro/routing/features/inline_insights/topic.rb	100664	1.83 KB	f1aa12ffffa92c9e22473add0520b1949b22f3650f4fcf0080760c10140095e0
lib/karafka/pro/routing/features/long_running_job.rb	100664	938 Bytes	1829c9bf0e6f65a888e59980c8250e4f3822d60c3a2f38d9d648fb58fcfd4254
lib/karafka/pro/routing/features/long_running_job/config.rb	100664	861 Bytes	0bbc0e893369eb2e4b01fdce1d50c949c5e71c2214b91b5d2f8a45ab5629101d
lib/karafka/pro/routing/features/long_running_job/contracts/topic.rb	100664	1.3 KB	6f6d75846f6735dcc1cf2e9114191d456422bfb9cd1ac6b8cc70c1b32ffe4814
lib/karafka/pro/routing/features/long_running_job/topic.rb	100664	1.37 KB	84f5afa798d7d3cc936d81752b1625911f7f15e558d72b49b93134f9865e9422
lib/karafka/pro/routing/features/patterns.rb	100664	1.22 KB	65b651fa8284f28ace503ad2535782bb2cbb7f0a402c520bff087a74b67dc4bc
lib/karafka/pro/routing/features/patterns/builder.rb	100664	1.34 KB	c3b45558cf35db7e7224e6804cdc813b0c208d49bd5243aa836a1f986a563fea
lib/karafka/pro/routing/features/patterns/config.rb	100664	1.73 KB	b7077485f396fa2d3a6a37159bde16ec93a56a47736cb96cd0f192befd5de2f1
lib/karafka/pro/routing/features/patterns/consumer_group.rb	100664	2.91 KB	c8bdd48d65343b10afc97f200474de6594891972928ffdd242d473ec03cdf1bd
lib/karafka/pro/routing/features/patterns/contracts/consumer_group.rb	100664	2.06 KB	1cd0dcaa5f14ee8c8e8095b227e0dac67ab42b761a8f3d163f80f87e94bd576e
lib/karafka/pro/routing/features/patterns/contracts/pattern.rb	100664	1.53 KB	a6fe7c75520d276b68e8a40b187ae7548081455d78324807bfb2eaa010b32746
lib/karafka/pro/routing/features/patterns/contracts/topic.rb	100664	1.41 KB	4791dbc7f65020e0bb586fbdde174a1cf201e4a20ee149f3377a5b2197a84237
lib/karafka/pro/routing/features/patterns/detector.rb	100664	2.89 KB	88c6b7dbd84bdd9dc2843ff82b8d9a8d0fedcc449d347de79f1ec593f5c6e358
lib/karafka/pro/routing/features/patterns/pattern.rb	100664	4.03 KB	d1933110eaa04424ec81535b2377980d2f342edd93eb98b119610a8b4654c0f3
lib/karafka/pro/routing/features/patterns/patterns.rb	100664	1.29 KB	4187fdd1de30cf803c8961356bc13a4da93b0a2896afc506568bf2ad9e958162
lib/karafka/pro/routing/features/patterns/topic.rb	100664	1.77 KB	fdb645db12f10ee3e52f6d1a2db4afb92d5b4fc8edc456889024be0493df52e6
lib/karafka/pro/routing/features/patterns/topics.rb	100664	2.26 KB	6e43be3a2cfaabaf116b7468b3dec76d9d0e5762d9f3c7425d6d3622475a9510
lib/karafka/pro/routing/features/pausing.rb	100664	851 Bytes	3620fee01f87cd1a9d7411b655191d29e7586c648d05fcabdf37779dda1014ad
lib/karafka/pro/routing/features/pausing/contracts/topic.rb	100664	1.85 KB	df68eb57f25eee08b1ae96992eddd98ee6a6ad669fb4c524c78a3aa92c1def8b
lib/karafka/pro/routing/features/pausing/topic.rb	100664	1.75 KB	0a8fb3085cfb6384da69b7f70eaf08b5ac8057996500c31f391c9b7a4e7e9b40
lib/karafka/pro/routing/features/throttling.rb	100664	1.13 KB	ecd91dbc95f1cac69b6926077b648948164b51c7182a141bee01f50e40f78a0b
lib/karafka/pro/routing/features/throttling/config.rb	100664	926 Bytes	e1790267ef775682c0205d36fd25f7d25899d311a8c539536342f7a09016fc1e
lib/karafka/pro/routing/features/throttling/contracts/topic.rb	100664	1.51 KB	1f2b428bf418fd31c76eebc3a651a46e3577712648b563ce46459ecce2b22a5e
lib/karafka/pro/routing/features/throttling/topic.rb	100664	2.2 KB	7bc8909af23e2b419e8d3f922898c3ef3e801c4c2cd83fb63a288380668fb8e6
lib/karafka/pro/routing/features/virtual_partitions.rb	100664	949 Bytes	de50e6f5d24e8f44103e1d681572d19904dc77d5eef875b15059c8e42dbdf1ee
lib/karafka/pro/routing/features/virtual_partitions/config.rb	100664	917 Bytes	61295721eb0188b42666d4af29a13a3b20186e254a44e4948e98d909b313f05b
lib/karafka/pro/routing/features/virtual_partitions/contracts/topic.rb	100664	1.95 KB	f2d1d1bcf84bc7547b0d6cc1ac9ed13836db45766e2a1d49fc01a397e19993e1
lib/karafka/pro/routing/features/virtual_partitions/topic.rb	100664	2.17 KB	ea2cdc3695664c36b8f8f0a36670ec3d93eea90d47f231e1a09d4ec2c1dd5188
lib/karafka/process.rb	100664	2.44 KB	b7ee1522ef34d00853672ca95b1272f1ea48397230e460cbdd4d6576abf2580c
lib/karafka/processing/coordinator.rb	100664	6.71 KB	b603f9e3b7b8995d328fb70c4e3a588aa242980bfee80210934889bcd289682d
lib/karafka/processing/coordinators_buffer.rb	100664	2.2 KB	36806b2c41c96fadbc401ae68c338ef1e5e7f28935fa5cf82888f2f82e2be7b4
lib/karafka/processing/executor.rb	100664	5.99 KB	4e052f17b1a1fcc86e7384962618aa96661e011689de4c7f771580d5dd8215fd
lib/karafka/processing/executors_buffer.rb	100664	2.49 KB	ce0697367a220a319a1113899c5a8ac47e03c0c5039e86c4039d95308b95de39
lib/karafka/processing/expansions_selector.rb	100664	819 Bytes	3eeb757181c1403142e5063dda41fd9031951354801d220a16fb8b0eda695c76
lib/karafka/processing/inline_insights/consumer.rb	100664	1.79 KB	788bf99dc2e5bab8e5ba28516ac2f15146e92df18a5f24af93df69c9b4c0a3a2
lib/karafka/processing/inline_insights/listener.rb	100664	480 Bytes	032892bd4096fb0979d46682ce94d642f1c170dfcbbe41db5873f564a71d4396
lib/karafka/processing/inline_insights/tracker.rb	100664	5.36 KB	4c5f4c3e928d9be312758fdfc9aa6438c143e3c85b3537af3619353e6bccdc02
lib/karafka/processing/jobs/base.rb	100664	1.88 KB	b35d9e23f0c3206af5662ad886a8f9833f2bf4fa8cb4fd5023a185dba05bb917
lib/karafka/processing/jobs/consume.rb	100664	1.3 KB	c76c1383432e6a7ac9c788ab01482ccc6daf6db14d1c392f211b469b0b0c2eec
lib/karafka/processing/jobs/idle.rb	100664	652 Bytes	2f49e1398c2a5c636f3f95f46b3dbf013043335b4b3cfba1e8b62f680963a8ef
lib/karafka/processing/jobs/revoked.rb	100664	561 Bytes	7e2ddcbb18c88f9761943988cd70a4bf82e528b448adfa3391a3f3477a2ff829
lib/karafka/processing/jobs/shutdown.rb	100664	596 Bytes	60b136c19adc9f79982e65b0f167f42ff991446a0b3201f71c3dd5c6e7207899
lib/karafka/processing/jobs_builder.rb	100664	945 Bytes	00d79cb98b1f7ecc7cf741f3fa46426c05e650d0f948850e8ab6bc352827c8e0
lib/karafka/processing/jobs_queue.rb	100664	6.16 KB	28828c72fb6f62a9ffa4d1605e4fd152f09df2aecbbce6a529e71b023b7f3002
lib/karafka/processing/partitioner.rb	100664	824 Bytes	a14757c248a5c733fcd7bfd1ff31e848f16f90ed66f83676853da4ed7b08a87d
lib/karafka/processing/result.rb	100664	1020 Bytes	65f48cf2a034d16c4338fca3557d87e899956a037ccb0b3feb1548be97735a86
lib/karafka/processing/scheduler.rb	100664	718 Bytes	9decebfc26fdec91c0d4c3e06ed122dccac1fb5e4b0546026786ae9550dc181e
lib/karafka/processing/strategies/aj_dlq_mom.rb	100664	1.52 KB	78e64acf35ee113efc737391c29fde772834da21600829d4c0e893c40fe1a837
lib/karafka/processing/strategies/aj_mom.rb	100664	461 Bytes	5ee3917968cab8cde257fd8d9be9bc0cab310e992c8ae660f0b263c921e53f48
lib/karafka/processing/strategies/base.rb	100664	1.76 KB	edbd3894289fa10c48e0598645238ac69b066545bc1cb61473fdcf0b961b8cf4
lib/karafka/processing/strategies/default.rb	100664	5.72 KB	0a46900bd970d2903f1d2bb6cffd7ce12b3ef0fee833d38ad0c954c57627f0a4
lib/karafka/processing/strategies/dlq.rb	100664	3.3 KB	d1e62c6460f03bae92ebed9ad33b17492cf69db979b3a4541cbdccc33f5d3a7d
lib/karafka/processing/strategies/dlq_mom.rb	100664	1.8 KB	b55b667f041c123e42ea3dd7a7a37b828ddfdd52244bd273019f7f72cec1a2b5
lib/karafka/processing/strategies/mom.rb	100664	771 Bytes	e79e3596a639247b0b9823a1615ec6516c7de50251017b47ed6961319246d567
lib/karafka/processing/strategy_selector.rb	100664	1.26 KB	52a4025bea77fd7f2768d18244937e58f60e761943c1183bdb549bb2ffac0c1d
lib/karafka/processing/timed_queue.rb	100664	1.6 KB	af0a131fdd96d5a5849c15f0bd7c633ae65f9b3a8b39114af83ca4a735670640
lib/karafka/processing/worker.rb	100664	3.15 KB	012ad1082a7d456c3f32b426d9648cb683868d0ab270649313cb10ee5ae4a9fa
lib/karafka/processing/workers_batch.rb	100664	658 Bytes	6a7a594eec5acbff165ddfbb74d930282b65721aa694f2e73fce851a2152c202
lib/karafka/railtie.rb	100664	5.37 KB	7aeb77ffd201a2b9378aed224690c759f3b4acd1ee740bf6f1507ca8be9e785a
lib/karafka/routing/activity_manager.rb	100664	2.36 KB	8ed8dd07b21698fe6bfef31732bc970448bfe62a5ff24c8a9a8cf114496f5dbf
lib/karafka/routing/builder.rb	100664	3.94 KB	240cf6273858813133e6738c238f02595bac7d1d358aa558bcb7d76f22d8977c
lib/karafka/routing/consumer_group.rb	100664	4.07 KB	2cdb4cb82d77b96b9a1e81c46b39439d93080d161ab91e297235581a2eff7c2a
lib/karafka/routing/consumer_mapper.rb	100664	870 Bytes	45210f00fb4409616bf0fe89e75cb14c6ddd2015242711ff04c8d1886d4f3b9d
lib/karafka/routing/features/active_job.rb	100664	338 Bytes	30f236cad4b9bfae9cc952a289851d6c01e06f059962fc2424b753c5cefcd7cf
lib/karafka/routing/features/active_job/builder.rb	100664	1.05 KB	98ffc36fcc07f8e04b5d01f52fae747994e12f99934597b3351f54159b22da10
lib/karafka/routing/features/active_job/config.rb	100664	299 Bytes	488a9d1a6c48d59e3d0f833d8fe9423cfd2bd677e247bedb2ecd6218ea633c1d
lib/karafka/routing/features/active_job/contracts/topic.rb	100664	1.57 KB	9744cff83a3bd4a7a1f481a1c17ce8e32d7490f2e232544c3c6eb1e79fb7db77
lib/karafka/routing/features/active_job/proxy.rb	100664	248 Bytes	3947778773d6a4f2e873470181eded98000665ba3517a91761e7e9394117aeee
lib/karafka/routing/features/active_job/topic.rb	100664	993 Bytes	4655606aede3ce4186ad736cc9311f5bf30238eeacb38d1d32f35f3d45b20a4e
lib/karafka/routing/features/base.rb	100664	2.42 KB	d89790687cce04836241c357508eaf1f7eb1d909683e67eec811301d84025d6a
lib/karafka/routing/features/base/expander.rb	100664	1.82 KB	d38f48e308823049cb9a6ad8212f75fa9c5a38ee456c3e9f3a779cc07bd3aa77
lib/karafka/routing/features/dead_letter_queue.rb	100664	494 Bytes	2ad5b4f2c4f77be2933586265cf5fe14141d3a3badf7a57c928709ca0a90c511
lib/karafka/routing/features/dead_letter_queue/config.rb	100664	491 Bytes	a8d1ba45fdaded04d8a720cd586f534ba77dc77796641112370fa1df7ac4acdb
lib/karafka/routing/features/dead_letter_queue/contracts/topic.rb	100664	1.44 KB	c0e1e630306d4be128a6d68d298e4567b08b7c84a64342705b32ce165023f213
lib/karafka/routing/features/dead_letter_queue/topic.rb	100664	1.25 KB	7c2ed9c449e9b3012c8766ced8a3873b0da8fbeb93bf4e9cc9abb78b69145be2
lib/karafka/routing/features/declaratives.rb	100664	472 Bytes	e032c26efb9f4414ffb32e3f8e76e56e8c723df585de3d9cecafc4323b7eded6
lib/karafka/routing/features/declaratives/config.rb	100664	387 Bytes	881fae53261fe894be5638cdbb12f6114bb60bbc8c8df341dd9a3317f6511c94
lib/karafka/routing/features/declaratives/contracts/topic.rb	100664	1.07 KB	dad1a7360a91ceb58289621f806b3ddbc0cea3d9f7a55797827b7cc507260e32
lib/karafka/routing/features/declaratives/topic.rb	100664	1.28 KB	1335f455c5310c24752b383370b6bd5eaeb5f0eba48673d40c9cfed2aba13399
lib/karafka/routing/features/inline_insights.rb	100664	1.61 KB	22727dea16d23c35e4086b8ae74f0b68661f70868d089e67d2a60fbba0d33495
lib/karafka/routing/features/inline_insights/config.rb	100664	300 Bytes	85141f03e948a45ff1ccc6b1f8d22d3f5053658ac0c6db6c1df5e01aaf282129
lib/karafka/routing/features/inline_insights/contracts/topic.rb	100664	772 Bytes	08a572812b58d4161820efea23b149cecd7d1fb79bdac5241441090d46d7bce0
lib/karafka/routing/features/inline_insights/topic.rb	100664	757 Bytes	7a4f174ddb9155cc21fc52f7c0dd7cca837edf79de37f642dafcb9e4615590a8
lib/karafka/routing/features/manual_offset_management.rb	100664	642 Bytes	3ae42fa14515bb195bdd5b6da90b595146b1589c39c6b7e0d21ac88c64bfc1a6
lib/karafka/routing/features/manual_offset_management/config.rb	100664	329 Bytes	1e7419d90d72315f281ed7818fac3f627226c8ce8896548b2f02d8ba2d5807c9
lib/karafka/routing/features/manual_offset_management/contracts/topic.rb	100664	785 Bytes	6b69ab2c89a8f4f75c13fff0120abb0c35c99978c2546b560606cb2f46a05646
lib/karafka/routing/features/manual_offset_management/topic.rb	100664	1.21 KB	be5c6be5e82e6805472700cae99d97991265d33b3c270c0831e76917af1add36
lib/karafka/routing/proxy.rb	100664	1.8 KB	183b903fc23709be7e010409feb7df0795694ac6cbf6484a3b3c0217332dcc5b
lib/karafka/routing/router.rb	100664	1.76 KB	eba17a362fa082a59804fd9cb469e2f0aa501322d5b728d410eb4a0b98213a8b
lib/karafka/routing/subscription_group.rb	100664	4.36 KB	2c4b512be39d9bdd24c4a582f17805f8a9a597e29f7bdcd548aba135f667bcdb
lib/karafka/routing/subscription_groups_builder.rb	100664	2.27 KB	5f48c784628bf9a3cef41137a61c49d9155ae87a86d7aa5b9ef76575ae3f496b
lib/karafka/routing/topic.rb	100664	4.34 KB	f796cb50fb00427844a1c7e2db34cc68b860be697bef6509bf17d36e63b6b478
lib/karafka/routing/topics.rb	100664	1.23 KB	cecd2287983c3109985443a2c05ed25d8b4c1ea2ab3d13f6ebd4d5296bad974f
lib/karafka/runner.rb	100664	2.05 KB	c149f4752d311b98f70d20c2998847d5b51a540944e4e18fd0f521960c861244
lib/karafka/serialization/json/deserializer.rb	100664	683 Bytes	b70bde3aca8a988b35fa76bfa1279f0ded5bd85cf9b504442d75ad39cb6ed1cb
lib/karafka/server.rb	100664	5.8 KB	0b3f44a09104269a9806eaf305369e82e0a4851f691e478191b70faae2ea67da
lib/karafka/setup/attributes_map.rb	100664	10.2 KB	21640785d330a2b85418aee2ee459df36e60ad15a31da5bd402ee15026feeb6b
lib/karafka/setup/config.rb	100664	15.7 KB	ecd0f5063bc1ee0484cdfb4c9d294b2f42762930d29ab39ec4ef6aec242f24dc
lib/karafka/setup/dsl.rb	100664	555 Bytes	d9a93c794c071cda753465d9145dc657a8a2ab5d226e2fc0724e134c644f09ae
lib/karafka/status.rb	100664	2.17 KB	1d5f4ecb69ed0f41d17c8b063f884f741e131c8bbb6acdff00bebde85225bc24
lib/karafka/templates/application_consumer.rb.erb	100664	286 Bytes	44a56710679e00a419831a79da526cbad4a0d15c95f2834ee09e03ed0185ee0f
lib/karafka/templates/example_consumer.rb.erb	100664	369 Bytes	ec8631c779428e18877526c0a24d0c33c9140e3abe604a76f387742d84592c63
lib/karafka/templates/karafka.rb.erb	100664	2.5 KB	80d904b3c90db32d548f8dc0e1ea6a2f6dc0917daccb827dc3fca07fe30e423a
lib/karafka/time_trackers/base.rb	100664	387 Bytes	49b0470d8031ae5b30aad7c9294376b8ce777da4a25eb9f4d037851068a43913
lib/karafka/time_trackers/pause.rb	100664	3.75 KB	1e3d27300f63fc2910e358cbc6d8c7eb60b8851594cb93f5a61901e4b1ee7168
lib/karafka/time_trackers/poll.rb	100664	2.07 KB	a1f5688f32f6901a93ebb913c0676703f22ff33da0aa377100bda155f6312d16
lib/karafka/version.rb	100664	123 Bytes	4c118b379ff044d03c7629546a7e14aada434557e7d465cfaa032001aaefff9d
log/.gitkeep	100664	0 Bytes	e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
renovate.json	100664	159 Bytes	37f6199435407485a4fb924c3283710f2c938adf69489aaeb5ab208bf5f4229d