Seed rng for proper random partitioning, jitters, etc.

edenhill · May 3, 2016 · b79896c · b79896c
1 parent 82971a3
commit b79896c
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/kafkacat.c b/kafkacat.c
@@ -31,6 +31,7 @@
 #include <stdlib.h>
 #include <stdarg.h>
 #include <signal.h>
+#include <sys/time.h>
 #include <syslog.h>
 #include <sys/types.h>
 #include <sys/stat.h>
@@ -1243,11 +1244,16 @@ static void conf_dump (void) {
 int main (int argc, char **argv) {
         char tmp[16];
         FILE *in = stdin;
+	struct timeval tv;
 
         signal(SIGINT, term);
         signal(SIGTERM, term);
         signal(SIGPIPE, term);
 
+	/* Seed rng for random partitioner, jitter, etc. */
+	gettimeofday(&tv, NULL);
+	srand(tv.tv_usec);
+
         /* Create config containers */
         conf.rk_conf  = rd_kafka_conf_new();
         conf.rkt_conf = rd_kafka_topic_conf_new();