У нас есть приложение Kafka Streams, которое испытывает странное поведение. Случайно, когда задание убивается и перезапускается, группа потребителей сбрасывает свои смещения в самое раннее время, а все старые записи обрабатываются повторно.
Есть что-то конкретное, что нужно сделать, и нам этого не хватает?