홈 탐색 도움말
가입하기 로그인
publics
/
sarama
0
0
포크 0
파일 이슈 0 풀 리퀘스트 0 위키

설명 없음

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

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.