Как мне правильно создать новую группу потребителей и сбросить смещение для всех тем в Kafka CLI? ⇐ JAVA

[Anonymous]

У меня на платформе Kafka более 1000 тем, каждая тема содержит данные за 14 дней, около 1,2 миллиарда сообщений.
Я создал новую группу потребителей: groupA и выполнил команду для сброса смещения.

Код: Выделить всё

sh kafka-consumer-groups.sh --reset-offsets --execute --to-datetime "2023-05-03T00:00:00.000" --group groupA --bootstrap-server kfk-data- 001:9092,kfk-data-002:9092,kfk-data-003:9092 --all-topics

Но это не сработало так, как я ожидал, я попытался использовать данные извлечения группы A в Java, и она по-прежнему использует начальные данные для каждой темы.
Как мне правильно создать группу и сбросить смещение для всех тем?>

Подробнее здесь: https://stackoverflow.com/questions/761 ... t-from-all