Config

Reset streams application

Reset topologi (kafka strømmen), application-id er laget av nais og finnes som env-var i poden

kubectl exec -i deploy/kafka-cli -- kafka-streams-application-reset \
 --application-id aap.vedtak_stream_ \
 --input-topics aap.medlem.v1

Show consumers in a group

kubectl exec -i deploy/kafka-cli -- kafka-consumer-groups \
 --group aap.vedtak_stream_ \
 --describe

List consumer groups

kubectl exec -i deploy/kafka-cli -- kafka-consumer-groups --list

Interactive shell commands

Use scripts from /scripts to include brokers and aiven config, e.g:

kubectl exec -i deploy/kafka-cli -- kafka-consumer-groups --list

kubectl exec -i deploy/kafka-cli -- kafka-topics --describe --topic aap.soknad-sendt.v1