Không có mô tả

76 Commits

12 Branches

Evan Huus cbc1273e08 checkpoint wip simplify errors slightly		12 năm trước cách đây
.gitignore	78d686d98d Initial commit	12 năm trước cách đây
README.md	2de9a2dc0b README tweak	12 năm trước cách đây
broker.go	cbc1273e08 checkpoint wip simplify errors slightly	12 năm trước cách đây
broker_manager.go	eeb9b0926c More API slimming, publish ProduceResponse	12 năm trước cách đây
client.go	a7f7cc3025 Revert "Checkpoint work-in-progress on a fat client"	12 năm trước cách đây
consumer.go	0d4e4a2ea0 go fmt	12 năm trước cách đây
encoder_decoder.go	91b0ddffd1 go files use snake_case	12 năm trước cách đây
errors.go	cbc1273e08 checkpoint wip simplify errors slightly	12 năm trước cách đây
fetch_request.go	19099f5e88 Implement fetch requests	12 năm trước cách đây
fetch_response.go	1862bd8823 Decode remaining parts of fetch responses	12 năm trước cách đây
message.go	cf7a3109e5 Don't need to publish message format constant	12 năm trước cách đây
message_set.go	1862bd8823 Decode remaining parts of fetch responses	12 năm trước cách đây
metadata_request.go	39be3b4fee Refactor. Refresh topic metadata in more cases.	12 năm trước cách đây
metadata_response.go	77be473961 Add package declarations to stub files	12 năm trước cách đây
offset_commit_request.go	77be473961 Add package declarations to stub files	12 năm trước cách đây
offset_commit_response.go	77be473961 Add package declarations to stub files	12 năm trước cách đây
offset_fetch_request.go	77be473961 Add package declarations to stub files	12 năm trước cách đây
offset_fetch_response.go	77be473961 Add package declarations to stub files	12 năm trước cách đây
offset_request.go	77be473961 Add package declarations to stub files	12 năm trước cách đây
offset_response.go	77be473961 Add package declarations to stub files	12 năm trước cách đây
packet_crcs.go	2deb91d926 checkpoint wip message encoding/decoding	12 năm trước cách đây
packet_decoder.go	1862bd8823 Decode remaining parts of fetch responses	12 năm trước cách đây
packet_encoder.go	b6d96975b7 Allow sending arbitrary messages from producer	12 năm trước cách đây
packet_lengths.go	2deb91d926 checkpoint wip message encoding/decoding	12 năm trước cách đây
partition_chooser.go	853ab85e91 snake_case_files	12 năm trước cách đây
partition_metadata.go	fe73334510 Factor out common array encoding/decoding	12 năm trước cách đây
prep_encoder.go	b6d96975b7 Allow sending arbitrary messages from producer	12 năm trước cách đây
produce_request.go	39be3b4fee Refactor. Refresh topic metadata in more cases.	12 năm trước cách đây
produce_response.go	eeb9b0926c More API slimming, publish ProduceResponse	12 năm trước cách đây
producer.go	eeb9b0926c More API slimming, publish ProduceResponse	12 năm trước cách đây
real_decoder.go	1862bd8823 Decode remaining parts of fetch responses	12 năm trước cách đây
real_encoder.go	b6d96975b7 Allow sending arbitrary messages from producer	12 năm trước cách đây
request.go	738410b0c0 Simply interfaces slightly	12 năm trước cách đây
topic_metadata.go	91b0ddffd1 go files use snake_case	12 năm trước cách đây

sarama

Sarama is a Go library for Apache Kafka 0.8.