kafka-practice

用 Golang 操作 Kafka。

Get started

本地运行 ZK 和 Kafka 容器：

$ docker-compose up

启动消费者：

# 可以开多个终端运行多个实例
$ go run pkg/consumer/consumer.go
$ go run pkg/consumer/consumer.go

启动生产者：

$ go run pkg/producer/producer.go

Name		Name	Last commit message	Last commit date
Latest commit History 1 Commit
.idea		.idea
pkg		pkg
README.md		README.md
docker-compose.yml		docker-compose.yml
go.mod		go.mod
go.sum		go.sum