remove eof

open-telemetry · Apr 30, 2024 · a35283c · a35283c
1 parent 1ea216c
commit a35283c
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/src/accountingservice/Consumer.cs b/src/accountingservice/Consumer.cs
@@ -39,10 +39,6 @@ public void StartListening()
                 try
                 {
                     var consumeResult = _consumer.Consume();
-                    if (consumeResult.IsPartitionEOF)
-                    {
-                        continue;
-                    }
 
                     ProcessMessage(consumeResult.Message);
                 }
@@ -83,8 +79,7 @@ private IConsumer<string, byte[]> BuildConsumer(string servers)
             // https://github.com/confluentinc/confluent-kafka-dotnet/tree/07de95ed647af80a0db39ce6a8891a630423b952#basic-consumer-example
             AutoOffsetReset = AutoOffsetReset.Earliest,
             CancellationDelayMaxMs = 10_000,
-            EnableAutoCommit = true,
-            EnablePartitionEof = true,
+            EnableAutoCommit = true
         };
 
         return new ConsumerBuilder<string, byte[]>(conf)