siesta

A low level Apache Kafka library in Go

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 144 Commits
.gitignore		.gitignore
.travis.yml		.travis.yml
LICENSE		LICENSE
README.md		README.md
config.go		config.go
conn.go		conn.go
conn_test.go		conn_test.go
connector.go		connector.go
connector_test.go		connector_test.go
consumer_metadata.go		consumer_metadata.go
consumer_metadata_test.go		consumer_metadata_test.go
decoder.go		decoder.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
kafka_producer.go		kafka_producer.go
kafka_producer_test.go		kafka_producer_test.go
logger.go		logger.go
messages.go		messages.go
metadata.go		metadata.go
network_client.go		network_client.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
partitioner.go		partitioner.go
produce.go		produce.go
produce_test.go		produce_test.go
record_accumulator.go		record_accumulator.go
request_response.go		request_response.go
request_response_test.go		request_response_test.go
selector.go		selector.go
selector_test.go		selector_test.go
snappy.go		snappy.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