You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: docs/streams/developer-guide/app-reset-tool.md
+45-47Lines changed: 45 additions & 47 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -63,55 +63,53 @@ If you are using **classic rebalance protocol** , run the classic application re
63
63
Invoke the application reset tool from the command line
64
64
65
65
Warning! This tool makes irreversible changes to your application. It is strongly recommended that you run this once with `--dry-run` to preview your changes before making them.
66
-
67
-
```bash
68
-
$ bin/kafka-streams-application-reset.sh
69
-
```
66
+
67
+
68
+
$ bin/kafka-streams-application-reset.sh
70
69
71
70
The tool accepts the following parameters:
72
-
73
-
```text
74
-
Option (* = required) Description
75
-
--------------------- -----------
76
-
* --application-id <String: id> REQUIRED: The Kafka Streams application ID
77
-
(application.id).
78
-
--bootstrap-server <String: server to The server(s) to connect to.
79
-
connect to> The broker list string in the form HOST1:PORT1,HOST2:PORT2.
80
-
(default: localhost:9092)
81
-
--by-duration <String: urls> Reset offsets to offset by duration from
82
-
current timestamp. Format: 'PnDTnHnMnS'
83
-
--config-file <String: file name> (Deprecated) Property file containing configs to be
84
-
passed to admin clients and embedded consumer.
85
-
This option will be removed in a future version.
86
-
Use --command-config instead.
87
-
--command-config <String: file name> Config properties file to be passed to admin clients
88
-
and embedded consumer.
89
-
--dry-run Display the actions that would be
90
-
performed without executing the reset
91
-
commands.
92
-
--from-file <String: urls> Reset offsets to values defined in CSV
93
-
file.
94
-
--input-topics <String: list> Comma-separated list of user input
95
-
topics. For these topics, the tool will
96
-
reset the offset to the earliest
97
-
available offset.
98
-
--internal-topics <String: list> Comma-separated list of internal topics
99
-
to delete. Must be a subset of the
100
-
internal topics marked for deletion by
101
-
the default behaviour (do a dry-run without
102
-
this option to view these topics).
103
-
--shift-by <Long: number-of-offsets> Reset offsets shifting current offset by
104
-
'n', where 'n' can be positive or
105
-
negative
106
-
--to-datetime <String> Reset offsets to offset from datetime.
107
-
Format: 'YYYY-MM-DDThh:mm:ss.sss'
108
-
--to-earliest Reset offsets to earliest offset.
109
-
--to-latest Reset offsets to latest offset.
110
-
--to-offset <Long> Reset offsets to a specific offset.
111
-
--force Force removing members of the consumer group
112
-
(intended to remove left-over members if
113
-
long session timeout was configured).
114
-
```
71
+
72
+
73
+
Option (* = required) Description
74
+
--------------------- -----------
75
+
* --application-id <String: id> REQUIRED: The Kafka Streams application ID
76
+
(application.id).
77
+
--bootstrap-server <String: server to The server(s) to connect to.
78
+
connect to> The broker list string in the form HOST1:PORT1,HOST2:PORT2.
79
+
(default: localhost:9092)
80
+
--by-duration <String: urls> Reset offsets to offset by duration from
81
+
current timestamp. Format: 'PnDTnHnMnS'
82
+
--config-file <String: file name> (Deprecated) Property file containing configs to be
83
+
passed to admin clients and embedded consumer.
84
+
This option will be removed in a future version.
85
+
Use --command-config instead.
86
+
--command-config <String: file name> Config properties file to be passed to admin clients
87
+
and embedded consumer.
88
+
--dry-run Display the actions that would be
89
+
performed without executing the reset
90
+
commands.
91
+
--from-file <String: urls> Reset offsets to values defined in CSV
92
+
file.
93
+
--input-topics <String: list> Comma-separated list of user input
94
+
topics. For these topics, the tool will
95
+
reset the offset to the earliest
96
+
available offset.
97
+
--internal-topics <String: list> Comma-separated list of internal topics
98
+
to delete. Must be a subset of the
99
+
internal topics marked for deletion by
100
+
the default behaviour (do a dry-run without
101
+
this option to view these topics).
102
+
--shift-by <Long: number-of-offsets> Reset offsets shifting current offset by
103
+
'n', where 'n' can be positive or
104
+
negative
105
+
--to-datetime <String> Reset offsets to offset from datetime.
106
+
Format: 'YYYY-MM-DDThh:mm:ss.sss'
107
+
--to-earliest Reset offsets to earliest offset.
108
+
--to-latest Reset offsets to latest offset.
109
+
--to-offset <Long> Reset offsets to a specific offset.
110
+
--force Force removing members of the consumer group
111
+
(intended to remove left-over members if
112
+
long session timeout was configured).
115
113
116
114
Consider the following as reset-offset scenarios for `input-topics`:
0 commit comments