remove output from revoke callback

fkie-cad · Oct 1, 2024 · 2fba7b2 · 2fba7b2
1 parent d25ef2a
commit 2fba7b2
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/logprep/connector/confluent_kafka/input.py b/logprep/connector/confluent_kafka/input.py
@@ -491,7 +491,6 @@ def _revoke_callback(self, consumer, topic_partitions):
                 topic_partition.topic,
                 topic_partition.partition,
             )
-        self.output_connector._write_backlog()
         self.batch_finished_callback()
 
     def _lost_callback(self, consumer, topic_partitions):