Refer to this article to learn more about this: LINK
-
Apply all the deployment files listed in deployments folder:
Kubectl apply -f <deployment_file> -
exec into kafka-deployment pod (or your kafka service)
kubectl exec -it <kafka-service-pod> -- /bin/bash -
Send messages (or you can write your own producer code)
kafka-console-producer --broker-list localhost:9092 --topic <topic-name>
