Không có mô tả

80 Commits

12 Branches

Evan Huus b389af0788 Replace brokerManager with metadataCache		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	a2eefc8df1 Little naming changes for consistency	12 năm trước cách đây
client.go	b389af0788 Replace brokerManager with metadataCache	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	84d5cfc734 Finish improving errors	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_cache.go	b389af0788 Replace brokerManager with metadataCache	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	a2eefc8df1 Little naming changes for consistency	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	84d5cfc734 Finish improving errors	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	84d5cfc734 Finish improving errors	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	84d5cfc734 Finish improving errors	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	b389af0788 Replace brokerManager with metadataCache	12 năm trước cách đây
real_decoder.go	84d5cfc734 Finish improving errors	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.