Git-Mirrors/backend-and-orchestration-toolkit
1
0
Fork 0
mirror of https://github.com/autistic-symposium/backend-and-orchestration-toolkit.git synced 2025-06-08 23:13:08 -04:00
Code Issues Projects Releases Packages Wiki Activity

Create topics-cheatsheet.md

Browse source
This commit is contained in:
bt3gl 2022-03-23 10:52:34 +00:00 • committed by GitHub
parent 052fb6d388
commit 1b948da94c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 52 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

52
kafka-and-streaming/topics-cheatsheet.md Normal file
View file

@ -0,0 +1,52 @@
## Kafka Topics Cheatsheet
#### Create a temporary interactive container
```
kubectl exec -it -n <ns> kafka-tools -- bash
```
### List consumer groups
```
kafka-consumer-groups --bootstrap-server "$KAFKA_BOOTSTRAP_SERVERS" --list
```
### Inspect a consumer group
```
kafka-consumer-groups --bootstrap-server "$KAFKA_BOOTSTRAP_SERVERS" --describe --group GROUP
```
### Remove Lag - Reset a consumer group to latest
Reset offsets to latest (speeds up reset in Grafana):
```
kafka-consumer-groups --bootstrap-server "$KAFKA_BOOTSTRAP_SERVERS" --group GROUP \
--reset-offsets --topic TOPIC --to-earliest --dry-run
```
### Delete a Consumer Group
Reset offsets to latest (speeds up reset in Grafana):
```
kafka-consumer-groups --bootstrap-server "$KAFKA_BOOTSTRAP_SERVERS" --group GROUP \
--reset-offsets --topic TOPIC --to-earliest --dry-run
```
### Delete group.
```
kafka-consumer-groups --bootstrap-server "$KAFKA_BOOTSTRAP_SERVERS" --group GROUP --delete
Shift consumer back 10k
```
### Specify the partition to shift, else all will be shifted
```
kafka-consumer-groups --bootstrap-server "$KAFKA_BOOTSTRAP_SERVERS" --group GROUP \
--topic TOPIC:0 --reset-offsets --shift-by -10000
```