# Kafka

`failed/` contains my first failed attempt. 
* I think I was following [this](https://levelup.gitconnected.com/how-to-deploy-apache-kafka-with-kubernetes-9bd5caf7694f)
* First issue is that I had to replace the zookeeper ip in kafka2, but even after, there were resolution issues.

## Strimzi

Seems like a reasonable way to do it.

[Quickstart (unfortunately not for microk8s)](https://strimzi.io/quickstarts/)

```
kubectl create namespace kafka
curl -o 1.strimzi.yaml 'https://strimzi.io/install/latest?namespace=kafka'
kubectl create -f 1.strimzi.yaml -n kafka
# See quickstart for some ways to watch it deploy
curl -o 2.single.yaml 'https://strimzi.io/examples/latest/kafka/kafka-persistent-single.yaml'
# Edited and changed to mbox-cluster
kubectl apply -f 2.single.yaml -n kafka
kubectl wait kafka/mbox-cluster --for=condition=Ready --timeout=300s -n kafka 
# Lots of errors in logs, but it settles.
```

Test with a producer:

```
# Shell 1: producer
kubectl -n kafka run kafka-producer -ti --image=quay.io/strimzi/kafka:0.35.1-kafka-3.4.0 --rm=true --restart=Never -- bin/kafka-console-producer.sh --bootstrap-server mbox-cluster-kafka-bootstrap:9092 --topic my-topic
# Shell 2: Consumer
kubectl -n kafka run kafka-consumer -ti --image=quay.io/strimzi/kafka:0.35.1-kafka-3.4.0 --rm=true --restart=Never -- bin/kafka-console-consumer.sh --bootstrap-server mbox-cluster-kafka-bootstrap:9092 --topic my-topic --from-beginning
```

Awesome.

Delete everything:

```
kubectl -n kafka delete $(kubectl get strimzi -o name -n kafka)
kubectl delete -f 1.strimzi.yaml -n kafka
```