karafka-2.4.17

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

number: 2.4.17

platform: ruby

spec_sha256: 26827037467573a5c81c297beb0ff2422f4fae0c8d72ee880585c86106032aae

sha256: eff8c8590cd9324aba0f0eae0cd7aa5099e5897c1ba0eea0242fa77a8b536f35

created_at: 2025-01-15 18:23:55 UTC

updated_at: 2025-01-15 18:23:56 UTC

position: 0

version_data_entries_count: 463

uploaded_at: 2025-01-15 18:23:52 UTC

indexed: true

has_extensions: false

extensions: []

Gem size: 305 KB

Version Data Entries

Total: 463

Unpacked size: 1.17 MB

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.77 KB	a594941efb74773d11c50883850f1d922260276bfca83b4abaa1e54b1506d4c1
.github/ISSUE_TEMPLATE/feature_request.md	100664	593 Bytes	739d98d20ac43aedb1aa0c34d93209a440fc0ff142037f76950c95888dc4cfeb
.github/workflows/ci.yml	100664	6.18 KB	d4c0eef39c43db946044c789f7639abf56070bf97603f2b16d364dcb56b418db
.gitignore	100664	1023 Bytes	cfaaf830420e24157da66709f087a6f1c395deb5acf38a0bb162c3a77e6fb22f
.rspec	100664	311 Bytes	19308d005f1740d1061cf145b4c599fec685c773f68561dc60217b08d1295f6e
.ruby-gemset	100664	8 Bytes	2afae0b89d0be84fbce9611eb5bdcf52d69396704dc429f68b6270ce56c8880c
.ruby-version	100664	6 Bytes	cc714f5e0224a78311f4835e9fbb88e69ba35f65e7dd5cb7d86cabb4a84bbd72
CHANGELOG.md	100664	68.5 KB	3217993345e20048e2745f404507dda422b3990f545e214a802c39b9b8360719
CODE_OF_CONDUCT.md	100664	3.14 KB	c5be22a6783a9daf04a76f109d5695618c5e55638e2f5c5dc8821c3180ec88a3
CONTRIBUTING.md	100664	1.77 KB	0bbe6d4e34b631d47439606f987678f5db1f64617e9776023155f134f07825c1
Gemfile	100664	694 Bytes	2b6f4058c617823909e5e8c5aacd196cfa5843d289d32c3e12bb25f72e9d35c4
Gemfile.lock	100664	2.75 KB	ad213b4320e95401dba9111d97c4931293a84881c51018fcdd3a32cb1b01d6fe
LICENSE	100664	745 Bytes	78cb67ef59e77ec4faac8b77473549254efad2a8e252f7a22451f1164614e7fe
LICENSE-COMM	100664	15.7 KB	7ac2dc542b53f8a3913fdd2e930d9b5c1b4e1d11b2316dd61ddc6fe1ceb4fd07
LICENSE-LGPL	100664	7.47 KB	da7eabb7bafdf7d3ae5e9f223aa5bdc1eece45ac569dc21b3b037520b4464768
README.md	100664	5.54 KB	83d14a867c0090252fdefa59bf105c8e35acf78b9c2fef7817d511c74b39949e
SECURITY.md	100664	1.37 KB	dbe7c77ac440f6e65868ef3a7aff23c6a11a0f304767bcd371dcf7bb4a3b76f0
bin/benchmarks	100775	2.89 KB	ddd485a05f185b255d904fcaa541a555e0176639781433f1b2e8d23484f96e27
bin/create_token	100775	586 Bytes	a47a067dbf5cd47591d666fa9bb966d864d6114f700d3d21dce84dba86cb1533
bin/integrations	100775	9.55 KB	00bea8c206752a2b8b095f449329ab88ebee2d42334b3e15c6f3a19432ea8258
bin/karafka	100775	235 Bytes	cd1e04f7f42ee4f7572d07bc74bf9bf7c318812e92e63a4b7533324149c54fa1
bin/record_rss	100775	1.58 KB	9b8f5fe70fadaadea6a5148407652c48558226d4781a48208a802eebc788c1d9
bin/rspecs	100775	373 Bytes	30da8748baf4507436d82edcec552afd613a346eb06df83ad1f6f39f198cf3d5
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.pem	100664	1.56 KB	3b54f9d2b500c84c5aec36d0b7559f690d008b4cdc5beac634f655e3077c0354
certs/karafka-pro.pem	100664	601 Bytes	80e379259996ca2d52259405b21c86bb20306c53be5ce0e384b62546466dba4f
config/locales/errors.yml	100664	9.78 KB	bf98444c31f752ed965f35ad76bcb703c39b3c0e6b3b130c58120e6ee2aec760
config/locales/pro_errors.yml	100664	8.37 KB	d9a4c9881f58f494b2f76dbab3c0a2dd37a82f2aff1a7ad4cf73d7a9f042ffe5
docker-compose.yml	100664	979 Bytes	ba9e201cd39f3f681a97792b3d1ec79d6a35f9ec14bfd9d79d57539dc01649f0
karafka.gemspec	100664	1.82 KB	06461b1163539a0a4f91fc5c60126e4840e9fdff4750ed385533934bbb9bfe88
lib/active_job/karafka.rb	100664	482 Bytes	4dea0184240a1b8bae6bc97022365d48a5b03b34e73b88a23410ff89b57ceafc
lib/active_job/queue_adapters/karafka_adapter.rb	100664	1.44 KB	090b44dd2e0d7d0bca7693e1bb3a5dbb42156fc3b32195226e1c3028e5c72c9b
lib/karafka.rb	100664	6.22 KB	75021041230cab380231c1efbec3323c0213c578ade98c8a2541715b5c693efa
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	2.5 KB	b26ea84c8639757f2364561c6cd4929beff9209f29447c56936eda91fbd09d73
lib/karafka/active_job/job_extensions.rb	100664	1.15 KB	b4c0d6cdd3eff24f1c502f42e4d5619ad96b25357b13bf4e20bb66afe90185b9
lib/karafka/active_job/job_options_contract.rb	100664	1000 Bytes	9e627a98870a73f87cd05f5023a08d20af77025b7eb93ff9ea39c2076e02d22d
lib/karafka/admin.rb	100664	25.1 KB	2303880b5ece9213b28bbc8f87bec0beb7d35cf2aaebae05b00ab5364f5a65ef
lib/karafka/admin/acl.rb	100664	13 KB	8e466b6b7c0d7ba3c10ab7fcefd4f08d8e0ef6c5c806678e0a8fc1f91de9dd8f
lib/karafka/admin/configs.rb	100664	3.74 KB	5595f91b635c3bcdd82a0181fc000775d89587d3e3cf727cf223fc9765ecec3a
lib/karafka/admin/configs/config.rb	100664	2.59 KB	93061376ccad0ce44a1c609cb87c800bcff60bddb23470b480f32223969f07a5
lib/karafka/admin/configs/resource.rb	100664	3.07 KB	1240149e01191872863e9160c895ab27e065b6bafb18d1a58e71b3ebf183768f
lib/karafka/app.rb	100664	3.8 KB	0ff03a26294ff9df513f7035d71da5ae9f0c99b6604a8db565bdf9cc89b1e5ca
lib/karafka/base_consumer.rb	100664	14 KB	13b20e1f9a00deb825c8c2393b6abd2c586dcb3f9ca3b7e3d20bf7c1711ee561
lib/karafka/cli.rb	100664	1.77 KB	3b8a37121b1744f464dcc2a29a4aada023887a4c464d4af662396e0e3d4a296f
lib/karafka/cli/base.rb	100664	4.77 KB	ddd2445e6cedc7d7ff44e9cbd04dc970b9761f2063806e53fa7c9eb6805fcb50
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.06 KB	8e5153859d07e6520d42eaf5aadf00e765f08b40a5298ff7237d00ffbf7fa815
lib/karafka/cli/install.rb	100664	2.04 KB	057b621585b24074e5e9a2b3c271e81c356b6f2dd73bd54f5dde5f8cefdc6b1e
lib/karafka/cli/server.rb	100664	2.81 KB	52ad931e737251db631ea9669c31c1c11f6b7c143f53e9e7dddf04f6df20af0a
lib/karafka/cli/swarm.rb	100664	819 Bytes	5926a645507e60c32ae1976e4b293ab3de4bcc70c2e36fca718452558a10d78f
lib/karafka/cli/topics.rb	100664	1.73 KB	9d6ae7db27383dd15d64e986fb0149550a7ace6831d0923e73b839c72d4a5df9
lib/karafka/cli/topics/align.rb	100664	4.32 KB	2cacb7eee873ddd092ee8cd47aeae6cb5a7e0942e1925c83a60e1f1b7571e1e0
lib/karafka/cli/topics/base.rb	100664	2.22 KB	8bce1464f88b1e1f38d178eecc316037edc42b0b33d8ea1b4754b81516a195f8
lib/karafka/cli/topics/create.rb	100664	985 Bytes	dc872ce8bb6daaee9d6982b49ffa85ba644a814c39b6f7abf9c109628ccd428b
lib/karafka/cli/topics/delete.rb	100664	776 Bytes	14259ef3850bce0997240d42464f023e5cbc6cb5227ea1a3073d51049c3c4225
lib/karafka/cli/topics/migrate.rb	100664	691 Bytes	c41b405fff3aaf46da728531b7ffee9a58bacf6a0f93632c93a12bc21ee6b13b
lib/karafka/cli/topics/plan.rb	100664	7.16 KB	e2ee744412b23f73e24c24449754d0fb8a1b5d17b5851b3c9788ff8bebb5deb6
lib/karafka/cli/topics/repartition.rb	100664	1.44 KB	a7852df8356ad86487830c88b4cca0eacf3bdee61ccfb117d3d19ff1f8c92017
lib/karafka/cli/topics/reset.rb	100664	380 Bytes	7c6e99accee98528b19212f480392e4899fadf77a0b3fb9592d619af6dcfda73
lib/karafka/connection/client.rb	100664	31.2 KB	ccfe16c38d2772a95a58f24ca79cc2527822427e3a3493fab356e7c8db18134c
lib/karafka/connection/conductor.rb	100664	1012 Bytes	43843ac67de5d75d3bda05c474fb60e30954a25d8ac9c6f087df4e408569411f
lib/karafka/connection/listener.rb	100664	21.1 KB	e3ce2358d4065d448944056041b6a713609cb7ae469c5fc22fdef97c507519c6
lib/karafka/connection/listeners_batch.rb	100664	1.14 KB	1193ab461f6853043359d463761bfee2f72a9f20249cc2ab07a5f5daceed7ca0
lib/karafka/connection/manager.rb	100664	2.6 KB	3a2e74f7d6f1b0bc55899927de016b99435c6c3fac62fdcd836ebcd8d72134c0
lib/karafka/connection/messages_buffer.rb	100664	3.79 KB	88f8ed08fbdcd5ad1e3874722244b832ea42e3a4d6826e9005c1f36d6e683332
lib/karafka/connection/pauses_manager.rb	100664	1.37 KB	48308ac4d96b120532a411b526c87b06a2f74902f64f33d129aa9fca27743965
lib/karafka/connection/proxy.rb	100664	7.6 KB	34835ca4a9df8fa7087ecaeb56099e16849a1f3601c5c2a532447a5f51527d5c
lib/karafka/connection/raw_messages_buffer.rb	100664	4.74 KB	e399bf2caddfcdfd587ee7a6150916b261e51dcebf33c7f2d590b929d26291c9
lib/karafka/connection/rebalance_manager.rb	100664	4.49 KB	993343ed323ef60c1bddb8f90c42795bff1a01c2ab89af7976dd1cd4ef148dee
lib/karafka/connection/status.rb	100664	2.44 KB	3120f086a27ef3f993dd94f213c8b74264fcddc689813037cd797741686c251a
lib/karafka/constraints.rb	100664	1.6 KB	58a3d3a707c9130782649973c6b9519185843a4613068a65505a88441eadfdff
lib/karafka/contracts.rb	100664	331 Bytes	e23cf30da1bf460ce8315a4867f51e4dcd5c1b057b7d4ec1a86ac63fd088be55
lib/karafka/contracts/base.rb	100664	621 Bytes	c1b2417c33ff3400d0ca5d768b4bf3297877d76916ac89257afe231e24bd2dea
lib/karafka/contracts/config.rb	100664	8.24 KB	5e03946d70c27040c75de8b91f44a30b1e47fcb938a731eef9dfff3acef8bba0
lib/karafka/contracts/consumer_group.rb	100664	2.59 KB	af08d0cc450f00ebda2d4ab7babf27f43b9f28bb4058f78c589b53d63ba3a7c5
lib/karafka/contracts/routing.rb	100664	1.92 KB	9063492e085b9607f30da79e231b147204a1c934960d8a62359ddbdea55ba3ab
lib/karafka/contracts/server_cli_options.rb	100664	2.97 KB	eeeb43714bc436f832811d71d16ef016268fe97a22a19ce5e798f1e3fdcb1f3b
lib/karafka/contracts/topic.rb	100664	2.82 KB	eec32d8e6b140deb0e78b08cebbb31be39815952d5808a5df80c630d345ddd69
lib/karafka/deserializers/headers.rb	100664	385 Bytes	df5242482ad1d31a786e3d65b09484eb022b33fc64e12cf27370ecbcc7a78616
lib/karafka/deserializers/key.rb	100664	403 Bytes	5c31e17955dcf34babccab32ed28e4595b494ad86f3049ce0a2f3e4b18444664
lib/karafka/deserializers/payload.rb	100664	566 Bytes	e4e8cd90b1a3a84765ac4f409d36806fb5914c040228d2f873e60339af5abb70
lib/karafka/embedded.rb	100664	2.35 KB	ffa69a1297852dd53c72a3acf10a7723b62769a6f2021a1070fa619888609021
lib/karafka/env.rb	100664	1.43 KB	7c80157166da7eb037f8ad61d9436acb1ffa8d36aca62243732dc55f2451f282
lib/karafka/errors.rb	100664	4.61 KB	77caf1f47612337116f6642c2b6fc9fd5798e016b7fe50c3bd21fdc05bdd6a5e
lib/karafka/helpers/async.rb	100664	1.56 KB	6df5dc40eb5e8785a062e2a5ab7b668d8b1f8e7f6d96071022b3313660a0a456
lib/karafka/helpers/colorize.rb	100664	836 Bytes	8576b60ac437a6a2eecfff4403f6801cc4efdd0cc76614f3b61d76ff482b81dc
lib/karafka/helpers/config_importer.rb	100664	1.3 KB	9141cd8946a5c732f42bb5050b615f2459e90ac3fdddea82559201286a5d1ee8
lib/karafka/helpers/interval_runner.rb	100664	1.3 KB	814cbafb7114daf94ed1ca043415b36d53679c3de57c704f9421bdf95077cd99
lib/karafka/helpers/multi_delegator.rb	100664	933 Bytes	c472db16985b61622710a9fdb697d6d930d31ee02e512d8f47bec4e6ab4838d2
lib/karafka/instrumentation/assignments_tracker.rb	100664	3.32 KB	f3803ff9ccce54f33970ae075d0b1302a6adae869e8be6a790d4a631fa0f4c61
lib/karafka/instrumentation/callbacks/error.rb	100664	1.84 KB	53179581f23f5f5dd99c32a7cde36cf9207d534732896e942fc876bc249e9eb5
lib/karafka/instrumentation/callbacks/oauthbearer_token_refresh.rb	100664	1.18 KB	cb564f685ae9b8778b7dad994421db7e0cd0bdeee6d4b13be1aa54e707b3fda5
lib/karafka/instrumentation/callbacks/rebalance.rb	100664	2.71 KB	8fd2492eadcf10b966cfd76acecc8294d877d217d695871980ed77ef4eb5fd59
lib/karafka/instrumentation/callbacks/statistics.rb	100664	2.16 KB	2b8f31268af48c89f974f565f8b7dd9bd4817d2b1e67697c4a2fcabeba377166
lib/karafka/instrumentation/logger.rb	100664	1.7 KB	9c60d2e6106306243c2125fa7c7ebe4299d4d8e774a5f1df8a7b44db83180f9b
lib/karafka/instrumentation/logger_listener.rb	100664	14.7 KB	f4cca432d2015b6cf041c6efe2f7ddabc93a6bba940021dbed313d1841980f8f
lib/karafka/instrumentation/monitor.rb	100664	761 Bytes	33f962b4196acb949eec51099f7916c258f452161e20787b26aa6ccf4841d7b7
lib/karafka/instrumentation/notifications.rb	100664	3.47 KB	420eb5c9b0ab4c30315595ffeaf5dae16656e450312d2483fd6049ed263f3990
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	5.47 KB	6537b87d380193b35d7d224c0b6fdc80e13db1d0f5fa14fde556e5cf3743e865
lib/karafka/instrumentation/vendors/appsignal/dashboard.json	100664	4.73 KB	303b775ac4a597d912c38e57282141a9fda589ddca141a6948cd31f0be9068bf
lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb	100664	790 Bytes	6f4fecaf54c683074e7b7d8c077ebe0e75e17af5fff053c252c034277b663bd6
lib/karafka/instrumentation/vendors/appsignal/metrics_listener.rb	100664	12.3 KB	328c5749424780d8e6a22c495e46cc54920090374d4a43714503615eac329c0f
lib/karafka/instrumentation/vendors/datadog/dashboard.json	100664	16.3 KB	c09105abeab5dfb332db4a26ab3e25c3d7acb97b2b4f6e37530f8598b110a3e0
lib/karafka/instrumentation/vendors/datadog/logger_listener.rb	100664	6.33 KB	bd4fc731c7267636db8043ca4999c6d35153b151ecd670d813350dd7c5bcf1ff
lib/karafka/instrumentation/vendors/datadog/metrics_listener.rb	100664	11.5 KB	0e9abf7e6fd029c925af8b0e2441c8ebc0ecbdd684d2a6d0890b6621b42e7939
lib/karafka/instrumentation/vendors/kubernetes/base_listener.rb	100664	1.94 KB	a87d51feee00138158265fd27d7521d73fbfe9f602dd418be064ad5923715751
lib/karafka/instrumentation/vendors/kubernetes/liveness_listener.rb	100664	7.67 KB	7d39332d03ff9def6603bef6b5b1d56ab53ea4e0d20c499e7b794a3a2f4372d4
lib/karafka/instrumentation/vendors/kubernetes/swarm_liveness_listener.rb	100664	1.89 KB	b9765c7b3a03b8596b0fd1129a51e1c15de4dc9a0590a604074f6856879c9546
lib/karafka/licenser.rb	100664	2.53 KB	a62f7887c49f58505434cef02b75546c942f08bedc894d646a7dc5695b9f4627
lib/karafka/messages/batch_metadata.rb	100664	1.53 KB	3356e321fe33415523553e1b6672950bec6c79d6c630e476e31ece40d2bfa670
lib/karafka/messages/builders/batch_metadata.rb	100664	2.56 KB	e1902dfa26d876bbcbafedeec3378fcd09640d291802b160293a4b431c562026
lib/karafka/messages/builders/message.rb	100664	1.7 KB	9e97d57d359c2affbb3b646887831f652e13399f519085692dc168934a724044
lib/karafka/messages/builders/messages.rb	100664	1.25 KB	d4fc0af2584665d4f67153a789fae62b90229faefca0db7759742501a0ba66b3
lib/karafka/messages/message.rb	100664	2.04 KB	9f135fcd91f4e3a174e7505c79dc047961b9d9cf7736526a8653d9d5a616df5d
lib/karafka/messages/messages.rb	100664	2 KB	846f17fd9f01d11b25c2e7f781f00ae007d2ea18a35db1a6c05aef48ca2cbf81
lib/karafka/messages/metadata.rb	100664	808 Bytes	9c7aad6b4881c5033cee493f5d6b9a1a06caa544485da53dffc06ed3bf9bccd5
lib/karafka/messages/parser.rb	100664	376 Bytes	e69d075c6f07fdb38c79ba4ac662116df21f77ac253e0c9f4a796cb08ee5e5de
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.47 KB	689905574597017581d7531d389e92659f4a5be0c3f388af187700cea6458d38
lib/karafka/pro/active_job/dispatcher.rb	100664	4.89 KB	8e504ad5bbce5c1d3eba1f421bad10ff79773f7bd9a52aacacb73f179b1787b8
lib/karafka/pro/active_job/job_options_contract.rb	100664	1.52 KB	7309a270b6dacbe53eb2e0744b36339d8403d957a21a1e1c26790c19d2bacb0e
lib/karafka/pro/base_consumer.rb	100664	1.92 KB	156557c614f8f642c671c6e1100aea935e230f2863fde4814c79f544ba3be87a
lib/karafka/pro/cleaner.rb	100664	1.22 KB	64b32cfd7ba92e31b07c6b562fc4a0d38c60951ab4ec5b740b245e9085d1a9f5
lib/karafka/pro/cleaner/errors.rb	100664	507 Bytes	317faf381c501a6def0e13c32e686789679b69a1df0e4bcaf84ff2b86ff9b88f
lib/karafka/pro/cleaner/messages/message.rb	100664	1.81 KB	d46ad685366332da3fcadc8dbf09d2bb6a80b5fb5d777d3117afcc013fe79ead
lib/karafka/pro/cleaner/messages/messages.rb	100664	1.15 KB	0e8ff40925944d317f113775c7ade0e4a349da46fcc425fc4e9c8bc12ca976bb
lib/karafka/pro/cleaner/messages/metadata.rb	100664	1.17 KB	8583229116cdc4718d47cef19c574bda2b26483aaac543db686b5df32bff516c
lib/karafka/pro/connection/manager.rb	100664	11.1 KB	211345701e29707a2419247a2ff7ee411dd04d2749675d438ef8ed96ae58aa57
lib/karafka/pro/connection/multiplexing/listener.rb	100664	978 Bytes	772c73fdab90479908fef857b094ba06319b1a2a7d4deab973870fbcb07d45e0
lib/karafka/pro/contracts/base.rb	100664	391 Bytes	11c2eb07d106a3f2ae4d4a83cd0f783bff03dfd750be67d4c44317e64684832e
lib/karafka/pro/contracts/server_cli_options.rb	100664	3.69 KB	9b23f2fa5a023b21e0a49272bf6e34dd25a5d1e7b1c4db8dab6d0f370fb2a5dc
lib/karafka/pro/encryption.rb	100664	1.35 KB	72db05d490ddc16c9945633fdec34da90c1ae1677e73642de62e1f12709a582a
lib/karafka/pro/encryption/cipher.rb	100664	1.57 KB	fa6c01def277d9cf5484e518d5fdf9fe5d7a5430287c851937fa33373b3b6649
lib/karafka/pro/encryption/contracts/config.rb	100664	2.35 KB	c32b71b80128e9147de6875759b8b2da2885b242dfe13340cddc494328f309d9
lib/karafka/pro/encryption/errors.rb	100664	677 Bytes	e32569791b0a1ae253415acfdf6d7befdfeb8d054f54a55874af2292a2c0da0f
lib/karafka/pro/encryption/messages/middleware.rb	100664	1.26 KB	f78b8f7bec048944f8cce80fc694fac5caa56163d87738cfeb8b7c921dc4e63f
lib/karafka/pro/encryption/messages/parser.rb	100664	1.66 KB	d7c76846a2937783d2e1e046c957b1a778f78240c64bc304725ee4180490f392
lib/karafka/pro/encryption/setup/config.rb	100664	1.66 KB	5589de00b18d0ccfcb10d9a32146880d6e48b9f297575e9156995d2d305578fc
lib/karafka/pro/instrumentation/performance_tracker.rb	100664	2.57 KB	eced24d0a26293bb148bb001cd51b3808eaa07ff57fb3c05c64b21739d38112b
lib/karafka/pro/iterator.rb	100664	6.81 KB	d1f85fe1b42fe425d3094513217543d0244c858e085f1c2446e0dc1fbfde423d
lib/karafka/pro/iterator/expander.rb	100664	3.54 KB	9b2ebcb37d2235a8039309af6f697d02afcf6c7658dee6b9b69b8c32c11769e6
lib/karafka/pro/iterator/tpl_builder.rb	100664	7.36 KB	7c09d86f29af2ea093788c7300817ad51d2e64e95784ac55eb5b81c8a6f6d338
lib/karafka/pro/loader.rb	100664	4.29 KB	8731868a792dce7eb218698fc7b5a43d8a6ccbd7217e5431da8a459d014ddb90
lib/karafka/pro/processing/adaptive_iterator/consumer.rb	100664	2.12 KB	2484fd72bce48e52a9939e664caeee302daede7d94cd61c73a5c784f3763b3c6
lib/karafka/pro/processing/adaptive_iterator/tracker.rb	100664	2.43 KB	dec9df17474fe987688fc4a2ed85425325473a606a7ae51205fd92364ee74941
lib/karafka/pro/processing/collapser.rb	100664	2.16 KB	7c2a45bfaa73ea9cde5e80ae8cb82e63c62997328e67eab16b0d2787db995301
lib/karafka/pro/processing/coordinator.rb	100664	6.02 KB	6d51e5f0cbb643e981d095b21eaa0c6808f311229459d87a3e286437b9ee772a
lib/karafka/pro/processing/coordinators/errors_tracker.rb	100664	1.7 KB	11274a73ff92f1bfe5168aff914ad68356f1a8727be59130abf5be5a7e97fd28
lib/karafka/pro/processing/coordinators/filters_applier.rb	100664	4.4 KB	abe754fa209696dffbf2ed413fbcb403790e1e5a07079341d0278f0e11cff10f
lib/karafka/pro/processing/coordinators/virtual_offset_manager.rb	100664	6.7 KB	509ff8baa61ff46ac8c6ce0edb2932c1d5dcc08d1672bffb6a39219fd1ba29ff
lib/karafka/pro/processing/executor.rb	100664	1.04 KB	397d47771b71076973148ce8b213474a4af6a0a3ca1d6eb9c998470d92414f8c
lib/karafka/pro/processing/expansions_selector.rb	100664	1.05 KB	16a88b43730d32a19c7b4862358a7ee643cbd5ffc161c5fea325fd0e788aa179
lib/karafka/pro/processing/filters/base.rb	100664	2.12 KB	59ee233d2a0fb0d770a1289217fb168a0548f7ee3b45e8bb35aab4ffbc0d4413
lib/karafka/pro/processing/filters/delayer.rb	100664	1.61 KB	b3125c7f2f36b9774ba319cfde13f6fd051eeb0d55d11f286ce617a3399ba4e1
lib/karafka/pro/processing/filters/expirer.rb	100664	1.14 KB	c1eb2194a1fe052090a92796abde61a59aa8987deafed04c01a63e3b4981c998
lib/karafka/pro/processing/filters/inline_insights_delayer.rb	100664	2.19 KB	9dc1912b77757127f965604c51c63c04e20505e18cb54365c35f1c69e226462d
lib/karafka/pro/processing/filters/throttler.rb	100664	2.71 KB	2408de6de2075aad048157004a874a3971695d8f971b1d0ca5d0b07eb6de38a3
lib/karafka/pro/processing/filters/virtual_limiter.rb	100664	1.47 KB	31409f29381cbc12cafc26c0c7f5837064cd603f73a4eb94a3c7ec26854cf742
lib/karafka/pro/processing/jobs/consume_non_blocking.rb	100664	1.13 KB	9e3af5e3d09a18faac12eec3e6759f1415ae285ae4d70365b4c35b07c7f17357
lib/karafka/pro/processing/jobs/eofed_non_blocking.rb	100664	852 Bytes	cb532444abac4caece170b29d6bcc931524a1fb31717d17bfa4ef8e8dd4a4b81
lib/karafka/pro/processing/jobs/periodic.rb	100664	947 Bytes	d6cc3d9480c86ca7b4604a0d3a09d9f457fda4fab0a11b197cdf8cccde992fc6
lib/karafka/pro/processing/jobs/periodic_non_blocking.rb	100664	834 Bytes	c6ddc7adbf7e2e6f2aab6b212d27cae4311e6081d05ef69d5c6e622df659c001
lib/karafka/pro/processing/jobs/revoked_non_blocking.rb	100664	1.04 KB	868327d918d0587fc8fbf0f4ba850e6516c9acd50cd2e291c173b20a7179e72e
lib/karafka/pro/processing/jobs_builder.rb	100664	2.34 KB	6d916361a0c2028c8bd26326b3829dd99f327aea6aa0171fd2b793b285dd0c12
lib/karafka/pro/processing/jobs_queue.rb	100664	7.61 KB	25464a2d990b6590772ce579d0f0a88c940156ff137045ec23825a6f113b0de4
lib/karafka/pro/processing/offset_metadata/consumer.rb	100664	1.59 KB	2588a587e6497b63be02763087344d520de4d5ff5e0392ea723129f81c1f3fe1
lib/karafka/pro/processing/offset_metadata/fetcher.rb	100664	5.31 KB	44ee38728c0ac6af07aba9a0f16f2ae3b1dd17cdc93d7709588ef95c068071fd
lib/karafka/pro/processing/offset_metadata/listener.rb	100664	1.49 KB	573ab8a615c7353fd336e69583d385c7c154dc77a116c6b2f77c547888694043
lib/karafka/pro/processing/partitioner.rb	100664	3.66 KB	b5436db895e627c879e1667e620e0c38750efbb92c9456d2bdd960c2b57a36e6
lib/karafka/pro/processing/periodic_job/consumer.rb	100664	2.12 KB	8b91cb75941bd0890070c5cd54e577994aa4564df59ded1b594824e461f9ea23
lib/karafka/pro/processing/piping/consumer.rb	100664	4.8 KB	34e04d27dd2bdf1b83f6c603fcd9b4fc9443f8205004908535344724dc646522
lib/karafka/pro/processing/schedulers/base.rb	100664	4.53 KB	4c6b86841248daf294a55614e263c5f5c82271a9b0bced762bcc45c76eb4a21d
lib/karafka/pro/processing/schedulers/default.rb	100664	3.53 KB	5302f6d7c9a800d6cd330badf791ffeda6403ec625454f34c519222ce05aaa51
lib/karafka/pro/processing/strategies.rb	100664	289 Bytes	90a6aee4f3eac1e7d0d658bee2a9b1da39d86a22d9640a88a23f1969b4f448e3
lib/karafka/pro/processing/strategies/aj/dlq_ftr_lrj_mom.rb	100664	1.81 KB	8ad37eeeac5d65c003f2d7330056bf1b09c67ee84dbc9badd3eddce8edf7bb1f
lib/karafka/pro/processing/strategies/aj/dlq_ftr_lrj_mom_vp.rb	100664	2.16 KB	65a7d8215b0992bbc61b64ce9bc7712d55e215bec36d27c3819975d9350cf9a0
lib/karafka/pro/processing/strategies/aj/dlq_ftr_mom.rb	100664	2.18 KB	d755b6af3b24b4d211d1e8d142595697c7e73eba4946f89f23dbebe5e1c217d4
lib/karafka/pro/processing/strategies/aj/dlq_ftr_mom_vp.rb	100664	1.78 KB	8fd73d3594a2ab937c32c2bffb641c31e0d6e2a2ab8729f00adb913cce04ee75
lib/karafka/pro/processing/strategies/aj/dlq_lrj_mom.rb	100664	1.73 KB	41b952811d178ec0d0d04a9bbdc2332fdde83c3a8b517cc971e99bded8153ece
lib/karafka/pro/processing/strategies/aj/dlq_lrj_mom_vp.rb	100664	2.02 KB	dfb794b2478c0dd958c4063b7b0bb8c6e912286c152e4e0ef6dbfa19640b3b9d
lib/karafka/pro/processing/strategies/aj/dlq_mom.rb	100664	1.91 KB	0b3e577465bae3de7ce66120861e67adadce4aecad6087b49f63a7ce36711530
lib/karafka/pro/processing/strategies/aj/dlq_mom_vp.rb	100664	2.1 KB	7fba9735b5694b3b98b799adb9b095e5f6c18bca2e7cdbe3f8359226e3213962
lib/karafka/pro/processing/strategies/aj/ftr_lrj_mom.rb	100664	711 Bytes	50a18beb0f45a675526f0fc2b74373251f74360c89102102f42fea2a7b6539fc
lib/karafka/pro/processing/strategies/aj/ftr_lrj_mom_vp.rb	100664	1.7 KB	b311830000221440b2b447140e9a845413e781838836947dd97aae627e59165d
lib/karafka/pro/processing/strategies/aj/ftr_mom.rb	100664	730 Bytes	14673bdac7e6e35477a36e1c8399c2d80d75cb9b5abfab524b687ff8feb67a52
lib/karafka/pro/processing/strategies/aj/ftr_mom_vp.rb	100664	1.34 KB	f2041de023871fc044764c4a51ba3b5c2a7e3ee60b53bb8e2210a59306859c72
lib/karafka/pro/processing/strategies/aj/lrj_mom.rb	100664	692 Bytes	5c0b9a6c133acfca8a8689c84c049754179f38da19476b25648f866e18cbd201
lib/karafka/pro/processing/strategies/aj/lrj_mom_vp.rb	100664	2.34 KB	884327f772693540c64ba20503d57fe0ce05798f61d9f51fd1f697e8939338c4
lib/karafka/pro/processing/strategies/aj/mom.rb	100664	710 Bytes	c9352d60f8da6969c247fe8ffe34903b9c498c215959a44ccf16820d5cb4e426
lib/karafka/pro/processing/strategies/aj/mom_vp.rb	100664	1.11 KB	2d4f2a9324a55089e12847c51ef51ba81a7f3b0d2ced1c4229f1e185f605a7a1
lib/karafka/pro/processing/strategies/base.rb	100664	411 Bytes	e1c4d32236af0b3450786c69cddf4cf4e05f2ad58aa43f03d3870e45f52bc932
lib/karafka/pro/processing/strategies/default.rb	100664	15.7 KB	2ffa595fe9446711fb7a5daa8f75de5eeef95f519571029f86ec82dcbe559104
lib/karafka/pro/processing/strategies/dlq/default.rb	100664	9.97 KB	d91cb5a967ffaac4fa44c5df6eb0861c3bcfd076421d1276c27083d6a9149144
lib/karafka/pro/processing/strategies/dlq/ftr.rb	100664	1.27 KB	795858a027aafea4cb72fe5c05060bf1e1bd5acfa898564aa741d1f6abcc8eb5
lib/karafka/pro/processing/strategies/dlq/ftr_lrj.rb	100664	1.98 KB	32a345aefd14d2cea039e0e3551280dab00305f4f869fc00de0341870e10b6ff
lib/karafka/pro/processing/strategies/dlq/ftr_lrj_mom.rb	100664	1.85 KB	f235164c65568864c4534857dfd2252b82437f8bd9f92298907e0ed95de7bdc7
lib/karafka/pro/processing/strategies/dlq/ftr_lrj_mom_vp.rb	100664	894 Bytes	8fc14972b126a68ff14365e29f82bf4ad51b8d7fe8e1c7aec491b39c021c62f3
lib/karafka/pro/processing/strategies/dlq/ftr_lrj_vp.rb	100664	866 Bytes	4f904e61a8c470768bac9bf912a80670e6e38cd14007dc67597c1dceff6e1611
lib/karafka/pro/processing/strategies/dlq/ftr_mom.rb	100664	2.1 KB	13a70e3c3c6d6dd5353055b40e5681801230651e996d78e0f0cbec5c5096dae6
lib/karafka/pro/processing/strategies/dlq/ftr_mom_vp.rb	100664	811 Bytes	7c30e0de7486c4a877e0927d07d6001ee1d961a143b56c87307d1400151915e6
lib/karafka/pro/processing/strategies/dlq/ftr_vp.rb	100664	742 Bytes	1ee994c1e52a2de78efb7c3471969c959306a25052cf3d05add08f666dce449b
lib/karafka/pro/processing/strategies/dlq/lrj.rb	100664	1.46 KB	dc17eef618ebfda5340f8f1249a43c03436dedde6e3c9e98caad8629af1fc71a
lib/karafka/pro/processing/strategies/dlq/lrj_mom.rb	100664	2.36 KB	ea79511947889871063ed59c9a3fd7160db298366f30fd3d6c478f3e133ee3a8
lib/karafka/pro/processing/strategies/dlq/lrj_mom_vp.rb	100664	697 Bytes	c64fc293fe44bf38e4315275f9ac03258db97e742ba5a49edbe76c54fb60b2b8
lib/karafka/pro/processing/strategies/dlq/lrj_vp.rb	100664	831 Bytes	ead2f9959ad0ecb2668fe423e0bbbfffce2d18cff12bad1c613777da4011a223
lib/karafka/pro/processing/strategies/dlq/mom.rb	100664	2.51 KB	2c9e525ae68bea7a65382e639f4764cd8ab4520c1b910ff05b5c26ef12890bad
lib/karafka/pro/processing/strategies/dlq/mom_vp.rb	100664	689 Bytes	ed595ca23b0d7afcef9be30380eb47007b555acc8f1eae57a4e696f841bdbe2f
lib/karafka/pro/processing/strategies/dlq/vp.rb	100664	1004 Bytes	f434b435285ad20e21b4c087064c260a53865a802e8868357f645f261af1246e
lib/karafka/pro/processing/strategies/ftr/default.rb	100664	4.19 KB	5f8da6583519db5377ab67c71b6bc7e06f4d8ffbdbe9a128e6103ced137e3c6a
lib/karafka/pro/processing/strategies/ftr/vp.rb	100664	871 Bytes	5927f6f00fff7dd9c39b2c7917efcc254c5ce0f0f6aeb02619e3f8ac2541e2fc
lib/karafka/pro/processing/strategies/lrj/default.rb	100664	3.17 KB	5099d48957c02c14a5e013320732005fe16cbed96e25733660f0758a8659e229
lib/karafka/pro/processing/strategies/lrj/ftr.rb	100664	2.09 KB	09884eb478f432128011574f3c9ebfd10500a207b7a901a0beb02ed278382d42
lib/karafka/pro/processing/strategies/lrj/ftr_mom.rb	100664	1.99 KB	2252f00ae0fbe62b0166b7ea3b2577ad0893c86a99d4adfe5d35ebc44a15e368
lib/karafka/pro/processing/strategies/lrj/ftr_mom_vp.rb	100664	767 Bytes	e0c0961a4e50ecd105dc16491eb78c363a7f3533b05c5835b560b45218a05eaf
lib/karafka/pro/processing/strategies/lrj/ftr_vp.rb	100664	780 Bytes	f06475aa80c9f8c1dfbf923502d95a6991daba9434ab0cc073601f5ced0f12dc
lib/karafka/pro/processing/strategies/lrj/mom.rb	100664	2.09 KB	e627843e8a42319a4d65fd26be370f013ec73d16b03f15af92aa9c631f89c069
lib/karafka/pro/processing/strategies/lrj/mom_vp.rb	100664	764 Bytes	352a5367c667e826e21ec37487cd2ac9b5816815ac96344610e200b55c06488e
lib/karafka/pro/processing/strategies/lrj/vp.rb	100664	673 Bytes	d7a1793c192158e2a6c9a63cd902181625ff3d4ba132c96f8a35d86e947fd175
lib/karafka/pro/processing/strategies/mom/default.rb	100664	981 Bytes	dd11e76a0711fb60b0d81c09b07ec922a1aa16c1f23176a2297c4140790f7ab6
lib/karafka/pro/processing/strategies/mom/ftr.rb	100664	1.16 KB	5df3ba7ba2c46fd7264a8235f040ea14be2e76d75a74702d8f5c15fd38329062
lib/karafka/pro/processing/strategies/mom/ftr_vp.rb	100664	656 Bytes	1a9126fdef4a051e1caaa30fe9b9d3ef7a0efdf85af0c5fb4172f21be741ff69
lib/karafka/pro/processing/strategies/mom/vp.rb	100664	611 Bytes	5a208005a7ca4d87be51d755ac403a509c8e3c608efce753c3b6b8ad1482339a
lib/karafka/pro/processing/strategies/vp/default.rb	100664	7.88 KB	d3adec7905976e7aa3c84e28b33b8fdb4b279f65d62cb1562e8ef718e3a38d41
lib/karafka/pro/processing/strategy_selector.rb	100664	2.18 KB	033968b6adaccff45e3ca86fd9b3f18a1323d55b12b77b18babed6c220c6c9ca
lib/karafka/pro/processing/subscription_groups_coordinator.rb	100664	1.54 KB	52a9d990be163eecf265d38a5fc54597613370272c36d9de4b7dac0f763ac314
lib/karafka/pro/recurring_tasks.rb	100664	2.59 KB	fe3bf0e7a5accc7bffc7ce5a9ecac74b911fd220b9f7135af86cad9fa5300aeb
lib/karafka/pro/recurring_tasks/consumer.rb	100664	3.69 KB	7babce6c7274a28bd95df1ce052673e2011b7ef892a75dfc1b6aad78deb8e49e
lib/karafka/pro/recurring_tasks/contracts/config.rb	100664	1.54 KB	fdbb5b6f4a6d1d147416df6ca55b7488b3af00d164bf8cc39abb20df35d4cdac
lib/karafka/pro/recurring_tasks/contracts/task.rb	100664	1.14 KB	fff449a296301c4a5f0d7089417cf3142f6a7e2c5111fc7c22bddff7c12a16f8
lib/karafka/pro/recurring_tasks/deserializer.rb	100664	963 Bytes	801e41b669131aa8d5ec4f95353970d5f448cdad44fb2c91979e41fc6c2a8bf7
lib/karafka/pro/recurring_tasks/dispatcher.rb	100664	2.3 KB	7b7a69183fe1951c5174eab9e8a7302197d2c5717d3b527fd81bc4091a4ba7b3
lib/karafka/pro/recurring_tasks/errors.rb	100664	976 Bytes	32eaaa9eacf4e63e882526d2e3c7afe5b518d5ad1f439929733927e2ef459bcb
lib/karafka/pro/recurring_tasks/executor.rb	100664	4.34 KB	9f8c69deb61d98e1c552a7d9f228f2535228be2befd7a4e45c1d2785efd7032a
lib/karafka/pro/recurring_tasks/listener.rb	100664	1.15 KB	224134309bda879ed78ad849fc33cf3be25e237f1a18694e8ee22de20b82a57c
lib/karafka/pro/recurring_tasks/matcher.rb	100664	1.08 KB	ab703175f96042b04cd49087251f6b399f01e49916f088535dbcd5dc0bb84faf
lib/karafka/pro/recurring_tasks/schedule.rb	100664	1.87 KB	90171e29c51c5db0aebe3235ae80c38afc573e37aae40dc422aa6bbc3d2b7eb6
lib/karafka/pro/recurring_tasks/serializer.rb	100664	2.95 KB	299971e02e4768555bf46d7dffcaaba72e6a793a47d061fec36e016ab93d4c14
lib/karafka/pro/recurring_tasks/setup/config.rb	100664	1.53 KB	6ac72a8131c7ff40d09a140e3f57179079ce83bbde0fb12699a684c7b5df3047
lib/karafka/pro/recurring_tasks/task.rb	100664	4.23 KB	946dd6615ae9ff2097074a326bac91bc46309a90f4538684789877883ec5d5e6
lib/karafka/pro/routing/features/active_job.rb	100664	510 Bytes	9cc1a43ca0448649903128daeab9e2394d43c247ad9ed58c1c3c32ed84148e90
lib/karafka/pro/routing/features/active_job/builder.rb	100664	1.25 KB	5e6d6c503086549c58be6c79789ef8d582702ab07215dec4d556ea3baf6deade
lib/karafka/pro/routing/features/adaptive_iterator.rb	100664	868 Bytes	029bb37f3158c45c1018f79de1e2fdf2b435ef4bc63cde218efc3529dfe846fd
lib/karafka/pro/routing/features/adaptive_iterator/config.rb	100664	652 Bytes	6826ba8a7091d5a49600889012fcc99a9fca0931001d4e489de53a0af8e72ca8
lib/karafka/pro/routing/features/adaptive_iterator/contracts/topic.rb	100664	2.37 KB	b5f15199771d25f9d28c37569bf4b55c1c7a848a564bdaa9708adfe19db1b755
lib/karafka/pro/routing/features/adaptive_iterator/topic.rb	100664	2 KB	fb7a120eadaa83c34c8ceec11979e8056b2e816dcdb8f64e7c39ac38ed959bfe
lib/karafka/pro/routing/features/base.rb	100664	352 Bytes	ed0e9ab749f9ab9046eeae455ec891ac5763bae6d06c317e08fab95497002e5d
lib/karafka/pro/routing/features/dead_letter_queue.rb	100664	471 Bytes	9043605c4bf3b1d2fc79aa16441be1b4a27cdb6118ca2173075f6bbad4ad4b72
lib/karafka/pro/routing/features/dead_letter_queue/contracts/topic.rb	100664	1.87 KB	d62fe45efbe13891821190d154261063316bc589da7cfa4f06f7da3bfead7dca
lib/karafka/pro/routing/features/dead_letter_queue/topic.rb	100664	1 KB	92a5667165ca23c242179d00d7db32175ecfbc33b0faa5fa5045d09dae6040cf
lib/karafka/pro/routing/features/delaying.rb	100664	687 Bytes	f88895fbb26e521b0c05d8695693fe3ec94dba7521b18223577ab99b21a4782e
lib/karafka/pro/routing/features/delaying/config.rb	100664	452 Bytes	17a20da53726350fc1c518974a4888f0388e27ca6a95e9711a0ab39c3b870b43
lib/karafka/pro/routing/features/delaying/contracts/topic.rb	100664	1.02 KB	ae1c5298efef5370222de9556616bf3b8717b15bb65a245014a2e45be791bd63
lib/karafka/pro/routing/features/delaying/topic.rb	100664	1.39 KB	cffe092b361d2fce6ea9c8ced48050529200d436fdf41bd09a0671e5bf2cdc76
lib/karafka/pro/routing/features/direct_assignments.rb	100664	475 Bytes	d089f6ef3c6bc18744e67a4b17567b1f6ec99c9d84aded7903a6b6db09b39eeb
lib/karafka/pro/routing/features/direct_assignments/config.rb	100664	476 Bytes	9c485870904b5eacbad72984b3c0c10911e318298b89af8753e9d788c54e00d8
lib/karafka/pro/routing/features/direct_assignments/contracts/consumer_group.rb	100664	1.38 KB	7a9f3a97b605439d3186120cc16134ddeef81b8fa1f829b34b7b5439491b6a43
lib/karafka/pro/routing/features/direct_assignments/contracts/topic.rb	100664	3.65 KB	ba47ef75d4c33336284c3ada1c02f90e42f76f7e98ea755e8361d7bfc0fff881
lib/karafka/pro/routing/features/direct_assignments/subscription_group.rb	100664	2.68 KB	42e332e98fbc24801af10d92851d916a25e8ac296bd21cbee8bb1db6892bbc21
lib/karafka/pro/routing/features/direct_assignments/topic.rb	100664	2.09 KB	e27f7eeb5e25ebcf6eb3501659590d3251a3ca7c12e3154a52c39ec75ecdb0de
lib/karafka/pro/routing/features/expiring.rb	100664	612 Bytes	a0524e6d5b051e4dff7a08e7c4b4b144c73e8453b7e1cd41e1574e680fb4f275
lib/karafka/pro/routing/features/expiring/config.rb	100664	450 Bytes	64bcb8ca6451be817535c2a58522c4f4392c1e292fc2a9e45631deaa95985cba
lib/karafka/pro/routing/features/expiring/contracts/topic.rb	100664	1.02 KB	f031c7922fb9f8f99e717f6ec86c348b1c39ba7a10a26dda0cb0569dcdccc4d1
lib/karafka/pro/routing/features/expiring/topic.rb	100664	1.38 KB	f191130586a9c39ccc08b0d08d95210a61b3cb07abef3281928527469e3a6dc6
lib/karafka/pro/routing/features/filtering.rb	100664	518 Bytes	019a5e6c85a35a4e6941f9b4896c27f9f394bf6644e3108c5fd3ed13158223e1
lib/karafka/pro/routing/features/filtering/config.rb	100664	849 Bytes	f72f0a120f22370c396c384d157ae31f2468d92cab1dda65d281632cefefa796
lib/karafka/pro/routing/features/filtering/contracts/topic.rb	100664	1.09 KB	6cb035c8b67805ab9bd9b02a9e9250141fbda91130733c4d576f1e8f59bbd581
lib/karafka/pro/routing/features/filtering/topic.rb	100664	1.29 KB	da5a3c45606a26c674702f150ce6ddf6df8d5978911fbb9c9a3bda6a6dce19c9
lib/karafka/pro/routing/features/inline_insights.rb	100664	460 Bytes	1b9a9d45b64fdb464beb57883196017af5b10c8a5897cb66744346dff9e08a0e
lib/karafka/pro/routing/features/inline_insights/config.rb	100664	548 Bytes	73a106288900f8c2ac3b10cf002b78838694f95a78f1b36a1368bf60c558cc0e
lib/karafka/pro/routing/features/inline_insights/contracts/topic.rb	100664	1 KB	2d78ae19ce3a04b99475e22c778af4ccdaddf5aa46db3d0328746c1d9bbd02cc
lib/karafka/pro/routing/features/inline_insights/topic.rb	100664	1.44 KB	c24f0a2af70e6f59b46b9aabef241065781496771fa88b56d6ebffd212383ddd
lib/karafka/pro/routing/features/long_running_job.rb	100664	539 Bytes	ea6917d43ccd6b14a59957cf03db091a2025c4c975a6e300dc15f72e7d1e9b62
lib/karafka/pro/routing/features/long_running_job/config.rb	100664	462 Bytes	73f56c8a1123f1a5a9494cfa212abc25d58e7705f1de7808031e13de60b2402d
lib/karafka/pro/routing/features/long_running_job/contracts/topic.rb	100664	935 Bytes	74e6752a8460b8de68d2f026210384a8dc562bce6d291493ba0ce081003ae802
lib/karafka/pro/routing/features/long_running_job/topic.rb	100664	1.02 KB	e01d9b0d1bd20e9a9bf8381ed645cb21da71aab1f1e68ca92f2e390a9b0fbbc6
lib/karafka/pro/routing/features/multiplexing.rb	100664	2.02 KB	9e87933d0ce8bc32880411803b7026364bfa5854fa909ff9760686b9738a7f3e
lib/karafka/pro/routing/features/multiplexing/config.rb	100664	681 Bytes	29d8a09b01073c6533f7e95aa2743f59c90963aa2641cff45d36b345d2dc26ff
lib/karafka/pro/routing/features/multiplexing/contracts/topic.rb	100664	3.69 KB	c4179057f357208f0a94d40704f0290315bec9894be83824d7c47b75685c5404
lib/karafka/pro/routing/features/multiplexing/patches/contracts/consumer_group.rb	100664	967 Bytes	18cf8a6cd890020f243a32c28173a1ca7e7a3d16eb5ea9f7e7ce71fafb2b875c
lib/karafka/pro/routing/features/multiplexing/proxy.rb	100664	1.08 KB	7d754e3915b2c6d35a3838143ad8c0e5a416ba8613b3a88666ad43e06f04f97c
lib/karafka/pro/routing/features/multiplexing/subscription_group.rb	100664	981 Bytes	413c14345cb5c36f622e1ec52074db386d6e6b9fada971a389e1c5abab82748d
lib/karafka/pro/routing/features/multiplexing/subscription_groups_builder.rb	100664	1.04 KB	4836e1f8bd3615186cfb5a50fd5adc2ddc720008173e94576fc8cea628ae3042
lib/karafka/pro/routing/features/non_blocking_job.rb	100664	1.03 KB	289cadef7ec6be11fb892c36f0961eb54e2e6c53a5f0910c6c444cda18c39532
lib/karafka/pro/routing/features/non_blocking_job/topic.rb	100664	602 Bytes	598873329570b69bb18d4e9ad33851bc25260300b8041ef7951c7dbad068f2ac
lib/karafka/pro/routing/features/offset_metadata.rb	100664	1.02 KB	e6b6983df4c1d4ef534f17f9b64a486c381eb84723cd7630aac5d40c39206b8e
lib/karafka/pro/routing/features/offset_metadata/config.rb	100664	578 Bytes	08cf2ac8a9324a29004c9ce2d5c463ea86977b723ce48b8e107f9d0bcd8621ee
lib/karafka/pro/routing/features/offset_metadata/contracts/topic.rb	100664	1.08 KB	50d0b0fba1deff86926d0e9a232f739b62f61c517bb166dbfd0ce13e5bb6ecae
lib/karafka/pro/routing/features/offset_metadata/topic.rb	100664	2.05 KB	684934b9dfecf775d7882d3f4e28d141c4d324f49e2230c51d60f5f11d6896e9
lib/karafka/pro/routing/features/patterns.rb	100664	846 Bytes	e7b35d958da35b6716ad78d03e5db3402469fa8e6fbe584581505114ee771748
lib/karafka/pro/routing/features/patterns/builder.rb	100664	982 Bytes	281ab6637785c4ac373118e0e85507aeed8005ebe3bfd2fca24fab1facf6f42c
lib/karafka/pro/routing/features/patterns/config.rb	100664	1.34 KB	7d633eaa6eab38d70389f254defe85f7dc8073f0e76fcae4cfd5f8cb94b828ed
lib/karafka/pro/routing/features/patterns/consumer_group.rb	100664	2.52 KB	45586136c1783dd4677e63d62dfb5282d3eceb61a448fc1bc8eb2123aba32115
lib/karafka/pro/routing/features/patterns/contracts/consumer_group.rb	100664	1.97 KB	a6eb0d44fe4ed119f8290b38eb418ee0b8a0108c1e27973be41daab6508129f2
lib/karafka/pro/routing/features/patterns/contracts/pattern.rb	100664	1.14 KB	c5272bf94feff5ede5b565f9abf904a35cb7006b6efe93ec8c27c06ef15fd9a7
lib/karafka/pro/routing/features/patterns/contracts/topic.rb	100664	1.02 KB	8b52b810b62f3621334b066ef10a0c57a9fdecb305734995d176463d8772252b
lib/karafka/pro/routing/features/patterns/detector.rb	100664	2.82 KB	28cf767450b72502ab0c3fb1bce09c0de3dfc7907522d27a3868167aa71fb707
lib/karafka/pro/routing/features/patterns/pattern.rb	100664	3.64 KB	913adfd974230a1b4f26ab8a5f8b9e11814238e80eb82356e6d2a29ec9a38278
lib/karafka/pro/routing/features/patterns/patterns.rb	100664	919 Bytes	9e4b03b68eabba8033d50eaa4d4b6cf9958c948d262212c8e7b94fd8f95ffb57
lib/karafka/pro/routing/features/patterns/topic.rb	100664	1.38 KB	8e348bc1e5d6c130b5f691a182afc7fb71da30e5f61eb0227fdffac7c6c519b3
lib/karafka/pro/routing/features/patterns/topics.rb	100664	1.88 KB	91b546ea588031e1ad2bd0b3342a1dcef551767f6305ca099e93d5ffc4244e90
lib/karafka/pro/routing/features/pausing.rb	100664	452 Bytes	32b49d1c27f0f005bfbc7459603ce0a0793196c762d69fa15178333f55094e9e
lib/karafka/pro/routing/features/pausing/contracts/topic.rb	100664	1.46 KB	0dd52740cdadfbb09f0ce031dab0e7b39cb4d850f24df77b2a0e9b21dcc4b12c
lib/karafka/pro/routing/features/pausing/topic.rb	100664	1.36 KB	47f0149b12b478aecd241ce9b5a019179d71630608b9601810bf499f9a0b2b97
lib/karafka/pro/routing/features/periodic_job.rb	100664	584 Bytes	413936c37a8587824be25e1f121605aaa251779317b837a65b56467878d4ccc4
lib/karafka/pro/routing/features/periodic_job/config.rb	100664	757 Bytes	e68c42db623d09b2bfa9029bed0558264e55ec770dcf1901802f4b79d3cbacdb
lib/karafka/pro/routing/features/periodic_job/contracts/topic.rb	100664	1.25 KB	df1486eec8c944de45d6f2a1937cbae92038fcd663a7ba282e681600685e1bec
lib/karafka/pro/routing/features/periodic_job/topic.rb	100664	3.56 KB	e23ec03591f5a05d1471328f45e12183bbae4ec12541602c6a875bc6a00f3170
lib/karafka/pro/routing/features/recurring_tasks.rb	100664	467 Bytes	a6fd27711fe4f94eaae188b9e5761a84bedc7b1d6ef08c6c194cab9314632596
lib/karafka/pro/routing/features/recurring_tasks/builder.rb	100664	5.22 KB	3fbd887f34461bba53629e50481123b9e961b80adfc3b093f294666e1337be03
lib/karafka/pro/routing/features/recurring_tasks/config.rb	100664	460 Bytes	4277126e7986cf889516413e173dbd32b82f996c2b105694dfa5f92f8a8b56d1
lib/karafka/pro/routing/features/recurring_tasks/contracts/topic.rb	100664	945 Bytes	7ce1544f125abfa8d7560e4a6c82866fb0ab6d50d5c44825ec4ec294c2bfaf16
lib/karafka/pro/routing/features/recurring_tasks/proxy.rb	100664	410 Bytes	7db45d4dc0a9703ba1bb66d57db30408c9997d3a7a7ce5ff937149617dd6a2d9
lib/karafka/pro/routing/features/recurring_tasks/topic.rb	100664	1.12 KB	61d55305af617f8fbe078f6793c451b654d6908449228130a39e0831bc009cce
lib/karafka/pro/routing/features/scheduled_messages.rb	100664	352 Bytes	c1b927157fe1248cb027f68bb4e69f06af49096a1c3fb7cebe989865c114c87a
lib/karafka/pro/routing/features/scheduled_messages/builder.rb	100664	5.4 KB	cefb8f372f2687c8bb96664c540f56ebb73e085f2103e1e6bfe711527128fb7d
lib/karafka/pro/routing/features/scheduled_messages/config.rb	100664	466 Bytes	de27bc5d8ead697714de8bed2052e69c0b52dc70767d1214020710f9a34b9279
lib/karafka/pro/routing/features/scheduled_messages/contracts/topic.rb	100664	957 Bytes	2d41f5392a2d1a0d11852649a577bb4c5b2679277d7f259101a63f7befa9d82b
lib/karafka/pro/routing/features/scheduled_messages/proxy.rb	100664	416 Bytes	e234c8bbb2ae1101983c99b63c4756a4fc1c7d482437a8bcce6a6ea9235576d7
lib/karafka/pro/routing/features/scheduled_messages/topic.rb	100664	1.15 KB	8528e4446497d4e005c9ab4b97bd6c175589ed6adb0c7684d1a6190aba7c54fb
lib/karafka/pro/routing/features/swarm.rb	100664	921 Bytes	70f70244a4e97405f36359f0ebeabb0300f89e91c8806ee2013af0732a026976
lib/karafka/pro/routing/features/swarm/config.rb	100664	494 Bytes	3b16c34ed7ff12988992ee7869ea5a5a9bf97b13de27bee0777a673a5e3d3e7b
lib/karafka/pro/routing/features/swarm/contracts/routing.rb	100664	2.3 KB	84e1cfc949cd4e8454695f632143934b2c5068be61b1753e183391e3c205e257
lib/karafka/pro/routing/features/swarm/contracts/topic.rb	100664	2.52 KB	81cf3ad782119d91d31e2ce29c770fc9e7b67224216c0882f86cdd55f2dda1f0
lib/karafka/pro/routing/features/swarm/topic.rb	100664	2.2 KB	4b1477e8167864953272856bedbca099415593472e6e43af3452c242c454ddab
lib/karafka/pro/routing/features/throttling.rb	100664	761 Bytes	6e7f229c57371cb51ba3af19fdb94962c18eae3d292a77b18d38da4c56262388
lib/karafka/pro/routing/features/throttling/config.rb	100664	527 Bytes	0ecf4f9e64438050bc29dc79bf37540cb015198c8bdc7d85b390315065318e46
lib/karafka/pro/routing/features/throttling/contracts/topic.rb	100664	1.13 KB	81ef92d7826534b04be278001b026c1a2caec1fd5d05026250f05bf79eba25ff
lib/karafka/pro/routing/features/throttling/topic.rb	100664	1.81 KB	05cf53b1682455221202fee7758edcd23d02ce883732b01a35d3416c23a72fbd
lib/karafka/pro/routing/features/virtual_partitions.rb	100664	550 Bytes	78a0e0704904d6e3fc2db1facc181832b8a89201af0b87279e033a697e800d7d
lib/karafka/pro/routing/features/virtual_partitions/config.rb	100664	579 Bytes	d4782e2be2db5614817875345b4ee9a35f9fe8260f7f48f41a6081aa5fedac3e
lib/karafka/pro/routing/features/virtual_partitions/contracts/topic.rb	100664	1.72 KB	0f45254e50e8ecc0d609d3fe9d39779a8db93f77f824917f8034ea2bdb57c612
lib/karafka/pro/routing/features/virtual_partitions/topic.rb	100664	2.61 KB	7f8f8181dc95d9f723b9a1d4b30f6e1ecfa8734b0aab08b566160e21f67cd56f
lib/karafka/pro/scheduled_messages.rb	100664	2.24 KB	7e54caf1ca01ffa51b604831fd5f7557b96d20a43f904e015f219a67f27e22f1
lib/karafka/pro/scheduled_messages/consumer.rb	100664	6.32 KB	7b500273e9ec3438102bc5ed053cb2c3c000fce44b229df1b1f81c2d0d2bcf61
lib/karafka/pro/scheduled_messages/contracts/config.rb	100664	1.54 KB	17312e4a635efbd1b2e245dd3e6a0e9a41ec733bf5685572e929ae5fc211a0f4
lib/karafka/pro/scheduled_messages/contracts/message.rb	100664	3.17 KB	ba3150b31515f778282a4bb9019fc923b8384b8bffade2138c88a7a6360aee0d
lib/karafka/pro/scheduled_messages/daily_buffer.rb	100664	2.39 KB	48d9914b40f36293105b5294a612d5795666ae9a008358a3a09792e9beb64cd4
lib/karafka/pro/scheduled_messages/day.rb	100664	1.19 KB	40b07c6c42665207144ca36b21152c5950182e52a4f99cb7d5aca016449e36f5
lib/karafka/pro/scheduled_messages/deserializers/headers.rb	100664	1.24 KB	def6bc14f276360787eaa8aafd6a0b4d8854fab054a3f42612fa2082e7db42dc
lib/karafka/pro/scheduled_messages/deserializers/payload.rb	100664	876 Bytes	5f41a0ee47fa016b41d87c026d405a6d9ae7f783df61585c4268d04d662f3654
lib/karafka/pro/scheduled_messages/dispatcher.rb	100664	4.36 KB	8f7358caa3245cd700953194ac9f795dcd5570f7766e9fa073e07c1e083ad314
lib/karafka/pro/scheduled_messages/errors.rb	100664	630 Bytes	eaad3b492b414be1534bb7249eed734f0680d45941e96fe6c158456675f29ae0
lib/karafka/pro/scheduled_messages/max_epoch.rb	100664	904 Bytes	43cff2782b8d0d480f28455fcba4293a2f58f47859238c1e8a01d034c58525dd
lib/karafka/pro/scheduled_messages/proxy.rb	100664	8.15 KB	ac0ccdb51dde891162d6f29aa4c2eae423f9e050dadafc165b27f60c883c0306
lib/karafka/pro/scheduled_messages/schema_validator.rb	100664	1021 Bytes	7cdf440e7c9a24ec8480f8cb6ba0f5f19a03faedd9942404da6ebeac67a275e5
lib/karafka/pro/scheduled_messages/serializer.rb	100664	1.27 KB	5ed74eeb389d203bd7d058a784028c3b64f00b87415366c616feca22045765fc
lib/karafka/pro/scheduled_messages/setup/config.rb	100664	1.82 KB	86c2cb0c4cf787850673e0fdd984725c766e3959787a095bcbf9db08469fc545
lib/karafka/pro/scheduled_messages/state.rb	100664	1.64 KB	fb36c2187309cf048859d096a54668a473ccb14bcacac2961034b4960fe4fb14
lib/karafka/pro/scheduled_messages/tracker.rb	100664	1.69 KB	856f943a5b769ded1989e1d215128337cd724c39b9e1e68c524a1ba349439387
lib/karafka/pro/swarm/liveness_listener.rb	100664	6.07 KB	c2bdc29005ba6e3f5b9749ae0ef598cf0d9659fb9926452665e228f931211d3c
lib/karafka/process.rb	100664	3.25 KB	5232f16c57a3dc7ed72ae1a0001824b8446ceaed21689710f889c2e127d684b9
lib/karafka/processing/coordinator.rb	100664	7.99 KB	866e8518afd77eb98fefabdaaad461234d3332d9504aec39fa8ae3ce2a9bcd60
lib/karafka/processing/coordinators_buffer.rb	100664	2.23 KB	221969afd3e7fb45632e0096b9bf359dbff6bb63ca04f7ae609432944e9fa31b
lib/karafka/processing/executor.rb	100664	8.69 KB	ae018b71ebe9e13d16831549669d6a1c520e66a81346b88fb1c02b5d203504ba
lib/karafka/processing/executors_buffer.rb	100664	3.22 KB	1e32cde5e794fcd27f7f79edf7b70cd82076d0686add76d9cbe5cc4b02def1e7
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	3.02 KB	6d3da0404be56a5146c2a927a7521ea087baf0eae861997950b2415aadb81d6a
lib/karafka/processing/jobs/consume.rb	100664	1.34 KB	b0bdc323deabfc9ea9b452539414ae44b32febab100d37c742835dccf9fa8abf
lib/karafka/processing/jobs/eofed.rb	100664	711 Bytes	e3d4486441c3a88fd287aa963b98d207b0414e4a47573253b77ba2b7bf4ce3b4
lib/karafka/processing/jobs/idle.rb	100664	816 Bytes	08dd99467aa08ad723c1cf3836a41fbff0f7fdc044b30ed921dadbec25467fa7
lib/karafka/processing/jobs/revoked.rb	100664	734 Bytes	0f4bb2bdbd16e6fd5ea35daf11004220ae547396b631a647429110624bc05b2a
lib/karafka/processing/jobs/shutdown.rb	100664	772 Bytes	02fbf5bcfb6f548d9a7e2e61a9925531ec5f477d50a87410784b5071a5ba9e6e
lib/karafka/processing/jobs_builder.rb	100664	1.11 KB	58816b6ca29a3ace9142092a63ff1ba0f7f256d77b8b8eca6823fc8a34d8f93e
lib/karafka/processing/jobs_queue.rb	100664	7.46 KB	e53e94ed9c92669b9a9e2896818f795b9cc9ea62b17d43e55206896755dbc31e
lib/karafka/processing/partitioner.rb	100664	824 Bytes	a14757c248a5c733fcd7bfd1ff31e848f16f90ed66f83676853da4ed7b08a87d
lib/karafka/processing/result.rb	100664	1020 Bytes	65f48cf2a034d16c4338fca3557d87e899956a037ccb0b3feb1548be97735a86
lib/karafka/processing/schedulers/default.rb	100664	1.33 KB	62f99abc97bf3a9daaec5a9cf642a99c7355cb19f268652c076253da6c124660
lib/karafka/processing/strategies/aj_dlq_mom.rb	100664	1.52 KB	3c529054d1379bfd7a4a94507548578e519bc8790d9074e0b75a146a55959578
lib/karafka/processing/strategies/aj_mom.rb	100664	461 Bytes	5ee3917968cab8cde257fd8d9be9bc0cab310e992c8ae660f0b263c921e53f48
lib/karafka/processing/strategies/base.rb	100664	1.96 KB	7962e0178c4e56c71d021522ac9a9067e685c4c4c1d94b562177933af2af9457
lib/karafka/processing/strategies/default.rb	100664	7.69 KB	cc76d6dd184b580e282e36165c2f1d5390125017057c58543a34aa82d1cf1f77
lib/karafka/processing/strategies/dlq.rb	100664	6.03 KB	fdf13596613fc5777d7dcec03093ce4ccbe91b4bf87b19c7a53b14780dcf12e8
lib/karafka/processing/strategies/dlq_mom.rb	100664	2.57 KB	dcb4af0a555aa8a5cff7b415a83654a692d93e975f00110b3b3488e3771d1172
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.6 KB	3078a4707bbd44c7e727a5957ff011d4f9e2fadc830b6d5aa2f75106598a24dd
lib/karafka/processing/workers_batch.rb	100664	735 Bytes	1c2d88a4b8eacf1425d38419aec1ffb261d85276e0631a5aaa8a1da6a40c528c
lib/karafka/railtie.rb	100664	4.03 KB	5f37324d876d2d9685a9c526308411016e400a3611b9a70fd80c35b49cc57f00
lib/karafka/routing/activity_manager.rb	100664	2.36 KB	8ed8dd07b21698fe6bfef31732bc970448bfe62a5ff24c8a9a8cf114496f5dbf
lib/karafka/routing/builder.rb	100664	5.28 KB	0f11f1e2c3b830189fad0a7843489b59763a0f51910e07b0f30774681db9a788
lib/karafka/routing/consumer_group.rb	100664	4.08 KB	bba7327eb9b75466054daa37014c34da2ab0a032f968594668e7bd6a211cae3f
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	3.51 KB	ae1dc417cf9f920402e4d7b1857b4c7041017539fbfc54db24ac53c7319fb141
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	1.32 KB	a039a787cd74768646cb82edc64b0e9efd9670c3dac6d3154e647217b475dca4
lib/karafka/routing/features/dead_letter_queue/contracts/topic.rb	100664	1.94 KB	5304d6ce1ce7c3ffb3565a1cb9621be9a4a3544287cff98c624cec2fd5b955ce
lib/karafka/routing/features/dead_letter_queue/topic.rb	100664	2.58 KB	bbb8a6a377c7df80d592516053d8b066e4f3d787cf9053c0dc406bfd6900b713
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/deserializers.rb	100664	239 Bytes	cc4b2a483bb8d83bcb0210739b53a08991528876515414ccf61eb929ef83c149
lib/karafka/routing/features/deserializers/config.rb	100664	355 Bytes	6fa82aa4be6ad32880414d4b9f31b74d3e83ef25304338e44e53e8ef54839c42
lib/karafka/routing/features/deserializers/contracts/topic.rb	100664	981 Bytes	6b495f35817945afd8eef767c75f9fccabd61eeee0707a054793ad78a700b1ae
lib/karafka/routing/features/deserializers/topic.rb	100664	1.71 KB	d606c9fa4c930739861c67d4e1890dfd384d24b8688db77afab04f87da0b7494
lib/karafka/routing/features/eofed.rb	100664	422 Bytes	21889a12c362169fee4f3daf77cb8fc882454d1491d162f3e6afd621979d9db2
lib/karafka/routing/features/eofed/config.rb	100664	291 Bytes	80e840a44bd4e26f73a1969d2dc35b60eaf724c8209aebf98134eb32733e26fa
lib/karafka/routing/features/eofed/contracts/topic.rb	100664	1011 Bytes	af40cca5ed26419a1752f1776c792eec1bc916061200fa100cb197765a4a88a9
lib/karafka/routing/features/eofed/topic.rb	100664	675 Bytes	8fe70a2c544f8e18f24e191d7bde2f7368bbb764cbf4ec37a10e1a118564614b
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.64 KB	e2abcb3e4a4c62683f8fd93471d8822066d4d8374c4be1605d520812edb954bb
lib/karafka/routing/router.rb	100664	1.98 KB	4f4fb1d64f15b0b01d8ee976770e23615af94d205094eb3c2dee089d3f339d82
lib/karafka/routing/subscription_group.rb	100664	7.16 KB	985bcf2c882ca51a5a4d525c512a3d3e0ac1bd21a40b45e1ad33c33327b4a83c
lib/karafka/routing/subscription_groups_builder.rb	100664	2.62 KB	a159bc6ddb2346211ab5882871240a590c78f5251f044e0affa199e384873048
lib/karafka/routing/topic.rb	100664	5.39 KB	65d3e77dd974159a8b52233a825adf64e323b285e8b807c4cc2062430bb91ad5
lib/karafka/routing/topics.rb	100664	1.26 KB	69fad8453faacaa7e4c34a7125bb617ad9b0dd8735f90339ed961897b03f9a7e
lib/karafka/runner.rb	100664	2.54 KB	cee9148fbaa7130ede5e66c7cda86366c9ace49debccc96f022c6c1cc36f736d
lib/karafka/server.rb	100664	7.13 KB	b4b68f849407a8f3f29c141e97cab523613f26b9cc7f1a83ef6723e344398402
lib/karafka/setup/attributes_map.rb	100664	10.4 KB	7d2775ddad8e6e9b10dd15986e275b9367d1bf126c0ef938f8f398611371ba5a
lib/karafka/setup/config.rb	100664	19.4 KB	a0891da1424f06df866d34ba7a41178ba76bb11f0f060beaa142fbd56bdf6670
lib/karafka/setup/defaults_injector.rb	100664	2.73 KB	c7c4cbcfed7c0e0f62ca63a3141fac605a6f981627996d4e169aa010193635cd
lib/karafka/setup/dsl.rb	100664	555 Bytes	d9a93c794c071cda753465d9145dc657a8a2ab5d226e2fc0724e134c644f09ae
lib/karafka/status.rb	100664	2.47 KB	4b0ecbc85ffba585dbd6eac90d94100829e6c33e739672b985a61d077b2e0d87
lib/karafka/swarm.rb	100664	795 Bytes	de8961f7cf26d555508579d88aecc5deb37acaf5c38ac25dbf348454184d1404
lib/karafka/swarm/liveness_listener.rb	100664	1.61 KB	daf3cf1422bcd0e296bcfaecb63881b3c66e070fb7ae11ee10c9b9598928ac51
lib/karafka/swarm/manager.rb	100664	7.48 KB	cb992beeace4d90c02f5c4dbed023986f2a1b297b5a4519b4a70c792c081adcd
lib/karafka/swarm/node.rb	100664	5.5 KB	ed78d7fbf4e14d92c59986dacf59b609c9d9d53c82f5ce4b70b8615465d2d397
lib/karafka/swarm/pidfd.rb	100664	4.3 KB	d88dcc882017946a860622ba82cf4c47c32d4d5f2308b6df576371c9508de8f7
lib/karafka/swarm/supervisor.rb	100664	7.12 KB	5c1a956d2c4feaccdde411dcaef5d49da04ee052b3bdc24fc67c061a805237dc
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	3.66 KB	eb9b4507a856f0eaabc2014248d17876f6a253387f568eeab92e86b1ea6e00ca
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	5d72eaaa4034ca263e9257ef18b8707d6b211c7a7a2041286e48d805d62b51fc
log/.gitkeep	100664	0 Bytes	e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
renovate.json	100664	159 Bytes	37f6199435407485a4fb924c3283710f2c938adf69489aaeb5ab208bf5f4229d