Considera que há 4 consumidores (A,B,C,D) . C é fechado chamando close(). Idealmente as Partições atribuídas a,B e D devem ser revogada antes de atribuir qualquer novo as partições, mas Uma está ficando revogada e a obtenção de novas partições e, em seguida, B está ficando revogada. Por que esse comportamento é observado ? Como isso pode ser resolvido.
0
Em Kafka 2.4 um novo incremental reequilíbrio protocolo foi adicionado, que não revogar todas as partições durante um reequilíbrio: https://www.confluent.io/blog/cooperative-rebalancing-in-kafka-streams-consumer-ksqldb/