Skip to content

Commit

Permalink
kafkafixes
Browse files Browse the repository at this point in the history
  • Loading branch information
@Er3shk1gal
Er3shk1gal committed Nov 21, 2024
1 parent e22c251 commit da23c0b
Show file tree
Hide file tree
Showing 10 changed files with 20 additions and 20 deletions.
4 changes: 2 additions & 2 deletions AuthService/Kafka/KafkaRequestService.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand All @@ -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);
Expand Down
4 changes: 2 additions & 2 deletions AuthService/Kafka/KafkaService.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,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)
{

Expand All @@ -98,7 +98,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);
Expand Down
4 changes: 2 additions & 2 deletions EntertaimentService/Kafka/KafkaRequestService.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -180,7 +180,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);
Expand All @@ -203,7 +203,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);
Expand Down
4 changes: 2 additions & 2 deletions EntertaimentService/Kafka/KafkaService.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,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)
{

Expand All @@ -98,7 +98,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);
Expand Down
4 changes: 2 additions & 2 deletions MailService/Kafka/KafkaRequestService.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand All @@ -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);
Expand Down
4 changes: 2 additions & 2 deletions MailService/Kafka/KafkaService.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,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)
{

Expand All @@ -98,7 +98,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);
Expand Down
4 changes: 2 additions & 2 deletions PromoService/Kafka/KafkaRequestService.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand All @@ -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);
Expand Down
4 changes: 2 additions & 2 deletions PromoService/Kafka/KafkaService.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,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)
{

Expand All @@ -98,7 +98,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);
Expand Down
4 changes: 2 additions & 2 deletions TourService/Kafka/KafkaRequestService.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand All @@ -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);
Expand Down
4 changes: 2 additions & 2 deletions TourService/Kafka/KafkaService.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,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)
{

Expand All @@ -98,7 +98,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);
Expand Down

0 comments on commit da23c0b

Please sign in to comment.