This is the multi-page printable view of this section. Click here to print.

Return to the regular view of this page.

Actions

Learn how to use the actions provided by the Extension Provider for Apache Kafka.

Here, you will find the list of actions provided by the Extension Provider for Apache Kafka.

Apache Kafka Action

More information:

1 - KafkaConsumerGroupsResetOffsets

Learn how to use the KafkaConsumerGroupsResetOffsets action.

The KafkaConsumerGroupsResetOffsets action allows resetting offsets of consumer group. It supports one consumer group at the time, and group should be in EMPTY state.

Usage (CLI)

Usage: Execute the action. jikkou action KafkaConsumerGroupsResetOffsets execute [-hV] [--all] [--dry-run] [--to-earliest] [--to-latest] [--group=PARAM] [--logger-level=<level>] [-o=<format>] [--to-datetime=PARAM] [--to-offset=PARAM] [--excludes=PARAM]... [--groups=PARAM]... [--includes=PARAM]... --topic=PARAM [--topic=PARAM]... DESCRIPTION: Reset offsets of consumer group. Supports multiple consumer groups, and groups should be in EMPTY state. You must choose one of the following reset specifications: to-datetime, by-duration, to-earliest, to-latest, to-offset. OPTIONS: --all Specifies to act on all consumer groups. --dry-run Only show results without executing changes on Consumer Groups. --excludes=PARAM List of patterns to match the consumer groups that must be excluded from the reset-offset action. --group=PARAM The consumer group to act on. --groups=PARAM The consumer groups to act on. -h, --help Show this help message and exit. --includes=PARAM List of patterns to match the consumer groups that must be included in the reset-offset action. --logger-level=<level> Specify the log level verbosity to be used while running a command. Valid level values are: TRACE, DEBUG, INFO, WARN, ERROR. For example, `--logger-level=INFO` -o, --output=<format> Prints the output in the specified format. Allowed values: JSON, YAML (default YAML). --to-datetime=PARAM Reset offsets to offset from datetime. Format: 'YYYY-MM-DDTHH:mm:SS.sss' --to-earliest Reset offsets to earliest offset. --to-latest Reset offsets to latest offset. --to-offset=PARAM Reset offsets to a specific offset. --topic=PARAM The topic whose partitions must be included in the reset-offset action. -V, --version Print version information and exit.

Examples

Reset Single Consumer Group to the earliest offsets

jikkou action kafkaconsumergroupresetoffsets execute \ --group my-group \ --topic test \ --to-earliest

(output)

--- kind: "ApiActionResultSet" apiVersion: "core.jikkou.io/v1" metadata: labels: {} annotations: configs.jikkou.io/to-earliest: "true" configs.jikkou.io/group: "my-group" configs.jikkou.io/dry-run: "false" configs.jikkou.io/topic: - "test" results: - status: "SUCCEEDED" errors: [] data: apiVersion: "kafka.jikkou.io/v1beta1" kind: "KafkaConsumerGroup" metadata: name: "my-group" labels: kafka.jikkou.io/is-simple-consumer: false annotations: {} status: state: "EMPTY" members: [] offsets: - topic: "test" partition: 1 offset: 0 - topic: "test" partition: 0 offset: 0 - topic: "test" partition: 2 offset: 0 - topic: "--test" partition: 0 offset: 0 coordinator: id: "101" host: "localhost" port: 9092

Reset All Consumer Groups to the earliest offsets

jikkou action kafkaconsumergroupresetoffsets execute \ --all \ --topic test \ --to-earliest