class Karafka::BaseConsumer

def topic=(topic)

Returns:
  • (Karafka::Routing::Topic) - assigned topic

Parameters:
  • topic (Karafka::Routing::Topic) -- 
def topic=(topic)
  @topic = topic
  Consumers::Includer.call(self)
end