fixes issue #58 (#59)

allows a topic name or a Kafka.Topic to be passed to Producer.produce
developed with @mimaison

Author: edoardocomar

lib/producer.js

@@ -105,26 +105,19 @@ function Producer(conf, topicConf) {
 }
 
 /**
- * Create a topic if it does not exist. Otherwise, create it
+ * Create a topic if it does not exist. Otherwise, get the cached one
  *
  * @private
  */
-function maybeTopic(name, config) {
+function maybeTopic(name) {
   // create or get topic
   var topic;
 
   if (typeof(name) === 'string') {
-
-    // If config is an empty object, reuse the ones we have in cache
-    if (config) {
-      topic = this.Topic(name, config);
+    if (this.createdTopics[name]) {
+      topic = this.createdTopics[name];
     } else {
-      // if config is an empty object
-      if (this.createdTopics[name]) {
-        topic = this.createdTopics[name];
-      } else {
-        topic = this.createdTopics[name] = this.Topic(name, {});
-      }
+      topic = this.createdTopics[name] = this.Topic(name, {});
     }
 
     return topic;
@@ -216,7 +209,7 @@ Producer.prototype.produce = function(topic, partition, message, key) {
     throw new Error('Producer not connected');
   }
 
-  if (typeof topic === 'object') {
+  if (typeof topic === 'object' && !(topic instanceof Kafka.Topic)) {
     return this._produceObject(topic, partition);
   }
 
@@ -229,7 +222,7 @@ Producer.prototype.produce = function(topic, partition, message, key) {
 
   partition = partition == null ? this.defaultPartition : partition;
 
-  topic = maybeTopic.call(this, topic, false);
+  topic = maybeTopic.call(this, topic);
 
   return this._errorWrap(
     this._client.produce(topic, partition, message, key || null));