otel: fix fetch_limit calculation

Signed-off-by: László Várady <[email protected]>
axoflow · Sep 25, 2024 · e9d7f43 · e9d7f43
1 parent 87f77fa
commit e9d7f43
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/modules/grpc/otel/otel-source.cpp b/modules/grpc/otel/otel-source.cpp
@@ -117,7 +117,12 @@ syslogng::grpc::otel::SourceDriver::init()
   msg_info("OpenTelemetry server accepting connections", evt_tag_int("port", port));
 
   if (fetch_limit == -1)
-    fetch_limit = super->super.worker_options.super.init_window_size;
+    {
+      if (super->super.worker_options.super.init_window_size != -1)
+        fetch_limit = super->super.worker_options.super.init_window_size / super->super.num_workers;
+      else
+        fetch_limit = 100;
+    }
 
   /*
    * syslog-ng-otlp(): the original HOST is always kept