Method: Karafka::Routing::Features::Eofed::Topic#eofed

Defined in:
lib/karafka/routing/features/eofed/topic.rb

#eofed(active = false) ⇒ Object

Parameters:

  • active (Boolean) (defaults to: false) —

    should the ‘#eofed` job run on eof



19
20
21
22
23
 
# File 'lib/karafka/routing/features/eofed/topic.rb', line 19

def eofed(active = false)
  @eofed ||= Config.new(
    active: active
  )
end