kafkafixes

EspadaKomanda · Nov 21, 2024 · d21c1b9 · d21c1b9
1 parent da23c0b
commit d21c1b9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/ApiGatewayService/Kafka/KafkaRequestService.cs b/ApiGatewayService/Kafka/KafkaRequestService.cs
@@ -179,7 +179,7 @@ public async Task<bool> Produce(string topicName, Message<string, string> messag
                 if (IsTopicExists && IsTopicPendingMessageBusExist( responseTopic))
                 {
                     var deliveryResult = await _producer.ProduceAsync(
-                    new TopicPartition(topicName, new Partition(0));
+                    new TopicPartition(topicName, new Partition(0)));
                     if (deliveryResult.Status == PersistenceStatus.Persisted)
                     {
                         _logger.LogInformation("Message delivery status: Persisted {Result}", deliveryResult.Value);
@@ -202,7 +202,7 @@ public async Task<bool> Produce(string topicName, Message<string, string> messag
                 if (IsTopicCreated && IsTopicPendingMessageBusExist( responseTopic))
                 {
                     var deliveryResult = await _producer.ProduceAsync(
-                    new TopicPartition(topicName, new Partition(0));
+                    new TopicPartition(topicName, new Partition(0)));
                     if (deliveryResult.Status == PersistenceStatus.Persisted)
                     {
                         _logger.LogInformation("Message delivery status: Persisted {Result}", deliveryResult.Value);

diff --git a/ApiGatewayService/Kafka/KafkaService.cs b/ApiGatewayService/Kafka/KafkaService.cs
@@ -82,7 +82,7 @@ public async Task<bool> Produce( string topicName,Message<string, string> messag
             if (IsTopicExists)
             {
                 var deliveryResult = await _producer.ProduceAsync(
-                    new TopicPartition(topicName, new Partition(0));
+                    new TopicPartition(topicName, new Partition(0)));
                 if (deliveryResult.Status == PersistenceStatus.Persisted)
                 {
 
@@ -99,7 +99,7 @@ public async Task<bool> Produce( string topicName,Message<string, string> messag
             if (IsTopicCreated)
             {
                 var deliveryResult = await _producer.ProduceAsync(
-                    new TopicPartition(topicName, new Partition(0));
+                    new TopicPartition(topicName, new Partition(0)));
                 if (deliveryResult.Status == PersistenceStatus.Persisted)
                 {
                     _logger.LogInformation("Message delivery status: Persisted {Result}", deliveryResult.Value);