kafka-backup-demos

A collection of runnable demos for OSO Kafka Backup - a high-performance Kafka backup and restore tool with point-in-time recovery.

Quick Start

# Start the demo environment (default: Kafka 3.7.1)
docker compose up -d

# Or start with a specific Kafka version
KAFKA_VERSION=4.0.0 docker compose up -d

# Wait for services to be ready (~15 seconds)
docker compose logs kafka-setup

# Run any demo (see list below)
cd cli/backup-basic
./demo.sh

Prerequisites

• Docker and Docker Compose v2+
• 4GB+ available RAM
• For Java demos: JDK 17+ and Maven
• For Python demo: Python 3.9+

Demo Environment

The docker-compose.yml provides:

Service	Description	Port
kafka-broker-1	Apache Kafka (KRaft mode)	9092
minio	S3-compatible object storage	9000 (API), 9001 (Console)
kafka-cli	Kafka CLI tools container	-
kafka-backup	OSO Kafka Backup CLI	-

Monitoring Services (use --profile monitoring):

Service	Description	Port
klag	Kafka Consumer Lag Exporter	8888
prometheus	Metrics collection	9091
grafana	Metrics visualization	3000

Supported Kafka Versions

Version	Image	Notes
3.7.1	apache/kafka:3.7.1	Default, LTS
3.8.0	apache/kafka:3.8.0
3.9.0	apache/kafka:3.9.0
4.0.0	apache/kafka:4.0.0	ZooKeeper removed
4.1.0	apache/kafka:4.1.0	Latest stable

Pre-configured topics: orders, payments, events, orders_enriched, large_messages, benchmark-data

MinIO Console: http://localhost:9001 (minioadmin/minioadmin)

Demos

CLI Demos

Demo	Path	Feature	Difficulty
Offset State Verification	cli/offset-testing/	Consumer offset snapshot & inspection	Beginner
Basic Backup & Restore	cli/backup-basic/	Full backup/restore cycle to MinIO	Beginner
Snapshot Backup	cli/snapshot-backup/	Consistent point-in-time snapshots (stop_at_current_offsets)	Beginner
Validation & Evidence	cli/validation-evidence/	Deep integrity checks & compliance evidence	Intermediate
Continuous Incremental	cli/continuous-incremental/	Resumable incremental backups with offset tracking	Intermediate
Large Messages	cli/large-messages/	Handling large payloads with compression	Intermediate
Offset Mapping Report	cli/offset-report/	JSON offset mapping & analysis	Intermediate
Consumer Lag Monitoring	cli/klag-monitoring/	Klag + Prometheus lag monitoring	Intermediate
PITR + Rollback	cli/pitr-rollback-e2e/	End-to-end point-in-time recovery	Advanced

Java Demos

Demo	Path	Feature	Difficulty
Kafka Streams PITR	java-streams/pitr-restore/	Streams app point-in-time recovery	Intermediate
Offset Reset Verify	java-streams/offset-reset-verify/	Bulk offset reset correctness	Intermediate
Stateful Join Restore	java-streams/stateful-join-restore/	Stateful Streams DR: rebuild, changelog fast-restore, hot-backup pitfall	Advanced

Spring Boot Demos

Demo	Path	Feature	Difficulty
Backup & Restore Flow	springboot/backup-restore-flow/	E2E backup/restore with Spring Streams	Intermediate
Producer/Consumer PITR	springboot/producer-consumer/	Microservice pair with PITR	Advanced

Python Demo

Demo	Path	Feature	Difficulty
Backup & Restore	python/backup-restore-py/	Language-agnostic validation	Beginner

Benchmarks

Demo	Path	Feature	Difficulty
Performance Benchmarks	benchmarks/	Throughput, pipelined flush, compression, latency testing	Intermediate

Kubernetes Operator Demos

Demo	Path	Feature	Difficulty
kafka-backup-operator Retention Behavior	operators/kafka-backup-operator-retention/	Current retention model and external cleanup pattern	Beginner
Strimzi Backup Operator Safety Controls	operators/strimzi-backup-operator-safety/	Host aliases, suspend, selected restore, service accounts, backoff limits	Intermediate

Running kafka-backup Commands

# Using docker compose
docker compose --profile tools run --rm kafka-backup backup --config /config/backup.yaml
docker compose --profile tools run --rm kafka-backup restore --config /config/restore.yaml

# Using kafka-cli for Kafka commands
docker compose --profile tools exec kafka-cli kafka-console-producer.sh --bootstrap-server kafka-broker-1:9092 --topic orders
docker compose --profile tools exec kafka-cli kafka-console-consumer.sh --bootstrap-server kafka-broker-1:9092 --topic orders --from-beginning

Core Features Demonstrated

1. Topic Backup & Restore - Full backup to S3/MinIO with restore validation
2. Snapshot Backups - Consistent point-in-time snapshots with stop_at_current_offsets
3. Continuous Incremental Backups - Resumable backups with offset tracking across restarts
4. Point-in-Time Recovery (PITR) - Millisecond-precision time-window filtering
5. Validation & Compliance - Deep integrity checks and audit evidence generation
6. Consumer Offset Management - Snapshots, rollback, and bulk reset
7. Offset Mapping - JSON reports for migration planning
8. Large Message Handling - Compression (zstd, lz4, gzip) for large payloads
9. Pipelined Segment Flush - v0.15.8 backup performance improvement for compressed segment uploads
10. Operator Safety Controls - Kubernetes CRD validation for recent operator behavior fixes
11. Three-Phase Restore - Solving the offset space discontinuity problem
12. Stateful Kafka Streams Restore - Rebuild-from-inputs and changelog fast-restore for joined/aggregating topologies, plus the hot-backup consistency pitfall

Cleanup

# Stop all services
docker compose down

# Remove all data (including MinIO storage)
docker compose down -v

Multi-Version Testing

Test kafka-backup compatibility across multiple Kafka versions:

# Test all supported versions
./test-versions.sh

# Test specific versions
./test-versions.sh 4.0.0 4.1.0

# Run quick smoke test (default)
./test-versions.sh --quick

# Run full test suite
./test-versions.sh --full

# Run benchmarks per version
./test-versions.sh --benchmark 4.0.0

Results are saved to test-results/ as markdown reports.

Documentation

• Demo Index - Complete demo reference
• Kafka Streams Restore Runbook - Capability matrix and DR runbooks for stateful Streams apps
• Troubleshooting - Common issues and solutions
• Known Issues - Current limitations

Related

• kafka-backup Repository
• kafka-backup Documentation