hyper-kafka

Apache Kafka message broker for Hyper framework

Get Started

m := kafka.New(
  kafka.Addrs("localhost:9092"),
)
h := hyper.New(
  hyper.Message(m),
)

Name		Name	Last commit message	Last commit date
Latest commit History 6 Commits
vendor		vendor
.gitignore		.gitignore
LICENSE		LICENSE
README.md		README.md
glide.lock		glide.lock
glide.yaml		glide.yaml
kafka.go		kafka.go
kafka_test.go		kafka_test.go
message.go		message.go
options.go		options.go