aboutsummaryrefslogtreecommitdiffstats
path: root/fatcat_scholar/kafka.py
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@archive.org>2021-03-29 20:51:45 -0700
committerBryan Newbold <bnewbold@archive.org>2021-03-29 20:51:45 -0700
commit30b93dc18464bd8c1675d8279d2cf7493ba24a12 (patch)
tree151b1150b1856e7142ece2b1c3602f7aeab29a76 /fatcat_scholar/kafka.py
parentfc6ebef14cf3398ac1664b9f585d6ed5e7caf609 (diff)
downloadfatcat-scholar-30b93dc18464bd8c1675d8279d2cf7493ba24a12.tar.gz
fatcat-scholar-30b93dc18464bd8c1675d8279d2cf7493ba24a12.zip
make fmt
Diffstat (limited to 'fatcat_scholar/kafka.py')
-rw-r--r--fatcat_scholar/kafka.py3
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)