Se eu tiver um Tópico com retenção de 7 dias, com a retenção de offsets definida para 1 dia posso acabar na situação em que por grupo de consumidores, se reiniciado após 2 dias, reprocessaria as mensagens porque o offset expirou. (Conforme: https://anshita-singh.medium.com/kafka-message-retention-vs-committed-offset-retention-c2359e3f9c5b )
O que acontece ao contrário? Se eu tiver uma retenção de tópico de 1 dia e uma retenção de deslocamento de 7 dias, quando o consumidor Kafka iniciar, ele quer ler de uma posição que ainda não existe. Kafka lida com isso com elegância?...ou será que, ao publicar mensagens sobre o tópico, elas não serão lidas pelo consumidor porque sua posição está em um futuro distante?
Para um novo grupo de consumidores ou quando uma compensação fora dos limites for solicitada, a
auto.offset.resetpropriedade entrará em vigor. Por padrão, o consumo começará a partir do final do tópico.No entanto, “ainda” realmente não faz sentido. As compensações estão aumentando constantemente. Você teria que solicitar explicitamente um valor maior do que o existente