From 18da14f6d631001b3b91f246fe7bd57ba457fe46 Mon Sep 17 00:00:00 2001
From: Edward Wall <edward.wall@psi.ch>
Date: Thu, 6 Nov 2025 16:48:31 +0100
Subject: [PATCH] adds additional key that can be set

---
 src/asynStreamGeneratorDriver.cpp | 5 +++++
 1 file changed, 5 insertions(+)

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<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));