Home Esplora Aiuto
Registrati Accedi
publics
/
sarama
0
0
Forka 0
File Problemi 0 Pull Requests 0 Wiki

Nessuna descrizione

Albero (Tree): b389af0788
Rami (Branch) Tag
sarama
Evan Huus b389af0788 Replace brokerManager with metadataCache 13 anni fa
.gitignore 78d686d98d Initial commit 13 anni fa
README.md 2de9a2dc0b README tweak 13 anni fa
broker.go a2eefc8df1 Little naming changes for consistency 13 anni fa
client.go b389af0788 Replace brokerManager with metadataCache 13 anni fa
consumer.go 0d4e4a2ea0 go fmt 13 anni fa
encoder_decoder.go 91b0ddffd1 go files use snake_case 13 anni fa
errors.go cbc1273e08 checkpoint wip simplify errors slightly 13 anni fa
fetch_request.go 19099f5e88 Implement fetch requests 13 anni fa
fetch_response.go 1862bd8823 Decode remaining parts of fetch responses 13 anni fa
message.go 84d5cfc734 Finish improving errors 13 anni fa
message_set.go 1862bd8823 Decode remaining parts of fetch responses 13 anni fa
metadata_cache.go b389af0788 Replace brokerManager with metadataCache 13 anni fa
metadata_request.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 anni fa
metadata_response.go a2eefc8df1 Little naming changes for consistency 13 anni fa
offset_commit_request.go 77be473961 Add package declarations to stub files 13 anni fa
offset_commit_response.go 77be473961 Add package declarations to stub files 13 anni fa
offset_fetch_request.go 77be473961 Add package declarations to stub files 13 anni fa
offset_fetch_response.go 77be473961 Add package declarations to stub files 13 anni fa
offset_request.go 77be473961 Add package declarations to stub files 13 anni fa
offset_response.go 77be473961 Add package declarations to stub files 13 anni fa
packet_crcs.go 84d5cfc734 Finish improving errors 13 anni fa
packet_decoder.go 1862bd8823 Decode remaining parts of fetch responses 13 anni fa
packet_encoder.go b6d96975b7 Allow sending arbitrary messages from producer 13 anni fa
packet_lengths.go 84d5cfc734 Finish improving errors 13 anni fa
partition_chooser.go 853ab85e91 snake_case_files 13 anni fa
partition_metadata.go fe73334510 Factor out common array encoding/decoding 13 anni fa
prep_encoder.go 84d5cfc734 Finish improving errors 13 anni fa
produce_request.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 anni fa
produce_response.go eeb9b0926c More API slimming, publish ProduceResponse 13 anni fa
producer.go b389af0788 Replace brokerManager with metadataCache 13 anni fa
real_decoder.go 84d5cfc734 Finish improving errors 13 anni fa
real_encoder.go b6d96975b7 Allow sending arbitrary messages from producer 13 anni fa
request.go 738410b0c0 Simply interfaces slightly 13 anni fa
topic_metadata.go 91b0ddffd1 go files use snake_case 13 anni fa

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.