Ana Sayfa Keşfet Yardım
Üye Ol Giriş Yap
publics
/
sarama
0
0
Çatalla 0
Dosyalar Sorunlar 0 Değişiklik İstekleri 0 Wiki

Açıklama Yok

Ağaç: 6cc5972fbf
Dallar Biçim İmleri
sarama
Evan Huus 6cc5972fbf Refactor broker manager a bit 13 yıl önce
.gitignore 78d686d98d Initial commit 13 yıl önce
README.md 2de9a2dc0b README tweak 13 yıl önce
broker.go 19132e333c Don't use buffered channels in the broker 13 yıl önce
broker_manager.go 6cc5972fbf Refactor broker manager a bit 13 yıl önce
client.go eb4d0a37fb Correctly send client ID 13 yıl önce
consumer.go 0d4e4a2ea0 go fmt 13 yıl önce
encoder_decoder.go 91b0ddffd1 go files use snake_case 13 yıl önce
errors.go 4b9ba1b53c checkpoint wip broker recovery 13 yıl önce
fetch_request.go 77be473961 Add package declarations to stub files 13 yıl önce
fetch_response.go 77be473961 Add package declarations to stub files 13 yıl önce
message.go 0db1060be3 Checkpoint wip producing messages 13 yıl önce
message_set.go 2deb91d926 checkpoint wip message encoding/decoding 13 yıl önce
metadata_request.go 91b0ddffd1 go files use snake_case 13 yıl önce
metadata_response.go 77be473961 Add package declarations to stub files 13 yıl önce
offset_commit_request.go 77be473961 Add package declarations to stub files 13 yıl önce
offset_commit_response.go 77be473961 Add package declarations to stub files 13 yıl önce
offset_fetch_request.go 77be473961 Add package declarations to stub files 13 yıl önce
offset_fetch_response.go 77be473961 Add package declarations to stub files 13 yıl önce
offset_request.go 77be473961 Add package declarations to stub files 13 yıl önce
offset_response.go 77be473961 Add package declarations to stub files 13 yıl önce
packet_crcs.go 2deb91d926 checkpoint wip message encoding/decoding 13 yıl önce
packet_decoder.go ca7a207750 finish basic message encoding/decoding 13 yıl önce
packet_encoder.go ca7a207750 finish basic message encoding/decoding 13 yıl önce
packet_lengths.go 2deb91d926 checkpoint wip message encoding/decoding 13 yıl önce
partition_metadata.go 91b0ddffd1 go files use snake_case 13 yıl önce
prep_encoder.go ca7a207750 finish basic message encoding/decoding 13 yıl önce
produce_request.go 7802d4de85 encode produce requests 13 yıl önce
produce_response.go 77be473961 Add package declarations to stub files 13 yıl önce
producer.go 0d4e4a2ea0 go fmt 13 yıl önce
real_decoder.go ca7a207750 finish basic message encoding/decoding 13 yıl önce
real_encoder.go ca7a207750 finish basic message encoding/decoding 13 yıl önce
request.go 44d5d67f64 Move API defs to right file, fix error condition 13 yıl önce
topic_metadata.go 91b0ddffd1 go files use snake_case 13 yıl önce

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.