Kezdőlap Felfedezés Súgó
Regisztráció Bejelentkezés
publics
/
sarama
0
0
Másolás 0
Fájlok Problémák 0 Beolvasztási kérések 0 Wiki

Nincs leírás

Fa: 19099f5e88
Branch-ok Tag-ek
sarama
Evan Huus 19099f5e88 Implement fetch requests 13 éve
.gitignore 78d686d98d Initial commit 13 éve
README.md 2de9a2dc0b README tweak 13 éve
broker.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 éve
broker_manager.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 éve
client.go eb4d0a37fb Correctly send client ID 13 éve
consumer.go 0d4e4a2ea0 go fmt 13 éve
encoder_decoder.go 91b0ddffd1 go files use snake_case 13 éve
errors.go fc4945fdf9 Allowing details on encode/decode errors 13 éve
fetch_request.go 19099f5e88 Implement fetch requests 13 éve
fetch_response.go 77be473961 Add package declarations to stub files 13 éve
message.go e7e7a65825 Support gzipped messages 13 éve
message_set.go 4960166afb SendSimpleMessage for producer, doesn't quite work yet 13 éve
metadata_request.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 éve
metadata_response.go 77be473961 Add package declarations to stub files 13 éve
offset_commit_request.go 77be473961 Add package declarations to stub files 13 éve
offset_commit_response.go 77be473961 Add package declarations to stub files 13 éve
offset_fetch_request.go 77be473961 Add package declarations to stub files 13 éve
offset_fetch_response.go 77be473961 Add package declarations to stub files 13 éve
offset_request.go 77be473961 Add package declarations to stub files 13 éve
offset_response.go 77be473961 Add package declarations to stub files 13 éve
packet_crcs.go 2deb91d926 checkpoint wip message encoding/decoding 13 éve
packet_decoder.go fe73334510 Factor out common array encoding/decoding 13 éve
packet_encoder.go fe73334510 Factor out common array encoding/decoding 13 éve
packet_lengths.go 2deb91d926 checkpoint wip message encoding/decoding 13 éve
partitionChooser.go 4960166afb SendSimpleMessage for producer, doesn't quite work yet 13 éve
partition_metadata.go fe73334510 Factor out common array encoding/decoding 13 éve
prep_encoder.go fe73334510 Factor out common array encoding/decoding 13 éve
produce_request.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 éve
produce_response.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 éve
producer.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 éve
real_decoder.go fe73334510 Factor out common array encoding/decoding 13 éve
real_encoder.go fe73334510 Factor out common array encoding/decoding 13 éve
request.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 éve
response.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 éve
topic_metadata.go 91b0ddffd1 go files use snake_case 13 éve

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.