intermediate
Producer
Делайте producers explicit про message schema, keys, durability expectations, retry policy, observability и publish failure handling.
Producers задают payload schema, keys для partitioning, durability expectations (acks), compression и failure handling при publish failure. Observability: publish latency, error rate и serialization failures.
Компромисс: сильнее durability (wait all replicas) против ниже latency и выше throughput.
На интервью: Kafka producer acks для payment events vs metrics; idempotent producer settings.
Типовые ошибки: huge payloads; нет schema version; fire-and-forget без monitoring; неверный partition key ломает ordering.
Чеклист:
- Version schemas и compatibility.
- Keys для ordering и load balance.
- Acks и retries с idempotency.
- Метрики failed publishes и buffer saturation.