Halaman utama Jelajahi Bantuan
Daftar Masuk
publics
/
sarama
0
0
Fork 0
Berkas Masalah 0 Permintaan Tarik 0 Wiki

Tidak Ada Deskripsi

Pohon: daabaa3c99
Ranting Tag
sarama
Evan Huus daabaa3c99 Misc partition fixes, including making sure they're in the right order 13 tahun lalu
.gitignore 78d686d98d Initial commit 13 tahun lalu
README.md 2de9a2dc0b README tweak 13 tahun lalu
broker.go a2eefc8df1 Little naming changes for consistency 13 tahun lalu
client.go f87efdac57 More refactor, consistent API 13 tahun lalu
consumer.go 0d4e4a2ea0 go fmt 13 tahun lalu
encoder_decoder.go 91b0ddffd1 go files use snake_case 13 tahun lalu
errors.go cbc1273e08 checkpoint wip simplify errors slightly 13 tahun lalu
fetch_request.go 19099f5e88 Implement fetch requests 13 tahun lalu
fetch_response.go 1862bd8823 Decode remaining parts of fetch responses 13 tahun lalu
message.go 84d5cfc734 Finish improving errors 13 tahun lalu
message_set.go 1862bd8823 Decode remaining parts of fetch responses 13 tahun lalu
metadata_cache.go daabaa3c99 Misc partition fixes, including making sure they're in the right order 13 tahun lalu
metadata_request.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 tahun lalu
metadata_response.go a2eefc8df1 Little naming changes for consistency 13 tahun lalu
offset_commit_request.go 77be473961 Add package declarations to stub files 13 tahun lalu
offset_commit_response.go 77be473961 Add package declarations to stub files 13 tahun lalu
offset_fetch_request.go 77be473961 Add package declarations to stub files 13 tahun lalu
offset_fetch_response.go 77be473961 Add package declarations to stub files 13 tahun lalu
offset_request.go 77be473961 Add package declarations to stub files 13 tahun lalu
offset_response.go 77be473961 Add package declarations to stub files 13 tahun lalu
packet_crcs.go 84d5cfc734 Finish improving errors 13 tahun lalu
packet_decoder.go 1862bd8823 Decode remaining parts of fetch responses 13 tahun lalu
packet_encoder.go b6d96975b7 Allow sending arbitrary messages from producer 13 tahun lalu
packet_lengths.go 84d5cfc734 Finish improving errors 13 tahun lalu
partition_chooser.go daabaa3c99 Misc partition fixes, including making sure they're in the right order 13 tahun lalu
partition_metadata.go fe73334510 Factor out common array encoding/decoding 13 tahun lalu
prep_encoder.go 84d5cfc734 Finish improving errors 13 tahun lalu
produce_request.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 tahun lalu
produce_response.go eeb9b0926c More API slimming, publish ProduceResponse 13 tahun lalu
producer.go daabaa3c99 Misc partition fixes, including making sure they're in the right order 13 tahun lalu
real_decoder.go 84d5cfc734 Finish improving errors 13 tahun lalu
real_encoder.go b6d96975b7 Allow sending arbitrary messages from producer 13 tahun lalu
request.go 738410b0c0 Simply interfaces slightly 13 tahun lalu
topic_metadata.go 91b0ddffd1 go files use snake_case 13 tahun lalu
utils.go daabaa3c99 Misc partition fixes, including making sure they're in the right order 13 tahun lalu

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.