diff options
Diffstat (limited to 'fatcat_scholar/kafka.py')
| -rw-r--r-- | fatcat_scholar/kafka.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/fatcat_scholar/kafka.py b/fatcat_scholar/kafka.py index bee2fee..f412f8a 100644 --- a/fatcat_scholar/kafka.py +++ b/fatcat_scholar/kafka.py @@ -103,8 +103,7 @@ class KafkaWorker: # check for partition-specific commit errors if p.error: print( - f"Kafka consumer commit error: {p.error}", - file=sys.stderr, + f"Kafka consumer commit error: {p.error}", file=sys.stderr, ) raise KafkaException(p.error) |