| lib/karafka/connection/client.rb | 300 | D 2 days |
|
| lib/karafka/pro/connection/manager.rb | 134 | C 1 day |
|
| lib/karafka/cli/topics/plan.rb | 119 | C 1 day |
|
| lib/karafka/instrumentation/vendors/appsignal/metrics_listener.rb | 209 | C 7 hrs |
|
| lib/karafka/connection/listener.rb | 237 | C 7 hrs |
|
| lib/karafka/instrumentation/logger_listener.rb | 234 | B 6 hrs |
|
| lib/karafka/instrumentation/vendors/datadog/metrics_listener.rb | 189 | B 6 hrs |
|
| lib/karafka/pro/iterator/tpl_builder.rb | 91 | B 6 hrs |
|
| lib/karafka/swarm/manager.rb | 125 | B 4 hrs |
|
| lib/karafka/pro/processing/strategies/default.rb | 134 | B 4 hrs |
|
| lib/karafka/setup/attributes_map.rb | 314 | B 4 hrs |
|
| lib/karafka/server.rb | 74 | A 3 hrs |
|
| lib/karafka/swarm/supervisor.rb | 116 | A 3 hrs |
|
| lib/karafka/pro/processing/strategies/dlq/ftr_lrj.rb | 41 | A 3 hrs |
|
| lib/karafka/pro/processing/strategies/dlq/ftr_lrj_mom.rb | 43 | A 3 hrs |
|
| lib/karafka/pro/processing/strategies/vp/default.rb | 75 | A 3 hrs |
|
| lib/karafka/pro/processing/strategies/lrj/ftr.rb | 37 | A 2 hrs |
|
| lib/karafka/pro/processing/strategies/dlq/lrj_mom.rb | 37 | A 2 hrs |
|
| lib/karafka/pro/processing/strategies/dlq/lrj.rb | 34 | A 2 hrs |
|
| lib/karafka/pro/processing/strategies/aj/dlq_ftr_lrj_mom_vp.rb | 45 | A 2 hrs |
|
| lib/karafka/cli/topics/align.rb | 66 | A 2 hrs |
|
| lib/karafka/base_consumer.rb | 147 | A 2 hrs |
|
| lib/karafka/pro/processing/strategies/lrj/default.rb | 50 | A 2 hrs |
|
| lib/karafka/pro/processing/strategies/dlq/default.rb | 137 | A 2 hrs |
|
| lib/karafka/swarm/pidfd.rb | 91 | A 2 hrs |
|
| lib/karafka/processing/worker.rb | 47 | A 2 hrs |
|
| lib/karafka/pro/processing/strategies/lrj/ftr_mom.rb | 36 | A 2 hrs |
|
| lib/karafka/pro/processing/strategies/ftr/default.rb | 64 | A 1 hr |
|
| lib/karafka/pro/processing/strategies/aj/dlq_lrj_mom_vp.rb | 37 | A 1 hr |
|
| lib/karafka/pro/processing/strategies/aj/ftr_lrj_mom_vp.rb | 39 | A 1 hr |
|
| lib/karafka/pro/processing/strategy_selector.rb | 48 | A 1 hr |
|
| lib/karafka/pro/processing/strategies/lrj/mom.rb | 48 | A 1 hr |
|
| lib/karafka/pro/processing/strategies/aj/lrj_mom_vp.rb | 49 | A 1 hr |
|
| lib/karafka/processing/strategies/dlq.rb | 71 | A 1 hr |
|
| lib/karafka/pro/iterator.rb | 88 | A 1 hr |
|
| lib/karafka/pro/processing/strategies/aj/dlq_ftr_lrj_mom.rb | 43 | A 1 hr |
|
| lib/karafka/pro/contracts/server_cli_options.rb | 62 | A 1 hr |
|
| lib/karafka/contracts/server_cli_options.rb | 59 | A 1 hr |
|
| lib/karafka/instrumentation/vendors/datadog/logger_listener.rb | 119 | A 1 hr |
|
| lib/karafka/pro/routing/features/swarm/contracts/routing.rb | 45 | A 1 hr |
|
| lib/karafka/pro/processing/strategies/aj/dlq_ftr_mom_vp.rb | 38 | A 1 hr |
|
| lib/karafka/pro/processing/strategies/aj/dlq_ftr_mom.rb | 35 | A 1 hr |
|
| lib/karafka/pro/processing/strategies/dlq/ftr_mom.rb | 35 | A 1 hr |
|
| lib/karafka/cli/topics/base.rb | 40 | A 1 hr |
|
| lib/karafka/pro/routing/features/expiring/topic.rb | 33 | A 1 hr |
|
| lib/karafka/pro/routing/features/delaying/topic.rb | 33 | A 1 hr |
|
| lib/karafka/pro/routing/features/expiring/contracts/topic.rb | 25 | A 1 hr |
|
| lib/karafka/pro/routing/features/delaying/contracts/topic.rb | 25 | A 1 hr |
|
| lib/karafka/pro/processing/strategies/aj/dlq_lrj_mom.rb | 36 | A 1 hr |
|
| lib/karafka/patches/rdkafka/bindings.rb | 81 | A 1 hr |
|