Мне нужно создать настройку Kafka, в которой в начале каждого дня все сообщения в теме должны быть удалены, а ее смещение сброшено до 0.
Я попытался сделать это, установив log.retentionдо 1 дня, но это не сработало.Я также бежал kafka-delete-records.Он удалил все сообщения, но kafka.tools.GetOffsetShell все еще дал мне последнее смещение.Я хочу, чтобы оно равнялось 0.
Кроме того, я явно не устанавливаю группу потребителей.Они внутренние, как _confluent-ksql-default_transient_929377247691956102_1560973030312.Поэтому я хочу, чтобы смещение для темы было сброшено до 0 независимо от группы потребителей.