Tidak Ada Deskripsi

Evan Huus 14dc1b2c4c Implement a hashing partitioner		12 tahun lalu
.gitignore	78d686d98d Initial commit	12 tahun lalu
MIT-LICENSE	86b4691cdd Add license information	12 tahun lalu
README.md	f7879002bc Update README.md	12 tahun lalu
broker.go	d4d176a7cd missing period	12 tahun lalu
broker_test.go	efb24f7c1c Add accessor for broker's address	12 tahun lalu
client.go	34918e6fce Permit creating client with multiple broker addresses	12 tahun lalu
client_test.go	7dca867d92 Standardize on underscores	12 tahun lalu
consumer.go	228a7e2b9f Use a single consumer channel instead of two	12 tahun lalu
consumer_test.go	7dca867d92 Standardize on underscores	12 tahun lalu
crc32_field.go	4969d24fa1 kafka->sarama	12 tahun lalu
encoder_decoder.go	4969d24fa1 kafka->sarama	12 tahun lalu
errors.go	722c9b21ae Merge pull request #11 from Shopify/extendable_configuration	12 tahun lalu
fetch_request.go	4969d24fa1 kafka->sarama	12 tahun lalu
fetch_request_test.go	4969d24fa1 kafka->sarama	12 tahun lalu
fetch_response.go	4969d24fa1 kafka->sarama	12 tahun lalu
fetch_response_test.go	4969d24fa1 kafka->sarama	12 tahun lalu
length_field.go	4969d24fa1 kafka->sarama	12 tahun lalu
message.go	4797fe2e57 Only compress a message once	12 tahun lalu
message_set.go	4969d24fa1 kafka->sarama	12 tahun lalu
metadata_request.go	4969d24fa1 kafka->sarama	12 tahun lalu
metadata_request_test.go	4969d24fa1 kafka->sarama	12 tahun lalu
metadata_response.go	4969d24fa1 kafka->sarama	12 tahun lalu
metadata_response_test.go	dae9785f7e Replace broker's host/port with just addr	12 tahun lalu
offset_commit_request.go	4969d24fa1 kafka->sarama	12 tahun lalu
offset_commit_request_test.go	4969d24fa1 kafka->sarama	12 tahun lalu
offset_commit_response.go	4969d24fa1 kafka->sarama	12 tahun lalu
offset_commit_response_test.go	4969d24fa1 kafka->sarama	12 tahun lalu
offset_fetch_request.go	4969d24fa1 kafka->sarama	12 tahun lalu
offset_fetch_request_test.go	4969d24fa1 kafka->sarama	12 tahun lalu
offset_fetch_response.go	4969d24fa1 kafka->sarama	12 tahun lalu
offset_fetch_response_test.go	4969d24fa1 kafka->sarama	12 tahun lalu
offset_request.go	4969d24fa1 kafka->sarama	12 tahun lalu
offset_request_test.go	4969d24fa1 kafka->sarama	12 tahun lalu
offset_response.go	4969d24fa1 kafka->sarama	12 tahun lalu
offset_response_test.go	4969d24fa1 kafka->sarama	12 tahun lalu
packet_decoder.go	4969d24fa1 kafka->sarama	12 tahun lalu
packet_encoder.go	4969d24fa1 kafka->sarama	12 tahun lalu
partitioner.go	14dc1b2c4c Implement a hashing partitioner	12 tahun lalu
partitioner_test.go	14dc1b2c4c Implement a hashing partitioner	12 tahun lalu
prep_encoder.go	4969d24fa1 kafka->sarama	12 tahun lalu
produce_request.go	4969d24fa1 kafka->sarama	12 tahun lalu
produce_request_test.go	4969d24fa1 kafka->sarama	12 tahun lalu
produce_response.go	4969d24fa1 kafka->sarama	12 tahun lalu
produce_response_test.go	4969d24fa1 kafka->sarama	12 tahun lalu
producer.go	0465ed0341 Add ProducerConfig.Compression	12 tahun lalu
producer_test.go	7dca867d92 Standardize on underscores	12 tahun lalu
real_decoder.go	e4ff187a56 go 1.0 compatibility; all we lose is ipv6 zones	12 tahun lalu
real_encoder.go	4969d24fa1 kafka->sarama	12 tahun lalu
request.go	4969d24fa1 kafka->sarama	12 tahun lalu
request_test.go	4969d24fa1 kafka->sarama	12 tahun lalu
response_header.go	4969d24fa1 kafka->sarama	12 tahun lalu
response_header_test.go	4969d24fa1 kafka->sarama	12 tahun lalu
sarama.go	4969d24fa1 kafka->sarama	12 tahun lalu
utils.go	7f64dac45e Fix docs	12 tahun lalu

sarama

Sarama is an MIT-licensed Go client library for Apache Kafka 0.8 (and later).

Documentation is available via godoc at http://godoc.org/github.com/Shopify/sarama

README.md

sarama