class Karafka::Routing::Topic

def initialize(name, consumer_group)

Parameters:
  • consumer_group (Karafka::Routing::ConsumerGroup) -- owning consumer group of this topic
  • name (String, Symbol) -- of a topic on which we want to listen 
def initialize(name, consumer_group)
  @name = name.to_s
  @consumer_group = consumer_group
  @attributes = {}
  # @note We use identifier related to the consumer group that owns a topic, because from
  #   Karafka 0.6 we can handle multiple Kafka instances with the same process and we can
  #   have same topic name across mutliple Kafkas
  @id = "#{consumer_group.id}_#{@name}"
end