.github
|
376a293238
Update ISSUE_TEMPLATE.md
|
7 سال پیش |
examples
|
fe841de91b
Fix tiny typo in examples README link
|
7 سال پیش |
mocks
|
21e1c0b874
Fix comment for mocks.NewConsumer
|
7 سال پیش |
tools
|
bcc8fb3014
Fix config for calling NewSyncProducer()
|
7 سال پیش |
vagrant
|
eaafcb0eeb
Make vagrant up work again
|
6 سال پیش |
.gitignore
|
d1539ef689
Added coverage badge
|
6 سال پیش |
.travis.yml
|
5d7468a593
Drop golang 1.7
|
6 سال پیش |
CHANGELOG.md
|
3b1b38866a
Bump changelog
|
6 سال پیش |
LICENSE
|
59589985d3
Renaming MIT-LICENSE file to LICENSE and removing created LICENSE file
|
7 سال پیش |
Makefile
|
d1539ef689
Added coverage badge
|
6 سال پیش |
README.md
|
5d7468a593
Drop golang 1.7
|
6 سال پیش |
Vagrantfile
|
609cb1c1db
Use sensible heap size for JVMs in Vagrant
|
7 سال پیش |
acl_bindings.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
acl_create_request.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
acl_create_request_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
acl_create_response.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
acl_create_response_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
acl_delete_request.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
acl_delete_request_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
acl_delete_response.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
acl_delete_response_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
acl_describe_request.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
acl_describe_request_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
acl_describe_response.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
acl_describe_response_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
acl_filter.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
acl_types.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
add_offsets_to_txn_request.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
add_offsets_to_txn_request_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
add_offsets_to_txn_response.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
add_offsets_to_txn_response_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
add_partitions_to_txn_request.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
add_partitions_to_txn_request_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
add_partitions_to_txn_response.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
add_partitions_to_txn_response_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
api_versions_request.go
|
90a4cc632e
Fix race in broker version check
|
8 سال پیش |
api_versions_request_test.go
|
c5f4248429
Add support for latest protocol messages
|
8 سال پیش |
api_versions_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
7 سال پیش |
api_versions_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
8 سال پیش |
async_producer.go
|
5fd60c2be0
Add producer support for Kafka 0.11 Records
|
6 سال پیش |
async_producer_test.go
|
893be7d533
Permit setting version on mock produce response
|
6 سال پیش |
broker.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
broker_test.go
|
99dfd775b3
Unregister metrics when closing broker
|
6 سال پیش |
client.go
|
34068369ff
Merge pull request #975 from Shopify/return-partial-replicas
|
6 سال پیش |
client_test.go
|
240ddc7211
FIX: It shouldn't sort the replicas and isr while the order is
|
6 سال پیش |
client_tls_test.go
|
f933fb4b0b
Add NewMockBrokerListener() so that it's possible to test TLS connections
|
6 سال پیش |
config.go
|
a1cfcca530
changed Fetch.default value from 32KB to 1MB
|
6 سال پیش |
config_test.go
|
515a490ec1
Addressing review comments
|
6 سال پیش |
consumer.go
|
c8284bbf5c
Minimize diff with master
|
6 سال پیش |
consumer_group_members.go
|
83f973c2d6
More feedback, renamed structs
|
8 سال پیش |
consumer_group_members_test.go
|
cecb3d9807
Formating all files with gofmt -s
|
7 سال پیش |
consumer_metadata_request.go
|
90a4cc632e
Fix race in broker version check
|
8 سال پیش |
consumer_metadata_request_test.go
|
aa411f16fd
Add decode method to request types
|
9 سال پیش |
consumer_metadata_response.go
|
90a4cc632e
Fix race in broker version check
|
8 سال پیش |
consumer_metadata_response_test.go
|
9b6ac1a0fe
Add mock responses for OffsetManager testing
|
8 سال پیش |
consumer_test.go
|
d9ef2bef2e
advance partition consumer offset after compacted messages
|
6 سال پیش |
crc32_field.go
|
07a5840e2e
Make polynomial a type
|
6 سال پیش |
create_partitions_request.go
|
7957e72eca
factor out getStringLength, use putArrayLength
|
6 سال پیش |
create_partitions_request_test.go
|
b3f149d4d2
add create partitions
|
6 سال پیش |
create_partitions_response.go
|
b3f149d4d2
add create partitions
|
6 سال پیش |
create_partitions_response_test.go
|
b3f149d4d2
add create partitions
|
6 سال پیش |
create_topics_request.go
|
b5ace411a0
add CreateTopicsRequest/Response
|
6 سال پیش |
create_topics_request_test.go
|
b5ace411a0
add CreateTopicsRequest/Response
|
6 سال پیش |
create_topics_response.go
|
b5ace411a0
add CreateTopicsRequest/Response
|
6 سال پیش |
create_topics_response_test.go
|
b5ace411a0
add CreateTopicsRequest/Response
|
6 سال پیش |
delete_topics_request.go
|
620549d3ed
add DeleteTopicsRequest/Response
|
6 سال پیش |
delete_topics_request_test.go
|
620549d3ed
add DeleteTopicsRequest/Response
|
6 سال پیش |
delete_topics_response.go
|
620549d3ed
add DeleteTopicsRequest/Response
|
6 سال پیش |
delete_topics_response_test.go
|
620549d3ed
add DeleteTopicsRequest/Response
|
6 سال پیش |
describe_groups_request.go
|
90a4cc632e
Fix race in broker version check
|
8 سال پیش |
describe_groups_request_test.go
|
1621c4959a
Add tests for all new request types.
|
8 سال پیش |
describe_groups_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
7 سال پیش |
describe_groups_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
8 سال پیش |
dev.yml
|
66fbffdee6
[bot] remove unused 'packages' dev.yml element [skip ci]
|
6 سال پیش |
encoder_decoder.go
|
124e7c647e
Expose producer metrics with go-metrics
|
7 سال پیش |
end_txn_request.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
end_txn_request_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
end_txn_response.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
end_txn_response_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
errors.go
|
d9ef2bef2e
advance partition consumer offset after compacted messages
|
6 سال پیش |
fetch_request.go
|
5959a18af1
Make isolation level a type
|
6 سال پیش |
fetch_request_test.go
|
953231c528
Add support for Kafka 0.11 in consumer
|
6 سال پیش |
fetch_response.go
|
3be0b7c29d
Improve backward compatibility by keeping FetchResponseBlock.Records
|
6 سال پیش |
fetch_response_test.go
|
c8284bbf5c
Minimize diff with master
|
6 سال پیش |
functional_client_test.go
|
e931cc00ed
Stop test if client.Coordinator fails somehow
|
7 سال پیش |
functional_consumer_test.go
|
f0fc7e9247
Finalize most of the toxiproxy test framework
|
9 سال پیش |
functional_offset_manager_test.go
|
ccab789d44
OffsetManager: match upstream mark/next behaviour
|
7 سال پیش |
functional_producer_test.go
|
7b655373d8
Expose request latency metric
|
7 سال پیش |
functional_test.go
|
2c40df751c
Fix version.satisfies so all tests run against 0.9
|
8 سال پیش |
heartbeat_request.go
|
90a4cc632e
Fix race in broker version check
|
8 سال پیش |
heartbeat_request_test.go
|
1621c4959a
Add tests for all new request types.
|
8 سال پیش |
heartbeat_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
7 سال پیش |
heartbeat_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
8 سال پیش |
init_producer_id_request.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
init_producer_id_request_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
init_producer_id_response.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
init_producer_id_response_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
join_group_request.go
|
4351c00d43
Permit protocol ordering in JoinGroup requests
|
7 سال پیش |
join_group_request_test.go
|
4351c00d43
Permit protocol ordering in JoinGroup requests
|
7 سال پیش |
join_group_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
7 سال پیش |
join_group_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
8 سال پیش |
leave_group_request.go
|
90a4cc632e
Fix race in broker version check
|
8 سال پیش |
leave_group_request_test.go
|
1621c4959a
Add tests for all new request types.
|
8 سال پیش |
leave_group_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
7 سال پیش |
leave_group_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
8 سال پیش |
length_field.go
|
ff1f79c54b
Add dynamicPushDecoder interface
|
6 سال پیش |
list_groups_request.go
|
90a4cc632e
Fix race in broker version check
|
8 سال پیش |
list_groups_request_test.go
|
1621c4959a
Add tests for all new request types.
|
8 سال پیش |
list_groups_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
7 سال پیش |
list_groups_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
8 سال پیش |
message.go
|
ed80c61d79
Make timestamp fields of type time.Time and time.Duration
|
6 سال پیش |
message_set.go
|
d7d2bb7b2b
Support multiple mixed Record types
|
6 سال پیش |
message_test.go
|
5c2219768a
fix TestMessageEncoding
|
6 سال پیش |
metadata_request.go
|
88a4afb3d1
Misc minor lint changes
|
8 سال پیش |
metadata_request_test.go
|
aa411f16fd
Add decode method to request types
|
9 سال پیش |
metadata_response.go
|
88a4afb3d1
Misc minor lint changes
|
8 سال پیش |
metadata_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
8 سال پیش |
metrics.go
|
124e7c647e
Expose producer metrics with go-metrics
|
7 سال پیش |
metrics_test.go
|
124e7c647e
Expose producer metrics with go-metrics
|
7 سال پیش |
mockbroker.go
|
f933fb4b0b
Add NewMockBrokerListener() so that it's possible to test TLS connections
|
6 سال پیش |
mockresponses.go
|
5169c3158b
Fix formatting
|
6 سال پیش |
offset_commit_request.go
|
88a4afb3d1
Misc minor lint changes
|
8 سال پیش |
offset_commit_request_test.go
|
aa411f16fd
Add decode method to request types
|
9 سال پیش |
offset_commit_response.go
|
90a4cc632e
Fix race in broker version check
|
8 سال پیش |
offset_commit_response_test.go
|
9b6ac1a0fe
Add mock responses for OffsetManager testing
|
8 سال پیش |
offset_fetch_request.go
|
90a4cc632e
Fix race in broker version check
|
8 سال پیش |
offset_fetch_request_test.go
|
aa411f16fd
Add decode method to request types
|
9 سال پیش |
offset_fetch_response.go
|
88a4afb3d1
Misc minor lint changes
|
8 سال پیش |
offset_fetch_response_test.go
|
9b6ac1a0fe
Add mock responses for OffsetManager testing
|
8 سال پیش |
offset_manager.go
|
96fa1c8378
Allow resetting manager to the same offset
|
6 سال پیش |
offset_manager_test.go
|
b966238f31
adds ResetOffset to reset to earlier offset values. #554
|
6 سال پیش |
offset_request.go
|
d65b3fd46b
Support ListOffsetRequest v1 [KIP-79]
|
7 سال پیش |
offset_request_test.go
|
d65b3fd46b
Support ListOffsetRequest v1 [KIP-79]
|
7 سال پیش |
offset_response.go
|
d65b3fd46b
Support ListOffsetRequest v1 [KIP-79]
|
7 سال پیش |
offset_response_test.go
|
d65b3fd46b
Support ListOffsetRequest v1 [KIP-79]
|
7 سال پیش |
packet_decoder.go
|
b3f149d4d2
add create partitions
|
6 سال پیش |
packet_encoder.go
|
b3f149d4d2
add create partitions
|
6 سال پیش |
partitioner.go
|
8637e89db9
Minor changes to reflect comments to PR
|
7 سال پیش |
partitioner_test.go
|
f3b2363114
Fix concurrency issue in hashedPartitioner
|
7 سال پیش |
prep_encoder.go
|
b3f149d4d2
add create partitions
|
6 سال پیش |
produce_request.go
|
b7f694ebc8
Determine the records type based on the magic number not API version
|
6 سال پیش |
produce_request_test.go
|
5fd60c2be0
Add producer support for Kafka 0.11 Records
|
6 سال پیش |
produce_response.go
|
5fd60c2be0
Add producer support for Kafka 0.11 Records
|
6 سال پیش |
produce_response_test.go
|
ca457b7003
Support ProduceResponse v1 and v2 encoding
|
6 سال پیش |
produce_set.go
|
6899ef50de
Set Record.OffsetDelta to avoid broker recompression
|
6 سال پیش |
produce_set_test.go
|
6899ef50de
Set Record.OffsetDelta to avoid broker recompression
|
6 سال پیش |
real_decoder.go
|
7957e72eca
factor out getStringLength, use putArrayLength
|
6 سال پیش |
real_encoder.go
|
b3f149d4d2
add create partitions
|
6 سال پیش |
record.go
|
5fd60c2be0
Add producer support for Kafka 0.11 Records
|
6 سال پیش |
record_batch.go
|
eee4c711a2
Check for insufficient data when we try to get the records.
|
6 سال پیش |
record_test.go
|
5fd60c2be0
Add producer support for Kafka 0.11 Records
|
6 سال پیش |
records.go
|
c8284bbf5c
Minimize diff with master
|
6 سال پیش |
records_test.go
|
b7f694ebc8
Determine the records type based on the magic number not API version
|
6 سال پیش |
request.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
request_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
6 سال پیش |
response_header.go
|
66411d8222
Cleanup a bunch more error formats
|
8 سال پیش |
response_header_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
10 سال پیش |
sarama.go
|
7b655373d8
Expose request latency metric
|
7 سال پیش |
sasl_handshake_request.go
|
90a4cc632e
Fix race in broker version check
|
8 سال پیش |
sasl_handshake_request_test.go
|
c5f4248429
Add support for latest protocol messages
|
8 سال پیش |
sasl_handshake_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
7 سال پیش |
sasl_handshake_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
8 سال پیش |
sync_group_request.go
|
124e7c647e
Expose producer metrics with go-metrics
|
7 سال پیش |
sync_group_request_test.go
|
1621c4959a
Add tests for all new request types.
|
8 سال پیش |
sync_group_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
7 سال پیش |
sync_group_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
8 سال پیش |
sync_producer.go
|
8268907a6b
Tweak documentation of Close/AsyncClose methods
|
7 سال پیش |
sync_producer_test.go
|
cecb3d9807
Formating all files with gofmt -s
|
7 سال پیش |
timestamp.go
|
ed80c61d79
Make timestamp fields of type time.Time and time.Duration
|
6 سال پیش |
txn_offset_commit_request.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
txn_offset_commit_request_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
txn_offset_commit_response.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
txn_offset_commit_response_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
6 سال پیش |
utils.go
|
84e6098610
Escape periods in Kafka version regex
|
6 سال پیش |
utils_test.go
|
a709f2d5ca
String functions for KafkaVersion (#989)
|
6 سال پیش |