fix: decrease log intensity

README.md

@@ -63,9 +63,16 @@ The configuration file, `appsettings.json`, must be provided through a `volume m
 Execute the `30_run-container.sh` script or use the standard Docker run command. The script includes the `--rm` flag to automatically remove the container upon completion.
 
 ```sh
+
+# Linux/ MacOs
 $ ./30_run-container.sh ./src/kafka.transfer.app/appsettings.linux.json
-#OR
-$ docker run -it --rm -v "${APPSETTINGS_PATH}:/app/appsettings.json" ghcr.io/informatievlaanderen/kafka-topic-transfer:0.0.1
+
+# Windows
+$ ./30_run-container.sh "C:\APPSETTINGS_PATH\appsettings.MACHINENAME.json"
+
+
+# OR
+$ docker run -it --rm -v "ABSOLUTE_APPSETTINGS_PATH:/app/appsettings.json" ghcr.io/informatievlaanderen/kafka-topic-transfer:0.0.2
 ```
 
 ## Running with Docker-Compose
@@ -81,7 +88,7 @@ networks:
 
 services:
   basisregisters.kafka-topic-transfer:
-    image: ghcr.io/informatievlaanderen/kafka-topic-transfer:0.0.1
+    image: ghcr.io/informatievlaanderen/kafka-topic-transfer:0.0.2
     container_name: basisregisters.kafka-topic-transfer
     volumes:
       - "/home/yusuf/repos/fork/kafka-transfer/src/kafka.transfer.app/appsettings.linux.json:/app/appsettings.json"

VERSION

@@ -1 +1 @@
-0.0.1
+0.0.2

docker-compose.yml

@@ -5,7 +5,7 @@ networks:
 
 services:
   basisregisters.kafka-topic-transfer:
-    image: ghcr.io/informatievlaanderen/kafka-topic-transfer:0.0.1
+    image: ghcr.io/informatievlaanderen/kafka-topic-transfer:0.0.2
     container_name: basisregisters.kafka-topic-transfer
     volumes:
       - "/home/yusuf/repos/fork/kafka-transfer/src/kafka.transfer.app/appsettings.linux.json:/app/appsettings.json"

src/kafka.transfer.app/DataTarget/DataTargetBlock.cs

@@ -39,15 +39,18 @@ public async Task Start()
             var rawMessage = block.RawMessage as ConsumeResult<string, string>;
 
             //Observer sent -> 
-            _logger.LogInformation("Publishing consumed message with offset {Offset}", rawMessage!.TopicPartitionOffset.Offset);
-
+            var offset = rawMessage!.TopicPartitionOffset.Offset.Value;
+            var logLevel = offset % 1000L == 0 ? LogLevel.Information : LogLevel.Debug;
+            _logger.Log(logLevel, $"Publishing consumed message with offset {offset}");
+
             await _target.Publish(rawMessage, _cancellationToken.Token);
             _offsetManager.OnNext(block.RawMessage);
 
             //No more messages in the queue
             if (_bufferBlock.Count == 0)
             {
-                _logger.LogInformation("All messages in TPL queue are consumed and published");
+                _logger.LogInformation("All messages in TPL queue are consumed and published. \nWaiting for messages from consumer.");
+                _logger.LogInformation($"Current offset: {offset}");
             }
         }
     }