A simple Kafka implementation in golang
.
├── docker-compose.yml
├── go.mod
├── go.sum
├── kafka
│ ├── client.go
│ ├── consumer_group.go
│ ├── model
│ │ ├── interface.go
│ │ └── model.go
│ ├── producer.go
│ └── topic.go
├── main.go
├── producer
│ └── producer.go
└── README.md