Class: Karafka::Web::Pro::Commanding::Handlers::Partitions::Commands::Resume

Inherits:
Base
  • Object
show all
Defined in:
lib/karafka/web/pro/commanding/handlers/partitions/commands/resume.rb

Overview

Resumes paused partition

Instance Method Summary collapse

Methods inherited from Base

#initialize

Constructor Details

This class inherits a constructor from Karafka::Web::Pro::Commanding::Handlers::Partitions::Commands::Base

Instance Method Details

#call ⇒ Object

Expires the pause so Karafka resumes processing of the given topic partition



16
17
18
19
20
21
 
# File 'lib/karafka/web/pro/commanding/handlers/partitions/commands/resume.rb', line 16

def call
  coordinator.pause_tracker.expire
  coordinator.pause_tracker.reset if request[:reset_attempts]

  result('applied')
end