เมื่อสมาชิกของ Kafka Consumer มีการเปลี่ยนแปลง จะเกิดการ repartition

ดังนั้นเมื่อดีพลอยแอปพลิเคชัน ระหว่างกระบวนการหยุด/รีสตาร์ต จะเกิดการ repartition 2 ครั้ง

ในระหว่างกระบวนการ repartition จะไม่สามารถดึงข้อความมาได้ชั่วคราว จึงทำให้เกิดความล่าช้าในการประมวลผล

จึงเป็นบทความเกี่ยวกับกลยุทธ์การแก้ปัญหาเพื่อรับมือกับเรื่องนี้

  • กระบวนการที่เกิด partition rebalancing

  • การตั้งค่าเพื่อลด rebalancing ให้เหลือน้อยที่สุด และข้อควรพิจารณาเมื่อดีพลอย

ยังไม่มีความคิดเห็น

ยังไม่มีความคิดเห็น