aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPriyansh <[email protected]>2021-12-25 03:32:18 -0500
committerPriyansh <[email protected]>2021-12-25 03:32:18 -0500
commitfea7e43ccb24734a5dee49460bd47bd9460b3f73 (patch)
tree393b34740d5a35dc4c478dbb37e6f748f63aa9a6
parent13c904ea5a58921d0c189601e10723c864a4b43f (diff)
downloadKafkaPySpark-fea7e43ccb24734a5dee49460bd47bd9460b3f73.tar.xz
KafkaPySpark-fea7e43ccb24734a5dee49460bd47bd9460b3f73.zip
Remove unused deps
-rw-r--r--consumer.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/consumer.py b/consumer.py
index 06d553b..8d15b07 100644
--- a/consumer.py
+++ b/consumer.py
@@ -1,4 +1,4 @@
-from kafka import KafkaConsumer, TopicPartition
+from kafka import KafkaConsumer
import json
import re
from database_configuration import insert_tweet