b7f3b816ba
Implements plan §13.13 Kafka sink using rdkafka crate.
Changes:
- Add rdkafka 0.37 as optional dependency with tokio feature
- Add kafka-sink feature flag to Cargo.toml
- Implement CdcManager::flush_kafka with:
- Topic pattern: miroir.cdc.{index}
- Partition key: primary_key (preserves per-key ordering)
- At-least-once delivery via acks=all
- event_id in record headers for consumer-side dedup
- Connection pooling per sink URL
- Producer timeout: 30s message timeout, 60s delivery timeout
- Add stub function when kafka-sink feature disabled
- Add unit tests for Kafka sink type serialization
Closes: miroir-uhj.13.3
Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
|
||
|---|---|---|
| .. | ||
| miroir-core | ||
| miroir-ctl | ||
| miroir-proxy | ||