karafka-2.0.0.beta1

https://rubygems.org

karafka

quick gemspec

.gem

.gem metadata (gemspec)

.gemspec

source_code_uri
https://github.com/karafka/karafka
rubygems_mfa_required
true

id: 982945

number: 2.0.0.beta1

platform: ruby

spec_sha256: 6be5ebad871055d3dfcdf394feae5a50b3b40e274050eff6203cbda7cc83234c

sha256: 22792f5c73a95c2e008fc71d411fe4556263463ed11555b8f8b23257e70d4652

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

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

position: 111

version_data_entries_count: 115

uploaded_at: 2022-05-22 14:02:47 UTC

indexed: true

has_extensions:

extensions:

Gem size: 87.5 KB

Version Data Entries

Total: 115

Unpacked size: 246 KB

Full NameModeUIDGIDMtimeLinknameSizeSHA
.coditsu/ci.yml10066400138 Bytese4ebfa4ad81dd12ffe492ff9168a0fb9c20d3e74e8bff0aa06f54c6c76cef711
.console_irbrc10066400336 Bytes4431d0fa2de6c2846d47a90a2f22d6c5dea9a41f097abf9160e05b2b81b30c6e
.diffend.yml10066400158 Bytesa49a2e6b3b48603cfe838d422d381d219a49d7593c72c9a82c5e10296e90b4b9
.github/ISSUE_TEMPLATE/bug_report.md100664001.3 KB49838cfbc9c1c052cc8cb1e8889276bee6caff8e24a270c49322f2d61e5dd7d2
.github/ISSUE_TEMPLATE/feature_request.md10066400593 Bytes739d98d20ac43aedb1aa0c34d93209a440fc0ff142037f76950c95888dc4cfeb
.github/workflows/ci.yml100664003.04 KB7823711f2023f6b974bcdc5085663c57fd02a67fd4f79186ce03acd5663a40f5
.gitignore100664001023 Bytescfaaf830420e24157da66709f087a6f1c395deb5acf38a0bb162c3a77e6fb22f
.rspec1006640022 Bytes59cb44b82275dbbbe102e09ad72aaafa8a3b1f15ec35682f21c6741ca9d2c7b2
.ruby-gemset100664008 Bytes2afae0b89d0be84fbce9611eb5bdcf52d69396704dc429f68b6270ce56c8880c
.ruby-version100664006 Bytes905360921e63f419d6a111dd3216bf28402f367ab9aa69444d80e97419600d80
CHANGELOG.md1006640032.8 KB5f4349fdfbec8eef8e1b9004d0fa101bc8892627f8e266156c58b0baf0417389
CODE_OF_CONDUCT.md100664003.14 KBc5be22a6783a9daf04a76f109d5695618c5e55638e2f5c5dc8821c3180ec88a3
CONTRIBUTING.md100664002.14 KBff116e17f4313236959a57a2f4b4f5d5a8cd1286c5db10b18d55a4f89a51dd93
Gemfile10066400336 Bytes835cc2e99d2d7e7c9bedba273fa7d729deb4a04a823c49203262bc9f5f5a13e0
Gemfile.lock100664003.01 KBac37c0b4097bbe7ead124e19a938ed410e0d9df3c42e5ca0cfc82be635f75de5
LICENSE10066400676 Bytese0ba5ff22408c4e5a0ee71b3ee8bfc68faa51b74fc36ee09eb454deceb5597d9
LICENSE-COMM1006640015.9 KB3c9a519e15e08855abb5237f90ebb38f06d2e86700c32f2bfeda2c7e7999714c
LICENSE-LGPL100664007.47 KBda7eabb7bafdf7d3ae5e9f223aa5bdc1eece45ac569dc21b3b037520b4464768
README.md100664003.95 KBc842a99b598bd3c85723a040be43b327d768537895ebe3402f67bf7d1f22577a
bin/benchmarks100775002.46 KBa44b426893921660a53bbc39745660a37bedcec9e21427e9d785120de0f35b38
bin/create_token10077500770 Bytesaa93123ad7aaed1cda4f231bc6ef248a4856eb8671466791d38c43ba4022e872
bin/integrations100775006.28 KBeff7ff9cf47fed61d93e4bb4c16cc7499dff5a2f6eb4978fa623dfe83f54a506
bin/karafka10077500688 Bytes05b71a2e7ac0c9ffe7714e711a887ae8c235fbe59e71ce8339412080895d63e2
bin/stress10077500282 Bytes97e83a9c81ac8493a5bdf83391aeb69ca0b74323782dbe13dcbb65713cde5817
certs/karafka-pro.pem10066400601 Bytes80e379259996ca2d52259405b21c86bb20306c53be5ce0e384b62546466dba4f
certs/mensfeld.pem100664001.49 KB614c78ad388bdb72fbdfc27924283ec38e84fbaee7ba2f3f96b67bb69e3bec85
config/errors.yml10066400440 Bytesf83b5454fd28d9487e812fb33e5f8ec8c43e32fe12874d30a6b34d507cbef417
docker-compose.yml10066400807 Bytesb448259453eb56120f2462298521e551aa41f08b597e87070b2ff5ffd8502d49
karafka.gemspec100664001.42 KB36bd138605e013f05019613aeb875961da32d2ab756aba8dbbe772c874a41c80
lib/active_job/karafka.rb10066400784 Bytesc937d6b4d2be799e88d0f9c3499d3ae67f89dccb71ef6fd8eeecf97ee96cb377
lib/active_job/queue_adapters/karafka_adapter.rb10066400869 Bytesc52274add31f1edf456c760fdd5543f38770d5a5c20877b57108843e8cadf1ab
lib/karafka.rb100664002.66 KB747c002a56865c5eb873aa849fd599072c313a4b8f70a03b5a8a762421188453
lib/karafka/active_job/consumer.rb10066400910 Bytes0621bde2cab10be137ac78901b3e25691d2b1374fd24ba9112f53fb639e87ab4
lib/karafka/active_job/dispatcher.rb100664001017 Bytes6ac75aa3cf710a398071596db7cf8875e5d51ada32d1da84c4df43c2d4514cef
lib/karafka/active_job/job_extensions.rb100664001.01 KB727ff923dbc60f5a8e3c0af70c8cf3afb6484b7b5202ee1477b6f431eac8eeb7
lib/karafka/active_job/job_options_contract.rb10066400569 Bytes0634c9a8946b3ebaf9b1663344327c4398322c437fc434c16882e122f543fbc0
lib/karafka/active_job/routing_extensions.rb10066400535 Bytes538b238047dea47776b297d901dcdc90665f81a993798cbb20e880e06d557d31
lib/karafka/app.rb100664001.03 KB4e8af3a226e74eec439dbcf08ccd4a200c4d07dd09d8d7ddcfe798428a93b11e
lib/karafka/base_consumer.rb100664005.71 KBe624ea98c07e7478ff74ffe30a80624cb1dee667b00affb6e6f197bbb8f19aa9
lib/karafka/cli.rb100664001.71 KB407a9c3973134847b28d2e7e89f7d9bbcd99ab2952cdb26e36ce0f5a1b0750c4
lib/karafka/cli/base.rb100664002.14 KBd3c869dc219ac1702d26ce14bde0d308793f5501377a9f57d701ee6b7ff43758
lib/karafka/cli/console.rb10066400781 Bytes2d2fc7986540e3dbb988b281620edd61f079ef74645e894ec74e461596639bd2
lib/karafka/cli/info.rb100664002 KB74d998720ddea21bfa0c7c43c0eaca53141c22481fd4f6b14140e6edcb5c910d
lib/karafka/cli/install.rb100664001.76 KBb40306c40abea6defe18e85f1b4744a65efcfde100d5f77a705d3cf9809fb423
lib/karafka/cli/server.rb100664001.2 KB38d28ea3063213be37dd24d609877b15ca30d2fd7439ef0f6691d1e3377568cb
lib/karafka/connection/client.rb1006640011 KB30b73a4a8eadbc1c6d97bf5c069b7b21d3c050d004c7a8516e9b016929a265a4
lib/karafka/connection/listener.rb100664006.89 KB4a8cfcf8023ca3fe0aee44dcfecdc96681404ea6a520fe40c7b0c1a2b1b6d73c
lib/karafka/connection/messages_buffer.rb100664002.91 KB72d93f5dfc08c06a68e3df830cc667346cfe7db4990efb2686c861663c355cc0
lib/karafka/connection/pauses_manager.rb100664001.39 KB11bce0cd67ea783e1eaca055e44933f92d1e279b397974e2707dc60371b3b000
lib/karafka/connection/rebalance_manager.rb100664002.9 KBb4b532ce9c794b7f5c499284a54db8ab698368208fe3182b2fb0c9f103e64328
lib/karafka/contracts.rb10066400327 Bytes0a2b9ad7b94e44baacf04f81130eb9c68f21fbbcbccdbb7aa0f94a22ea8749e6
lib/karafka/contracts/base.rb10066400778 Bytesb9ce9d2f4ef2ee8515aa808fd92aa50cd37cacbebc1a0d7c681bb6caa67a05c1
lib/karafka/contracts/config.rb100664002.07 KB0c299b6ee57a4fc132d2c1d4e705d481d5ae4378ce1b66580bf03dbd55c1d07d
lib/karafka/contracts/consumer_group.rb10066400997 Bytes87bf7ecd9633eb04439bf11de6366607f6584a6e2103822f6dac31a0347675d4
lib/karafka/contracts/consumer_group_topic.rb100664001001 Bytes8266b66a68ddf5ed43dac664d288c4b5dda7dba573a61bfcc28bed3df95bf4a5
lib/karafka/contracts/server_cli_options.rb10066400674 Bytes76805fbcb467bddb5dc2b742d31ec5bc5d8e2360a4de0cf382f5011765d4ac6b
lib/karafka/env.rb100664001.43 KB7c80157166da7eb037f8ad61d9436acb1ffa8d36aca62243732dc55f2451f282
lib/karafka/errors.rb100664002.19 KB474397e7477ef8def488bd592bc7fb566c6dc12e70e4274a0598a5c1f48a8746
lib/karafka/helpers/multi_delegator.rb10066400933 Bytesc472db16985b61622710a9fdb697d6d930d31ee02e512d8f47bec4e6ab4838d2
lib/karafka/instrumentation.rb10066400641 Bytes4751ae47b221c25da4f6ca89b78a8d3c62eb36ea56cfa5e48c6100510caf540e
lib/karafka/instrumentation/callbacks/error.rb100664001.55 KBc7e29b880e8276737ba95ae1a60099ed17989ab226769851ec8c1d7d925b544e
lib/karafka/instrumentation/callbacks/statistics.rb100664001.74 KBfdb56dab19c3f2cb5e8dde264f29f9b456b3cce81bd94afbbfcfe029a723720d
lib/karafka/instrumentation/logger.rb100664001.7 KB9c60d2e6106306243c2125fa7c7ebe4299d4d8e774a5f1df8a7b44db83180f9b
lib/karafka/instrumentation/logger_listener.rb100664004.07 KB5cd44ea407cb7fd22102587c8df917ac0033361f5d269902c43d57f9b231ee53
lib/karafka/instrumentation/monitor.rb100664002.44 KBc6cbbd7e245049132146730873a568e14fdc4cef7b919a8a36aabdfb5e1185c2
lib/karafka/instrumentation/proctitle_listener.rb100664001.04 KBd44fc85a9cc97a943a47838f1959ff8f2dbba976d3ba4be96d85e24e1396ba5b
lib/karafka/licenser.rb100664002.57 KB1b38a42863eef0b1fce269d88ca500c19ea390d93350e14a5ebf607914961858
lib/karafka/messages/batch_metadata.rb10066400539 Bytes94066c2ca705277e49333bf426ee5aecaa02a9377ed4f63ad9c21460f9f38784
lib/karafka/messages/builders/batch_metadata.rb100664002.1 KB6d4d6a6514a11f4dd28dd7deb253dd6c11a36891a633bb7413999a992341dbe9
lib/karafka/messages/builders/message.rb100664001.36 KB8b9fb31af1a92d9aa34c4bec3b1d4f0752eb6fda8bb7b2031cbaf5fcc56225e9
lib/karafka/messages/builders/messages.rb100664001.23 KB5e3dca1638d4c7018e8f0d630623153c906cc9f0e4ffbf759bc3395e33925581
lib/karafka/messages/message.rb100664001.47 KB0caa232df6b5079b4070a53d1ed8a1345c033c240ae019f8220b011d6fc0eceb
lib/karafka/messages/messages.rb100664001.85 KB4269d340d6d1dd198937d5e471d9a2b001d347a0f30a329f53da073bd40e43c0
lib/karafka/messages/metadata.rb10066400362 Bytes45159d2a186917f7350a4a0a22fe031603eb406f2c30c30a145ea412f56b1af5
lib/karafka/messages/seek.rb10066400270 Bytes1aeb13ee86e9afb829120c812531a72ed44e169146fa5608e14c544b99226de2
lib/karafka/patches/rdkafka/consumer.rb10066400656 Bytes72ff89568105af60357f7926aa4108e56f1006b202193e9bdbd9e71030467605
lib/karafka/pro.rb10066400451 Bytes57ee351f4aafb1c151cd2863e30aa4684356440e7a74d35316f242ea5ae71237
lib/karafka/pro/active_job/dispatcher.rb100664002.02 KB33b9278b0eee963a24a03427cc8afbc2697550ca7996cf254180968904d62313
lib/karafka/pro/active_job/job_options_contract.rb10066400949 Bytesa3b3ca7a0a53752937991695111178ed238099f7b718a97b0fb1e9904709719d
lib/karafka/pro/loader.rb100664001.35 KB68ca818af176243a3078f9970aedc316755fe2ce6390259d4e8a7497752620e7
lib/karafka/pro/performance_tracker.rb100664002.77 KBcf446e7e42ec33f5e69a91c1b3fba2b2069e1018a53333e9165c39611f62410a
lib/karafka/process.rb100664001.94 KB1f0b779daa8e9825584a7f87e565de593b13118e89cdaec43edd91fb6bdee72f
lib/karafka/processing/executor.rb100664003.95 KBa210f53bb3ef76092724116ff94552c4898df90966376cc0b1ac77004de9fb71
lib/karafka/processing/executors_buffer.rb100664001.45 KB463c3ef707ad64cf3854dcc4be8b7ab4deb8e52dd8adeafadddbcd5c853c4710
lib/karafka/processing/jobs/base.rb100664001.14 KBdffd2b16c7d3c43957a87169018b2c1089fba4ad246d3b86607fbc5389a88bb9
lib/karafka/processing/jobs/consume.rb10066400957 Bytesbc0283c9cdfc519725a7de2c2a0c708202a21c22a0540cf9038c3d07c52e76fe
lib/karafka/processing/jobs/revoked.rb10066400561 Bytes7e2ddcbb18c88f9761943988cd70a4bf82e528b448adfa3391a3f3477a2ff829
lib/karafka/processing/jobs/shutdown.rb10066400596 Bytes60b136c19adc9f79982e65b0f167f42ff991446a0b3201f71c3dd5c6e7207899
lib/karafka/processing/jobs_queue.rb100664005.03 KB6fd58c67695a71799fa8e986ee4bf4d822d7a85e73d1efb1efa78b0b1493e990
lib/karafka/processing/worker.rb100664002.75 KBf97284aa076102e0ca529877d2f286b7fd7a489e19e4583dcf5cbca5a2add32a
lib/karafka/processing/workers_batch.rb10066400555 Bytesd3266b0a99343aa6988b949de43e37029eb42973af77e6e064e6f945fa99cfe9
lib/karafka/railtie.rb100664003.8 KB91eafa35b0527057d2534773de7ed1c2f85f6b543d76b4665b7b09e65c911e2d
lib/karafka/routing/builder.rb100664002.66 KB56dc41c8051afe67554f497acefd99f121291ec17bd463684e611d225199e098
lib/karafka/routing/consumer_group.rb100664002.09 KBbe7922921c758dbea7831cabd627d8a2b8da424ba39d7bf6dc3ebc856d572235
lib/karafka/routing/consumer_mapper.rb100664001.18 KBbd42326c09dd22c60c49053a28a155fc0315565a241ac767d9091c15ed8a6d74
lib/karafka/routing/proxy.rb100664001.58 KB4230a20e0a49a6c5aad1e72118260b09972f7af1703660d09a0598893f42d650
lib/karafka/routing/router.rb100664001.06 KB99b9a1ed4f52bc72c89dc48a613c60be933c92627a906cb8dd6aba724b8b3225
lib/karafka/routing/subscription_group.rb100664001.78 KBaa6eb1b283eeea42459516cf36f4ec5bce2d03455788d2e090dd93f70affc96e
lib/karafka/routing/subscription_groups_builder.rb100664001.84 KB694a57d8a75b83e81195c1101954e51157888183c153fc5eb94766c3acf3d54a
lib/karafka/routing/topic.rb100664002.88 KBc5fa6bc47c20f0e4d039dfa9fc57feda0060a771436237eb7449ad33a7b09683
lib/karafka/runner.rb100664002.09 KB372a7b8bc37610047ade2ef243ea4e5445f7317971cc6fd7a739bd3035cff91d
lib/karafka/scheduler.rb10066400722 Bytes4ec0598a9cbcf671207dcb1f2784e0d2d0966203843c2a446b20b5ccedd85f50
lib/karafka/serialization/json/deserializer.rb10066400609 Bytes25ca80fd3f8baacc2812ab41359494e62ff0fad0c1ec5214c1b143eba46f3387
lib/karafka/server.rb100664004.14 KBee913d829f1642edd49b37084a0a8d16749e905a3cf40d6f51e21d7bce51b622
lib/karafka/setup/config.rb100664007.86 KB3ba7e5a9a7dc01fc96bdeb7e6017dff07bafcf547b967fe57ed2b7f8b38dc802
lib/karafka/setup/dsl.rb10066400555 Bytesd9a93c794c071cda753465d9145dc657a8a2ab5d226e2fc0724e134c644f09ae
lib/karafka/status.rb10066400977 Bytes85f49895adeb635da102a1ee39a66a59a4258b0f14baa9d5eef1b7a78a772680
lib/karafka/templates/application_consumer.rb.erb10066400286 Bytes44a56710679e00a419831a79da526cbad4a0d15c95f2834ee09e03ed0185ee0f
lib/karafka/templates/example_consumer.rb.erb10066400375 Bytes4f443ec86a1a93a7d32ac84332e05b38a21e99b94d0eab1963d38edfd7bc0d86
lib/karafka/templates/karafka.rb.erb100664001.86 KB99a4f02575ae9d20df6430dc14be09a717bf131eafceaa6eda0498a0c2b180ab
lib/karafka/time_trackers/base.rb10066400501 Bytes2f39990f90504428eb22d0e32d5285ee647da6d0838e3194ee824ae2fd9868a7
lib/karafka/time_trackers/pause.rb100664002.73 KBdb3c7e7201e10bfecebc6f15695dab6d98abe9aa66a1cbbb22e246ca06e23a2c
lib/karafka/time_trackers/poll.rb100664001.74 KB5b1e6aad553fbe16b4230f2435e6e88ac2d45595f14b6faceb43579793cff047
lib/karafka/version.rb10066400128 Bytes263f062e1e2fbe295d82e9e192ec7433c792114375bb6c7f5b98142d45ae9fee
log/.gitkeep100664000 Bytese3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855