diff options
| author | Priyansh <[email protected]> | 2021-12-28 22:03:04 -0500 |
|---|---|---|
| committer | Priyansh <[email protected]> | 2021-12-28 22:03:04 -0500 |
| commit | b18c9a814c11f4d66f7a460d2179087805e034a1 (patch) | |
| tree | 0525f32909fa24d83fd7fba6e3bacdc0d526b92b /producer.py | |
| parent | 101072ea24cc0670bbd689d039d5144fa5216a4b (diff) | |
| download | KafkaPySpark-main.tar.xz KafkaPySpark-main.zip | |
Diffstat (limited to 'producer.py')
| -rw-r--r-- | producer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/producer.py b/producer.py index b965491..252a26b 100644 --- a/producer.py +++ b/producer.py @@ -33,7 +33,7 @@ class TwitterStreamer(): listener = ListenerTS() auth = self.twitterAuth.authenticateTwitterApp() stream = Stream(auth, listener) - stream.filter(track=["Christmas"], stall_warnings=True, languages= ["en"]) + stream.filter(track=["Covid"], stall_warnings=True, languages= ["en"]) class ListenerTS(StreamListener): |