timho102003 / log_analysis_kafka_spark_stream Goto Github PK
View Code? Open in Web Editor NEWThe goal of this application is to ingest a large log file into a Kafka producer using the `confluent_kafka` Python library, process the ingested data with Spark Streaming, and perform data wrangling operations on the streamed data.