| Mode | Name | Size | |
|---|---|---|---|
| -rw-r--r-- | .gitignore | 1810 | logplain |
| -rw-r--r-- | LICENSE | 1065 | logplain |
| -rw-r--r-- | consumer.py | 469 | logplain |
| d--------- | kafka | 265 | logplain |
| -rw-r--r-- | producer.py | 1350 | logplain |
| -rw-r--r-- | requirements.txt | 42 | logplain |
![]() |
index : KafkaPySpark | |
| Fetching tweets and integrating it with Kafka and PySpark. |
| aboutsummaryrefslogtreecommitdiff |
| Mode | Name | Size | |
|---|---|---|---|
| -rw-r--r-- | .gitignore | 1810 | logplain |
| -rw-r--r-- | LICENSE | 1065 | logplain |
| -rw-r--r-- | consumer.py | 469 | logplain |
| d--------- | kafka | 265 | logplain |
| -rw-r--r-- | producer.py | 1350 | logplain |
| -rw-r--r-- | requirements.txt | 42 | logplain |