Tradițional, când un consumator nou intra sau părăsea un Consumer Group, protocolul Eager revoca forțat toate partițiile alocate tuturor consumatorilor, oprind complet procesarea (Stop-the-World). Protocolul modern Cooperative Sticky Assignor permite rebalansarea incrementală: consumatorii continuă să citească din partițiile neafectate fără nicio pauză.
Activarea strategiei CooperativeStickyAssignor în clientul Java
Properties props = new Properties();
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
props.put(ConsumerConfig.GROUP_ID_CONFIG, "grup-procesare-evenimente");
// Setarea strategiei cooperative:
props.put(ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG,
"org.apache.kafka.clients.consumer.CooperativeStickyAssignor");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Collections.singletonList("evenimente-utilizatori"));
Întrebări & Exemple de Cod:
Rebalansarea Consumatorilor în Kafka: Cooperative Sticky Assignor vs Eager ProtocolAi o nelămurire despre utilizarea comenzii
Rebalansarea Consumatorilor în Kafka: Cooperative Sticky Assignor vs Eager Protocolsau 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.