tools/kafka_repeater: Send messages to multiple partitions

btccom · Aug 7, 2019 · 77f77d1 · 77f77d1
1 parent fe7f774
commit 77f77d1
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/tools/kafka_repeater/KafkaRepeater.hpp b/tools/kafka_repeater/KafkaRepeater.hpp
@@ -57,7 +57,9 @@ class KafkaRepeater {
     , produceBrokers_(produceBrokers)
     , produceTopic_(produceTopic)
     , producer_(
-          produceBrokers_.c_str(), produceTopic_.c_str(), 0 /* patition */) {}
+          produceBrokers_.c_str(),
+          produceTopic_.c_str(),
+          RD_KAFKA_PARTITION_UA) {}
 
   static inline void loadOption(
       const libconfig::Setting &cfg,