|
.gitignore
|
78d686d98d
Initial commit
|
12 лет назад |
|
MIT-LICENSE
|
86b4691cdd
Add license information
|
12 лет назад |
|
README.md
|
cd81a9cf7f
Mention 1.0 compat and vet issues in README
|
12 лет назад |
|
broker.go
|
0f7b431bdf
Remove Broker.Equals()
|
12 лет назад |
|
broker_test.go
|
0f7b431bdf
Remove Broker.Equals()
|
12 лет назад |
|
client.go
|
761894ac88
Merge pull request #30 from Shopify/client_api_2
|
12 лет назад |
|
client_test.go
|
d1bbdae1d5
Make Client.Leader() public.
|
12 лет назад |
|
consumer.go
|
9d5c25779a
Fix a logic bug that occurs when a broker is down.
|
12 лет назад |
|
consumer_test.go
|
0522caa404
Match names correctly
|
12 лет назад |
|
crc32_field.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
encoder_decoder.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
errors.go
|
722c9b21ae
Merge pull request #11 from Shopify/extendable_configuration
|
12 лет назад |
|
fetch_request.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
fetch_request_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
fetch_response.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
fetch_response_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
length_field.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
message.go
|
013a53b381
Fix message compression flag.
|
12 лет назад |
|
message_set.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
message_test.go
|
013a53b381
Fix message compression flag.
|
12 лет назад |
|
metadata_request.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
metadata_request_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
metadata_response.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
metadata_response_test.go
|
dae9785f7e
Replace broker's host/port with just addr
|
12 лет назад |
|
offset_commit_request.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
offset_commit_request_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
offset_commit_response.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
offset_commit_response_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
offset_fetch_request.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
offset_fetch_request_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
offset_fetch_response.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
offset_fetch_response_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
offset_request.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
offset_request_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
offset_response.go
|
2565bc81b7
Add an OffsetMethod that permits specifying other methods of determining the offset, such as querying the broker
|
12 лет назад |
|
offset_response_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
packet_decoder.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
packet_encoder.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
partitioner.go
|
f8f6c2a832
Fix HashPartitioner returning negative partitions.
|
12 лет назад |
|
partitioner_test.go
|
f8f6c2a832
Fix HashPartitioner returning negative partitions.
|
12 лет назад |
|
prep_encoder.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
produce_request.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
produce_request_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
produce_response.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
produce_response_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
producer.go
|
d1bbdae1d5
Make Client.Leader() public.
|
12 лет назад |
|
producer_test.go
|
7dca867d92
Standardize on underscores
|
12 лет назад |
|
real_decoder.go
|
e4ff187a56
go 1.0 compatibility; all we lose is ipv6 zones
|
12 лет назад |
|
real_encoder.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
request.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
request_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
response_header.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
response_header_test.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
sarama.go
|
4969d24fa1
kafka->sarama
|
12 лет назад |
|
utils.go
|
7f64dac45e
Fix docs
|
12 лет назад |
Evan Huus