go_kafka_client

Apache Kafka Client Library for Go

Prerequisites:

Install Golang http://golang.org/doc/install
Make sure env variables GOPATH and GOROOT exist and point to correct places
Install GPM https://github.com/pote/gpm
go get github.com/stealthly/go_kafka_client && cd $GOPATH/src/github.com/stealthly/go_kafka_client
gpm install

Optional (for all tests to work):

Download Apache Zookeeper http://zookeeper.apache.org/releases.html#download
Add environment variable ZOOKEEPER_PATH poiting to the root of Zookeeper distribution
Download Apache Kafka http://kafka.apache.org/downloads.html. *Note: we used kafka_2.10-0.8.1.1 for this development
Add environment variable KAFKA_PATH pointing to the root of Kafka distribution
cd $GOPATH/src/github.com/stealthly/go_kafka_client && go test -v
All tests should pass

After this is done you're ready to write some code!

Name		Name	Last commit message	Last commit date
Latest commit History 242 Commits
config		config
consumers		consumers
main		main
producers		producers
.gitignore		.gitignore
.travis.yml		.travis.yml
Godeps		Godeps
LICENSE		LICENSE
README.md		README.md
consumer.go		consumer.go
consumer_config.go		consumer_config.go
consumer_test.go		consumer_test.go
fetcher.go		fetcher.go
fetcher_test.go		fetcher_test.go
filter.go		filter.go
message_buffer.go		message_buffer.go
message_buffer_test.go		message_buffer_test.go
partition_assignment.go		partition_assignment.go
partition_assignment_test.go		partition_assignment_test.go
structs.go		structs.go
test_kafka_server.go		test_kafka_server.go
testing_utils.go		testing_utils.go
topics.go		topics.go
utils.go		utils.go
workers.go		workers.go
workers_test.go		workers_test.go
zk_coordinator.go		zk_coordinator.go
zk_coordinator_test.go		zk_coordinator_test.go

vladiacob/go_kafka_client