diff --git a/src/asynStreamGeneratorDriver.cpp b/src/asynStreamGeneratorDriver.cpp index dec026f..290361f 100644 --- a/src/asynStreamGeneratorDriver.cpp +++ b/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(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));