Hi Everyone, Started a thread to discuss KIP-1095: Kafka Canary Isolation (link <https://cwiki.apache.org/confluence/display/KAFKA/KIP-1095%3A+Kafka+Canary+Isolation> )
Canary isolation aims to improve Kafka service quality by reducing blast radius of bad Kafka deployment to a small portion of traffic. The key solution including 1. define canary broker (a new broker metadata - pod is introduced) 2. define canary partition - a small portion of partitions placed on canary brokers 3. producer/consumer use topic metadata to route and isolate canary traffic in canary With canary isolation, it's expected to detect deployment caused failure in canary and rollback before it impact whole production. Regards,