lib/mimi/messaging/kafka/reply_listener.rb
# Create reply topic if it is not created yet
#
# @param kafka_topic [String] name of the reply topic
#
Create reply topic if it is not created yet
Create reply topic if it is not created yet
def create_topic(kafka_topic)
          @adapter.connection.create_topic(kafka_topic)
        rescue ::Kafka::TopicAlreadyExists
          raise "Failed to create #{self.class}: " \
            "attempted to concurrently listen on topic: #{kafka_topic}"
        end
def create_topic ( kafka_topic ) @adapter . connection . create_topic ( kafka_topic ) rescue :: Kafka :: TopicAlreadyExists raise "Failed to create #{self.class}: " "attempted to concurrently listen on topic: #{kafka_topic}" end
Create reply topic if it is not created yet
Create reply topic if it is not created yet
kafka_topic
name of the reply topic
name of the reply topic