Here, you will find the list of actions provided by the Extension Provider for Apache Kafka.
Apache Kafka Action
More information:
This is the multi-page printable view of this section. Click here to print.
Here, you will find the list of actions provided by the Extension Provider for Apache Kafka.
More information:
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:
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.
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
jikkou action kafkaconsumergroupresetoffsets execute \
--all \
--topic test \
--to-earliest
This section describes the KafkaShareGroupsResetOffsets action, used to reset the
Share-Partition Start Offset (SPSO) of one or more Kafka share groups.
group.share.enable=true).You must choose one of the following reset specifications: to-earliest, to-latest, to-offset,
or delete-offsets.
| Option | Description |
|---|---|
--group | The share group to act on. |
--groups | The share groups to act on. |
--all | Act on all share groups. |
--topic | Topics to include. Each entry is topic (all partitions) or topic:partition. |
--to-earliest | Reset offsets to the earliest offset. |
--to-latest | Reset offsets to the latest offset. |
--to-offset | Reset offsets to a specific offset. |
--delete-offsets | Delete the share-partition offsets for the given topics. |
--includes | Patterns of share groups to include. |
--excludes | Patterns of share groups to exclude. |
--dry-run | Only show results without executing changes. |
Reset a single share group to the earliest offset for a topic:
$ jikkou action KafkaShareGroupsResetOffsets execute \
--group my-share-group \
--topic my-topic \
--to-earliest
Delete the share-partition offsets for a topic:
$ jikkou action KafkaShareGroupsResetOffsets execute \
--group my-share-group \
--topic my-topic \
--delete-offsets