lib/deimos/producer.rb in deimos-ruby-1.8.2.pre.beta2 vs lib/deimos/producer.rb in deimos-ruby-1.8.2

@@ -102,10 +102,12 @@
       def publish_list(payloads, sync: nil, force_send: false, topic: self.topic)
         return if Deimos.config.kafka.seed_brokers.blank? ||
                   Deimos.config.producers.disabled ||
                   Deimos.producers_disabled?(self)
 
+        raise 'Topic not specified. Please specify the topic.' if topic.blank?
+
         backend_class = determine_backend_class(sync, force_send)
         Deimos.instrument(
           'encode_messages',
           producer: self,
           topic: topic,
@@ -181,11 +183,11 @@
         message.topic = topic
         message.encoded_payload = if message.payload.nil?
                                     nil
                                   else
                                     encoder.encode(message.payload,
-                                                   topic: "#{config[:topic]}-value")
+                                                   topic: "#{Deimos.config.producers.topic_prefix}#{config[:topic]}-value")
                                   end
       end
 
       # @param key [Object]
       # @return [String|Object]
@@ -199,12 +201,12 @@
            config[:key_schema].nil?
           raise 'No key config given - if you are not encoding keys, please use `key_config plain: true`'
         end
 
         if config[:key_field]
-          encoder.encode_key(config[:key_field], key, topic: "#{config[:topic]}-key")
+          encoder.encode_key(config[:key_field], key, topic: "#{Deimos.config.producers.topic_prefix}#{config[:topic]}-key")
         elsif config[:key_schema]
-          key_encoder.encode(key, topic: "#{config[:topic]}-key")
+          key_encoder.encode(key, topic: "#{Deimos.config.producers.topic_prefix}#{config[:topic]}-key")
         else
           key
         end
       end