Config

Reset streams application

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

kafka.cli pod må deployes med aiven secret som har rettigheter på partisjonen. Det vil si aiven secret til streams appen. F.eks. aiven-nom-orgenhet-eventsrc-to-state-senon7u8

kubectl exec -i deploy/kafka-cli -- kafka-streams-application-reset --application-id nom-orgenhet-eventsrc-to-state --input-topics nom.orgenhet-eventsource

List consumer groups

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

Show consumers in a group

kubectl exec -i deploy/kafka-cli -- kafka-consumer-groups --group nom-api-849c455c4-sg9q2 --describe

Describe kafka topic

kubectl exec -i deploy/kafka-cli -- kafka-topics --describe --topic org.nom.ressurs-eventsource

Delete records i kafka topic

‼️ Dette fungerer ikke. kafka-cli har ikke rettighetene til å gjøre dette

NB! Flere steg.

1. Lag json fil for sletting.
   Sett riktig topic, og offset å slette frem til. Offset = -1 er slett alt
2. Kopier den inn i kafka-cli pod
3. Dobbeltsjekk slette-filen i pod'en
4. Kjør slette commando

Se også Option 2 i https://www.oak-tree.tech/blog/kafka-admin-remove-messages og https://stackoverflow.com/questions/46209666/how-do-i-delete-clean-kafka-queued-messages-without-deleting-topic

kafka.cli pod må deployes med aiven secret som har rettigheter på partisjonen. F.eks. gi org-kafka-manger readwrite på topic, og bruk denne appens k8s aiven secret (f.eks. aiven-org-kafka-manager-cg37ax1v)

echo '{"partitions": [{"topic": "mytest", "partition": 0, "offset": -1}], "version":1 }' > topic.json  

kubectl cp topic.json kafka-cli-7954b679c6-cqpdw:/tmp

kubectl exec -i deploy/kafka-cli -- cat /tmp/topic.json  

kubectl exec -i deploy/kafka-cli -- kafka-delete-records --offset-json-file /tmp/topic.json