diff options
Diffstat (limited to 'fatcat_scholar/kafka.py')
| -rw-r--r-- | fatcat_scholar/kafka.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/fatcat_scholar/kafka.py b/fatcat_scholar/kafka.py index f412f8a..71067c1 100644 --- a/fatcat_scholar/kafka.py +++ b/fatcat_scholar/kafka.py @@ -1,10 +1,10 @@ -import sys import json import signal +import sys from collections import Counter -from typing import List, Any +from typing import Any, List -from confluent_kafka import Consumer, Producer, KafkaException +from confluent_kafka import Consumer, KafkaException, Producer class KafkaWorker: |