Inicio Explorar Axuda
Rexistro Iniciar sesión
publics
/
sarama
0
0
Fork 0
Ficheiros Incidencias 0 Pull Requests 0 Wiki

Sen descrición

Árbore: 5e41ad652f
Ramas Etiquetas
sarama
Evan Huus 5e41ad652f Fix bug where old partitions weren't cleaned up %!s(int64=13) %!d(string=hai) anos
.gitignore 78d686d98d Initial commit %!s(int64=13) %!d(string=hai) anos
README.md 2de9a2dc0b README tweak %!s(int64=13) %!d(string=hai) anos
broker.go 0d5af9417d refactor out common code %!s(int64=13) %!d(string=hai) anos
broker_manager.go 5e41ad652f Fix bug where old partitions weren't cleaned up %!s(int64=13) %!d(string=hai) anos
client.go eb4d0a37fb Correctly send client ID %!s(int64=13) %!d(string=hai) anos
consumer.go 0d4e4a2ea0 go fmt %!s(int64=13) %!d(string=hai) anos
encoder_decoder.go 91b0ddffd1 go files use snake_case %!s(int64=13) %!d(string=hai) anos
errors.go fc4945fdf9 Allowing details on encode/decode errors %!s(int64=13) %!d(string=hai) anos
fetch_request.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
fetch_response.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
message.go 4960166afb SendSimpleMessage for producer, doesn't quite work yet %!s(int64=13) %!d(string=hai) anos
message_set.go 4960166afb SendSimpleMessage for producer, doesn't quite work yet %!s(int64=13) %!d(string=hai) anos
metadata_request.go 91b0ddffd1 go files use snake_case %!s(int64=13) %!d(string=hai) anos
metadata_response.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
offset_commit_request.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
offset_commit_response.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
offset_fetch_request.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
offset_fetch_response.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
offset_request.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
offset_response.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
packet_crcs.go 2deb91d926 checkpoint wip message encoding/decoding %!s(int64=13) %!d(string=hai) anos
packet_decoder.go ca7a207750 finish basic message encoding/decoding %!s(int64=13) %!d(string=hai) anos
packet_encoder.go ca7a207750 finish basic message encoding/decoding %!s(int64=13) %!d(string=hai) anos
packet_lengths.go 2deb91d926 checkpoint wip message encoding/decoding %!s(int64=13) %!d(string=hai) anos
partitionChooser.go 4960166afb SendSimpleMessage for producer, doesn't quite work yet %!s(int64=13) %!d(string=hai) anos
partition_metadata.go 91b0ddffd1 go files use snake_case %!s(int64=13) %!d(string=hai) anos
prep_encoder.go 4fd1ecc22c Clarify encoding errors, permit sending produceRequests %!s(int64=13) %!d(string=hai) anos
produce_request.go 4960166afb SendSimpleMessage for producer, doesn't quite work yet %!s(int64=13) %!d(string=hai) anos
produce_response.go 4960166afb SendSimpleMessage for producer, doesn't quite work yet %!s(int64=13) %!d(string=hai) anos
producer.go 863b58681b Infrastructure for not expecting a response. %!s(int64=13) %!d(string=hai) anos
real_decoder.go 1c4240b9cf Fix some offset calculation bugs %!s(int64=13) %!d(string=hai) anos
real_encoder.go 1c4240b9cf Fix some offset calculation bugs %!s(int64=13) %!d(string=hai) anos
request.go 44d5d67f64 Move API defs to right file, fix error condition %!s(int64=13) %!d(string=hai) anos
topic_metadata.go 91b0ddffd1 go files use snake_case %!s(int64=13) %!d(string=hai) anos

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.