ssal config added

Author: piyal-ict-mbstu

src/KafkaLogHandler.php

@@ -90,7 +90,7 @@ protected function write(array $record): void
                 topic: $this->topic,
                 broker: $this->brokers
             );
-            if (!empty($this->config['sasl_config'])) {
+            if ($this->config['is_sasl_apply'] && !empty($this->config['sasl_config'])) {
                 $kafka->withSasl(new Sasl(
                     username: $this->config['sasl_config']['username'],
                     password: $this->config['sasl_config']['password'],

src/KafkaLogger.php

@@ -43,6 +43,7 @@ public static function getInstance(string $topicName, string $brokers, array $op
      */
     public function __invoke(array $config): Logger
     {
+
         $logger = new Logger('kafka');
         throw_if(empty($config['brokers']), new \Exception('Brokers is provided', ResponseAlias::HTTP_UNPROCESSABLE_ENTITY));
         throw_if($config['is_sasl_apply'] && empty($config['sasl_config']), new \Exception('SASL Configuration is required', ResponseAlias::HTTP_UNPROCESSABLE_ENTITY));
@@ -52,6 +53,7 @@ public function __invoke(array $config): Logger
             throw_if(empty($config['sasl_config']['mechanisms']), new \Exception('Auth Mechanisms is invalid', ResponseAlias::HTTP_UNPROCESSABLE_ENTITY));
             throw_if(empty($config['sasl_config']['security_protocol']), new \Exception('SecurityProtocol is invalid', ResponseAlias::HTTP_UNPROCESSABLE_ENTITY));
         }
+
         $topic = $config['topic'];
         $brokers = $config['brokers'];
         $key = $config['key'] ?? config('app.name');