Go Kafka App

This Go app demonstrates Kafka messaging usiing k8s(minikube) + skaffold

Prerequisites

Go (Golang) installed: https://golang.org/dl/
Accessible Kafka cluster or instance.
Docker and Docker Compose (optional)
Skaffold (optional)

Run Kafka Locally

Run with Docker Compose

docker-compose up

Run with Skaffold

skaffold run  --port-forward

Run App

Install dependencies: go mod download
Update Kafka connection info for producers and consumers.
Run: go run main.go

Customization

Modify message processing in Kafka consumer.
Adjust Kafka topic and format.
Handle errors, add features.

Resources

License

MIT License. See LICENSE.

Fork, enhance, and adapt. Questions/improvements? Create an issue or pull request. Happy coding!