README

Content locked

The catalog is public. Reading this content requires approved access.

P7 (3% of grade): Kafka, Stock Price Data

Overview

Clarifications/Corrections

AI Usage

Setup

Price Generation (price_generator.py)

Running in Background

Part 1: Kafka Producer (producer.py)

Topic Initialization

Reading records from database

Sending price reports via Kafka

Running in Background

Part 2: Kafka Debug Consumer (debug.py)

Part 3: Kafka Consumer (consumer.py)

Part 4: Consumer Crash Recovery

Checkpointing

Restart

Reading Parquet Files

Submission

Testing