Kafka 0.8 için nispeten az sayıda dokümantasyon, broker'larda mevcut konuların, bölümlerin ve kopyaların dengelenmesi için beklenen davranıştan bahsetmiyor. Daha açık söylemek gerekirse, bir aracının gelmesi ve bir aracının (lider ya da değil) çarpışması durumunda beklenen davranış nedir?Kafka'daki brokerler için yeniden dengeleme 0.8
Teşekkürler.
Bu 2 vakayı bir süre önce test ettim ve ağır yük altında değil. 2 brokerden oluşan bir kümede 2 bölümlük replikasyon faktörü ile bir konuya eşzamanlı olarak 10k mesajlar (sadece küçük bir dize) gönderen bir yapımcım var. 2 tüketici var. Her bileşen ayrı bir makinede konuşlandırılmıştır. Ne gözlemledim geçerli:
günü normal çalışma: komisyoncu 1 bölümünde bölüm 1 ve çoğaltma lideridir 2. komisyoncu 2 lider bölümü 1. bölüm 2. ve çoğaltma olduğunu içine bir komisyoncu 3 getir Küme, bölümlerde otomatik olarak yeniden dengelemeyi başlatmaz.
Aracı yeniden canlandırmada (yeniden başlatmadan çöktü): yeniden dengeleme, üretici ve tüketicilere karşı şeffaftır. Yeniden başlatma aracı ilk önce günlüğü çoğaltır ve ardından kendini kullanılabilir hale getirir. herhangi bir komisyoncu üzerinde öldürmek tarafından simüle -9: broker üzerinde
(lider veya değil) çöktü. Üretici ve tüketiciler, öldürülen aracının ZK'sindeki geçici düğümün süresi dolana kadar donduruyor. Bundan sonra, işlemler normal olarak devam eder.