adds additional key that can be set

src/asynStreamGeneratorDriver.cpp

@@ -40,6 +40,11 @@ static rd_kafka_t *create_kafka_producer(const char *kafkaBroker) {
     set_kafka_config_key(conf, "bootstrap.servers",
                          const_cast<char *>(kafkaBroker));
     set_kafka_config_key(conf, "queue.buffering.max.messages", "10000000");
+    // With 2e6 counts / s
+    // and a packet size of 20480 events (163920 bytes)
+    // this implies we need to send around 100 messages a second
+    // and need about .2 gigabit upload
+    // set_kafka_config_key(conf, "queue.buffering.max.kbytes", "10000000");
 
     // Create the Producer
     producer = rd_kafka_new(RD_KAFKA_PRODUCER, conf, errstr, sizeof(errstr));