kafka-replay-cli 0.1.1

A CLI tool to dump and replay Kafka messages using Parquet

kafka-replay-cli

A lightweight, local-first CLI tool for dumping and replaying Kafka messages using Parquet files. Built for observability, debugging, and safe testing of event streams.

---

Features

• Dump Kafka topics into Parquet files
• Replay messages from Parquet back into Kafka
• Filter replays by timestamp range and key
• Optional throttling during replay (simulate timing)

---

📦 Installation

Install from PyPI:

pip install kafka-replay-cli

---

Usage

Dump messages from a topic to Parquet

kafka-replay-cli dump \
  --topic test-topic \
  --output test.parquet \
  --bootstrap-servers localhost:9092 \
  --max-messages 1000

Replay messages from a Parquet file

kafka-replay-cli replay \
  --input test.parquet \
  --topic replayed-topic \
  --bootstrap-servers localhost:9092 \
  --throttle-ms 100

Add timestamp and key filters

kafka-replay-cli replay \
  --input test.parquet \
  --topic replayed-topic \
  --start-ts "2024-01-01T00:00:00Z" \
  --end-ts "2024-01-02T00:00:00Z" \
  --key-filter "user-123"

---

🔍 Querying Kafka Messages with DuckDB

You can run SQL directly on dumped Parquet files using the query command:

kafka-replay-cli query \
  --input test.parquet \
  --sql "SELECT timestamp, CAST(key AS VARCHAR) FROM input WHERE CAST(value AS VARCHAR) LIKE '%login%'"

⚠️ Note: Kafka key and value fields are stored as binary (BLOB) in the Parquet file for full fidelity.
To search or filter them using LIKE, you must explicitly cast them to VARCHAR.

---

Output to file:

kafka-replay-cli query \
  --input test.parquet \
  --sql "SELECT key FROM input" \
  --output results.json

---

📜 License

MIT

---

🙋‍♂️ Maintainer

Konstantinas Mamonas
Feel free to fork, open issues, or suggest improvements.