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

Tidak Ada Deskripsi

Pohon: b6d96975b7
Ranting Tag
sarama
Evan Huus b6d96975b7 Allow sending arbitrary messages from producer 12 tahun lalu
.gitignore 78d686d98d Initial commit 12 tahun lalu
README.md 2de9a2dc0b README tweak 12 tahun lalu
broker.go b6d96975b7 Allow sending arbitrary messages from producer 12 tahun lalu
broker_manager.go b6d96975b7 Allow sending arbitrary messages from producer 12 tahun lalu
client.go eb4d0a37fb Correctly send client ID 12 tahun lalu
consumer.go 0d4e4a2ea0 go fmt 12 tahun lalu
encoder_decoder.go 91b0ddffd1 go files use snake_case 12 tahun lalu
errors.go fc4945fdf9 Allowing details on encode/decode errors 12 tahun lalu
fetch_request.go 19099f5e88 Implement fetch requests 12 tahun lalu
fetch_response.go 1862bd8823 Decode remaining parts of fetch responses 12 tahun lalu
message.go b6d96975b7 Allow sending arbitrary messages from producer 12 tahun lalu
message_set.go 1862bd8823 Decode remaining parts of fetch responses 12 tahun lalu
metadata_request.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 12 tahun lalu
metadata_response.go 77be473961 Add package declarations to stub files 12 tahun lalu
offset_commit_request.go 77be473961 Add package declarations to stub files 12 tahun lalu
offset_commit_response.go 77be473961 Add package declarations to stub files 12 tahun lalu
offset_fetch_request.go 77be473961 Add package declarations to stub files 12 tahun lalu
offset_fetch_response.go 77be473961 Add package declarations to stub files 12 tahun lalu
offset_request.go 77be473961 Add package declarations to stub files 12 tahun lalu
offset_response.go 77be473961 Add package declarations to stub files 12 tahun lalu
packet_crcs.go 2deb91d926 checkpoint wip message encoding/decoding 12 tahun lalu
packet_decoder.go 1862bd8823 Decode remaining parts of fetch responses 12 tahun lalu
packet_encoder.go b6d96975b7 Allow sending arbitrary messages from producer 12 tahun lalu
packet_lengths.go 2deb91d926 checkpoint wip message encoding/decoding 12 tahun lalu
partitionChooser.go b6d96975b7 Allow sending arbitrary messages from producer 12 tahun lalu
partition_metadata.go fe73334510 Factor out common array encoding/decoding 12 tahun lalu
prep_encoder.go b6d96975b7 Allow sending arbitrary messages from producer 12 tahun lalu
produce_request.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 12 tahun lalu
produce_response.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 12 tahun lalu
producer.go b6d96975b7 Allow sending arbitrary messages from producer 12 tahun lalu
real_decoder.go 1862bd8823 Decode remaining parts of fetch responses 12 tahun lalu
real_encoder.go b6d96975b7 Allow sending arbitrary messages from producer 12 tahun lalu
request.go b6d96975b7 Allow sending arbitrary messages from producer 12 tahun lalu
response.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 12 tahun lalu
topic_metadata.go 91b0ddffd1 go files use snake_case 12 tahun lalu

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.