diff options
| author | Priyansh <[email protected]> | 2021-12-25 02:34:29 -0500 |
|---|---|---|
| committer | Priyansh <[email protected]> | 2021-12-25 02:34:29 -0500 |
| commit | 5ef3baaf6575a4ad3b4e37897637d87af1af418a (patch) | |
| tree | d8346e19c5d83d8e28580c2c571e94e2fa9b8e1f /pySparkExample.py | |
| parent | 06b51f0c8e081c3e4120aef51c394662ea15a2a3 (diff) | |
| download | KafkaPySpark-5ef3baaf6575a4ad3b4e37897637d87af1af418a.tar.xz KafkaPySpark-5ef3baaf6575a4ad3b4e37897637d87af1af418a.zip | |
Added Database Insertion Script + Kafka Consumer stop if no message received in 3 seconds
Diffstat (limited to 'pySparkExample.py')
0 files changed, 0 insertions, 0 deletions