THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
bin/kafka-streams-application-reset.sh --application-id streams-wordcount --input-topics streams-file-input,streams1 –dry--dry-run ----Dry run to display the actions which will be performed when running Streams Reset Tool---- Following input topics offsets will be reset to beginning (for consumer group streams-wordcount) Topic - streams-file-input Following internal topics offsets will be reset to beginning (for consumer group streams-wordcount) Topic - streams-wordcount-Counts-repartition Topic - streams-wordcount-Counts-changelog Following internal topics will be deleted Topic - streams-wordcount-Counts-repartition Topic - streams-wordcount-Counts-changelog Following input topics are not found, will skip them Topic – streams1 |
...