kafka-client

Apache Kafka low level client in Golang

Installation:

You may also want to spin up a local broker at localhost:9092 for the functional test to work as well (it will be skipped otherwise).

Name		Name	Last commit message	Last commit date
Latest commit History 16 Commits
.gitignore		.gitignore
.travis.yml		.travis.yml
LICENSE		LICENSE
README.md		README.md
brokers.go		brokers.go
client.go		client.go
client_test.go		client_test.go
consumer_metadata.go		consumer_metadata.go
consumer_metadata_test.go		consumer_metadata_test.go
decoder.go		decoder.go
describe_groups.go		describe_groups.go
describe_groups_test.go		describe_groups_test.go
encoder.go		encoder.go
encoder_decoder_test.go		encoder_decoder_test.go
errors.go		errors.go
fetch.go		fetch.go
fetch_test.go		fetch_test.go
heartbeat.go		heartbeat.go
heartbeat_test.go		heartbeat_test.go
join_group.go		join_group.go
join_group_test.go		join_group_test.go
leave_group.go		leave_group.go
leave_group_test.go		leave_group_test.go
list_groups.go		list_groups.go
list_groups_test.go		list_groups_test.go
messages.go		messages.go
metadata.go		metadata.go
offset.go		offset.go
offset_commit.go		offset_commit.go
offset_commit_test.go		offset_commit_test.go
offset_fetch.go		offset_fetch.go
offset_fetch_test.go		offset_fetch_test.go
offset_test.go		offset_test.go
produce.go		produce.go
produce_test.go		produce_test.go
request_response.go		request_response.go
request_response_test.go		request_response_test.go
snappy.go		snappy.go
sync_group.go		sync_group.go
sync_group_test.go		sync_group_test.go
topic_metadata.go		topic_metadata.go
topic_metadata_test.go		topic_metadata_test.go
util.go		util.go
utils_test.go		utils_test.go

Provide feedback