heartbeat.interval.ms în Consumatorul Kafka în Apache Kafka

Frecvența cu care firul de fundal al consumatorului expediază semnale de viață către coordonatorul de grup.

Sintaxă
props.put(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG, 15000); // 15 secunde

Regula de aur pentru heartbeat.interval.ms

Valoarea pentru heartbeat.interval.ms trebuie configurată întotdeauna la cel mult o treime (1/3) din valoarea parametrului session.timeout.ms. Aceasta asigură că dacă un pachet de heartbeat este pierdut din cauza unei congestii temporare de rețea, mai rămân cel puțin 2 șanse de retransmisie înainte ca brokerul să declare consumatorul căzut.

Exemplu Concret: Configurare proporțională
Properties props = new Properties();
props.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 45000);   // 45 secunde
props.put(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG, 15000); // 15 secunde
Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: heartbeat.interval.ms în Consumatorul Kafka

Ai o nelămurire despre utilizarea comenzii heartbeat.interval.ms în Consumatorul Kafka sau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!

💬

Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!

Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.

Comunitate Adaugă o întrebare sau distribuie un cod

Moderare & Siguranță:

Pentru a menține calitatea și securitatea informațiilor, fiecare întrebare sau fragment de cod/prompt este analizat (manual sau prin moderare asistată de AI) înainte de publicare.