Change log level to debug

Author: simPod

src/Clients/Consumer/KafkaConsumer.php

@@ -51,7 +51,7 @@ function (RdKafkaConsumer $kafka, int $err, string $reason): void {
             function (RdKafkaConsumer $kafka, int $err, ?array $partitions = null): void {
                 switch ($err) {
                     case RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS:
-                        $this->logger->info(
+                        $this->logger->debug(
                             'Assigning partitions',
                             $partitions === null ? [] : array_map(
                                 static function (TopicPartition $partition): string {
@@ -63,7 +63,7 @@ static function (TopicPartition $partition): string {
                         $kafka->assign($partitions);
                         break;
                     case RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS:
-                        $this->logger->info(
+                        $this->logger->debug(
                             'Revoking partitions',
                             $partitions === null ? [] : array_map(
                                 static function (TopicPartition $partition): string {
@@ -170,11 +170,11 @@ private function doStart(
                         $onPartitionEof();
                     }
 
-                    $this->logger->info('No more messages. Will wait for more');
+                    $this->logger->debug('No more messages. Will wait for more');
 
                     break;
                 case RD_KAFKA_RESP_ERR__TIMED_OUT:
-                    $this->logger->info(sprintf('Timed out with timeout %d ms', $timeoutMs));
+                    $this->logger->debug(sprintf('Timed out with timeout %d ms', $timeoutMs));
                     if ($onTimedOut !== null) {
                         $onTimedOut();
                     }
@@ -225,7 +225,7 @@ private function checkBatchTimedOut(
 
     public function shutdown(): void
     {
-        $this->logger->info('Shutting down');
+        $this->logger->debug('Shutting down');
 
         $this->shouldRun = false;
     }