lib/water_drop/pool.rb in waterdrop-0.1.7 vs lib/water_drop/pool.rb in waterdrop-0.1.8

@@ -12,10 +12,10 @@
           size: ::WaterDrop.config.connection_pool_size,
           timeout: ::WaterDrop.config.connection_pool_timeout
         ) do
           Poseidon::Producer.new(
             ::WaterDrop.config.kafka_hosts,
-            object_id.to_s
+            object_id.to_s + rand.to_s + Time.now.to_f.to_s
           )
         end
       end
     end
   end