dexblog.ro
Acces rapid: Învață AI Învață Programare Specificații Dispozitive Comparații
KAFKA Toate comenzile Apache Kafka

session.timeout.ms în Consumatorul Kafka în Apache Kafka

Configurații critice pentru Consumator Kafka 0.8+ Q&A / Distribuie cod

Timpul maxim permis fără semnale de heartbeat înainte ca brokerul să declare consumatorul decedat.

Sintaxă 
props.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 45000); // 45 secunde

Separarea dintre heartbeat și procesare

Clientul Java modern are un fir separat de execuție în fundal (Heartbeat Thread) care transmite semnale periodice de viață către broker. Dacă instanța de consumator se prăbușește brusc (Out Of Memory sau oprirea mașinii virtuale), brokerul așteaptă scurgerea duratei session.timeout.ms (implicit 45 secunde) înainte de a declanșa rebalansarea.

Exemplu Concret: Detectare mai rapidă a căderilor
Properties props = new Properties();
props.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 30000); // 30 secunde
props.put(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG, 10000); // 10 secunde (1/3 din session.timeout)
Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: session.timeout.ms în Consumatorul Kafka

Ai o nelămurire despre utilizarea comenzii session.timeout.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.