Sem descrição

Evan Huus fc4945fdf9 Allowing details on encode/decode errors há 12 anos atrás
.gitignore 78d686d98d Initial commit há 12 anos atrás
README.md 2de9a2dc0b README tweak há 12 anos atrás
broker.go 19132e333c Don't use buffered channels in the broker há 12 anos atrás
broker_manager.go 6cc5972fbf Refactor broker manager a bit há 12 anos atrás
client.go eb4d0a37fb Correctly send client ID há 12 anos atrás
consumer.go 0d4e4a2ea0 go fmt há 12 anos atrás
encoder_decoder.go 91b0ddffd1 go files use snake_case há 12 anos atrás
errors.go fc4945fdf9 Allowing details on encode/decode errors há 12 anos atrás
fetch_request.go 77be473961 Add package declarations to stub files há 12 anos atrás
fetch_response.go 77be473961 Add package declarations to stub files há 12 anos atrás
message.go 0db1060be3 Checkpoint wip producing messages há 12 anos atrás
message_set.go 2deb91d926 checkpoint wip message encoding/decoding há 12 anos atrás
metadata_request.go 91b0ddffd1 go files use snake_case há 12 anos atrás
metadata_response.go 77be473961 Add package declarations to stub files há 12 anos atrás
offset_commit_request.go 77be473961 Add package declarations to stub files há 12 anos atrás
offset_commit_response.go 77be473961 Add package declarations to stub files há 12 anos atrás
offset_fetch_request.go 77be473961 Add package declarations to stub files há 12 anos atrás
offset_fetch_response.go 77be473961 Add package declarations to stub files há 12 anos atrás
offset_request.go 77be473961 Add package declarations to stub files há 12 anos atrás
offset_response.go 77be473961 Add package declarations to stub files há 12 anos atrás
packet_crcs.go 2deb91d926 checkpoint wip message encoding/decoding há 12 anos atrás
packet_decoder.go ca7a207750 finish basic message encoding/decoding há 12 anos atrás
packet_encoder.go ca7a207750 finish basic message encoding/decoding há 12 anos atrás
packet_lengths.go 2deb91d926 checkpoint wip message encoding/decoding há 12 anos atrás
partition_metadata.go 91b0ddffd1 go files use snake_case há 12 anos atrás
prep_encoder.go ca7a207750 finish basic message encoding/decoding há 12 anos atrás
produce_request.go 7802d4de85 encode produce requests há 12 anos atrás
produce_response.go 77be473961 Add package declarations to stub files há 12 anos atrás
producer.go 0d4e4a2ea0 go fmt há 12 anos atrás
real_decoder.go 1c4240b9cf Fix some offset calculation bugs há 12 anos atrás
real_encoder.go 1c4240b9cf Fix some offset calculation bugs há 12 anos atrás
request.go 44d5d67f64 Move API defs to right file, fix error condition há 12 anos atrás
topic_metadata.go 91b0ddffd1 go files use snake_case há 12 anos atrás

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.