Knative Kafka

1. Install requirements

• Docker
• Minikube
• Knative CLI

Install minikube and kn.

brew install minikube
brew install kn

Ensure Docker is running. Then start minikube.

minikube start --memory=4096

Make sure you are using minikube from kubectl:

kubectl config current-context

This should print minikube. Open the dashboard.

minikube dashboard

Your dashboard should show four namespaces:

• default
• kube-node-lease
• kube-public
• kube-system
• kubernetes-dashboard

Make sure that all pods are in a "ready" state. (You can do this from the dashboard too.)

kubectl get pods --all-namespaces

2. Install yaml files

Install the first 5 yaml files

kubectl apply -f yamls/1_eventing-crds.yaml
kubectl apply -f yamls/2_eventing-core.yaml
kubectl apply -f yamls/3_eventing-kafka-controller.yaml
kubectl apply -f yamls/4_eventing-kafka-source.yaml
kubectl apply -f yamls/5_mt-channel-broker.yaml

Install Kafka

kubectl create namespace kafka

kubectl create -f 'https://strimzi.io/install/latest?namespace=kafka' -n kafka

kubectl apply -f https://strimzi.io/examples/latest/kafka/kafka-persistent-single.yaml -n kafka 

Watch the dashboard for stuff to turn green, or execute

kubectl wait kafka/my-cluster --for=condition=Ready --timeout=300s -n kafka

Link Kafka

Follow the remaining steps to install the kafka source:

kubectl apply -f yamls/10_kafka_topic.yml
kubectl apply -f yamls/11_event_display.yaml
kubectl apply -f yamls/12_event_source.yaml