.github
|
7df59f3971
Enable CLA bot
|
há 6 anos atrás |
examples
|
fe841de91b
Fix tiny typo in examples README link
|
há 8 anos atrás |
mocks
|
baa5962850
fix race condition in mock async producer
|
há 6 anos atrás |
tools
|
6c7fa2cd19
Readd channel on producer performance tool
|
há 6 anos atrás |
vagrant
|
57d5c44d29
Fix CI script with new mirror URL
|
há 6 anos atrás |
.gitignore
|
151daaac97
Addressing feeback
|
há 6 anos atrás |
.travis.yml
|
fe4d3fa79d
When running go fmt, match all Golang patch versions
|
há 6 anos atrás |
CHANGELOG.md
|
f91c0a80e8
Compile changelog for 1.20.0 release
|
há 6 anos atrás |
LICENSE
|
8da9fa72b8
Technically Shopify owns the repo
|
há 7 anos atrás |
Makefile
|
a318f6ee7d
CI test fixes
|
há 6 anos atrás |
README.md
|
970116bc74
Support Go 1.11
|
há 6 anos atrás |
Vagrantfile
|
609cb1c1db
Use sensible heap size for JVMs in Vagrant
|
há 8 anos atrás |
acl_bindings.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
acl_create_request.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
acl_create_request_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
acl_create_response.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
acl_create_response_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
acl_delete_request.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
acl_delete_request_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
acl_delete_response.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
acl_delete_response_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
acl_describe_request.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
acl_describe_request_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
acl_describe_response.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
acl_describe_response_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
acl_filter.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
acl_types.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
há 7 anos atrás |
add_offsets_to_txn_request.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
add_offsets_to_txn_request_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
add_offsets_to_txn_response.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
add_offsets_to_txn_response_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
add_partitions_to_txn_request.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
add_partitions_to_txn_request_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
add_partitions_to_txn_response.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
add_partitions_to_txn_response_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
admin.go
|
f3829d3df4
feat: add Timeout for ClusterAdmin
|
há 6 anos atrás |
admin_test.go
|
320229591a
support of admin operations in sarama
|
há 6 anos atrás |
alter_configs_request.go
|
f7466ea37d
Add Describe + AlterConfigs (#1014)
|
há 7 anos atrás |
alter_configs_request_test.go
|
6ce9e9249a
Fix flaky TestAlterConfigsRequest
|
há 7 anos atrás |
alter_configs_response.go
|
f7466ea37d
Add Describe + AlterConfigs (#1014)
|
há 7 anos atrás |
alter_configs_response_test.go
|
f7466ea37d
Add Describe + AlterConfigs (#1014)
|
há 7 anos atrás |
api_versions_request.go
|
90a4cc632e
Fix race in broker version check
|
há 8 anos atrás |
api_versions_request_test.go
|
c5f4248429
Add support for latest protocol messages
|
há 8 anos atrás |
api_versions_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
há 8 anos atrás |
api_versions_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
há 8 anos atrás |
async_producer.go
|
587c5f694a
Revert to individual msg retries for non-idempotent
|
há 6 anos atrás |
async_producer_test.go
|
587c5f694a
Revert to individual msg retries for non-idempotent
|
há 6 anos atrás |
balance_strategy.go
|
dfeba0fb8f
Better documentation, extend test timeout
|
há 6 anos atrás |
balance_strategy_test.go
|
113ce2c044
Implement a higher-level consumer group
|
há 6 anos atrás |
broker.go
|
a381ef860d
exported Broker's rack setting
|
há 6 anos atrás |
broker_test.go
|
a381ef860d
exported Broker's rack setting
|
há 6 anos atrás |
client.go
|
4e5d477980
Idempotent Producer - batch retry logic
|
há 6 anos atrás |
client_test.go
|
5d35641fb5
Fix test
|
há 6 anos atrás |
client_tls_test.go
|
970116bc74
Support Go 1.11
|
há 6 anos atrás |
config.go
|
4e5d477980
Idempotent Producer - batch retry logic
|
há 6 anos atrás |
config_resource_type.go
|
f7466ea37d
Add Describe + AlterConfigs (#1014)
|
há 7 anos atrás |
config_test.go
|
4e5d477980
Idempotent Producer - batch retry logic
|
há 6 anos atrás |
consumer.go
|
807de26ba5
Fix block on control messages
|
há 6 anos atrás |
consumer_group.go
|
8cc8678245
fixed the function call with changed parameter ordering
|
há 6 anos atrás |
consumer_group_members.go
|
12fa6736bd
fixed some typo and added some comments
|
há 6 anos atrás |
consumer_group_members_test.go
|
cecb3d9807
Formating all files with gofmt -s
|
há 8 anos atrás |
consumer_group_test.go
|
a318f6ee7d
CI test fixes
|
há 6 anos atrás |
consumer_metadata_request.go
|
12fa6736bd
fixed some typo and added some comments
|
há 6 anos atrás |
consumer_metadata_request_test.go
|
a5a9b835af
refactor ConsumerMetadataRequest/Response to FindCoordinatorRequest/Response
|
há 7 anos atrás |
consumer_metadata_response.go
|
12fa6736bd
fixed some typo and added some comments
|
há 6 anos atrás |
consumer_metadata_response_test.go
|
d0340489e8
remove deprecated fields
|
há 7 anos atrás |
consumer_test.go
|
d3f8616135
Unblock consumer when receiving invalid FetchResponse
|
há 6 anos atrás |
crc32_field.go
|
07a5840e2e
Make polynomial a type
|
há 7 anos atrás |
create_partitions_request.go
|
7957e72eca
factor out getStringLength, use putArrayLength
|
há 7 anos atrás |
create_partitions_request_test.go
|
b3f149d4d2
add create partitions
|
há 7 anos atrás |
create_partitions_response.go
|
b3f149d4d2
add create partitions
|
há 7 anos atrás |
create_partitions_response_test.go
|
b3f149d4d2
add create partitions
|
há 7 anos atrás |
create_topics_request.go
|
b5ace411a0
add CreateTopicsRequest/Response
|
há 7 anos atrás |
create_topics_request_test.go
|
b5ace411a0
add CreateTopicsRequest/Response
|
há 7 anos atrás |
create_topics_response.go
|
b5ace411a0
add CreateTopicsRequest/Response
|
há 7 anos atrás |
create_topics_response_test.go
|
b5ace411a0
add CreateTopicsRequest/Response
|
há 7 anos atrás |
delete_groups_request.go
|
0f1c3e9b87
Add support for DeleteGroups
|
há 6 anos atrás |
delete_groups_request_test.go
|
0f1c3e9b87
Add support for DeleteGroups
|
há 6 anos atrás |
delete_groups_response.go
|
7d531e2557
Use native time type for ThrottleTime
|
há 6 anos atrás |
delete_groups_response_test.go
|
7d531e2557
Use native time type for ThrottleTime
|
há 6 anos atrás |
delete_records_request.go
|
76a6b90ec2
Add DeleteRecords operation to Broker
|
há 7 anos atrás |
delete_records_request_test.go
|
76a6b90ec2
Add DeleteRecords operation to Broker
|
há 7 anos atrás |
delete_records_response.go
|
76a6b90ec2
Add DeleteRecords operation to Broker
|
há 7 anos atrás |
delete_records_response_test.go
|
76a6b90ec2
Add DeleteRecords operation to Broker
|
há 7 anos atrás |
delete_topics_request.go
|
796e8cc60f
Added support for DeleteTopicsRequest V1
|
há 7 anos atrás |
delete_topics_request_test.go
|
796e8cc60f
Added support for DeleteTopicsRequest V1
|
há 7 anos atrás |
delete_topics_response.go
|
620549d3ed
add DeleteTopicsRequest/Response
|
há 7 anos atrás |
delete_topics_response_test.go
|
620549d3ed
add DeleteTopicsRequest/Response
|
há 7 anos atrás |
describe_configs_request.go
|
fbd8338718
Implement DescribeConfigsRequest v1 & v2
|
há 6 anos atrás |
describe_configs_request_test.go
|
fbd8338718
Implement DescribeConfigsRequest v1 & v2
|
há 6 anos atrás |
describe_configs_response.go
|
f9494b44e1
Implement DescribeConfigsResponse 1 & 2
|
há 6 anos atrás |
describe_configs_response_test.go
|
f9494b44e1
Implement DescribeConfigsResponse 1 & 2
|
há 6 anos atrás |
describe_groups_request.go
|
90a4cc632e
Fix race in broker version check
|
há 8 anos atrás |
describe_groups_request_test.go
|
1621c4959a
Add tests for all new request types.
|
há 9 anos atrás |
describe_groups_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
há 8 anos atrás |
describe_groups_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
há 8 anos atrás |
dev.yml
|
970116bc74
Support Go 1.11
|
há 6 anos atrás |
encoder_decoder.go
|
124e7c647e
Expose producer metrics with go-metrics
|
há 8 anos atrás |
end_txn_request.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
end_txn_request_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
end_txn_response.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
end_txn_response_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
errors.go
|
20b46c16c3
add error codes 61-72
|
há 6 anos atrás |
fetch_request.go
|
e42dc76c4e
Add missing Kafka versions
|
há 7 anos atrás |
fetch_request_test.go
|
953231c528
Add support for Kafka 0.11 in consumer
|
há 7 anos atrás |
fetch_response.go
|
8d1bd4c0d6
Handle overflow-only batch
|
há 6 anos atrás |
fetch_response_test.go
|
8d1bd4c0d6
Handle overflow-only batch
|
há 6 anos atrás |
find_coordinator_request.go
|
a5a9b835af
refactor ConsumerMetadataRequest/Response to FindCoordinatorRequest/Response
|
há 7 anos atrás |
find_coordinator_request_test.go
|
a5a9b835af
refactor ConsumerMetadataRequest/Response to FindCoordinatorRequest/Response
|
há 7 anos atrás |
find_coordinator_response.go
|
5a23d49f7a
remove rack from FindCoordinatorResponse and hardcode Broker-decode/encode version to 0
|
há 7 anos atrás |
find_coordinator_response_test.go
|
5a23d49f7a
remove rack from FindCoordinatorResponse and hardcode Broker-decode/encode version to 0
|
há 7 anos atrás |
functional_client_test.go
|
e931cc00ed
Stop test if client.Coordinator fails somehow
|
há 8 anos atrás |
functional_consumer_group_test.go
|
a318f6ee7d
CI test fixes
|
há 6 anos atrás |
functional_consumer_test.go
|
4e5d477980
Idempotent Producer - batch retry logic
|
há 6 anos atrás |
functional_offset_manager_test.go
|
ccab789d44
OffsetManager: match upstream mark/next behaviour
|
há 8 anos atrás |
functional_producer_test.go
|
7b655373d8
Expose request latency metric
|
há 8 anos atrás |
functional_test.go
|
2c40df751c
Fix version.satisfies so all tests run against 0.9
|
há 9 anos atrás |
heartbeat_request.go
|
90a4cc632e
Fix race in broker version check
|
há 8 anos atrás |
heartbeat_request_test.go
|
1621c4959a
Add tests for all new request types.
|
há 9 anos atrás |
heartbeat_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
há 8 anos atrás |
heartbeat_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
há 8 anos atrás |
init_producer_id_request.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
init_producer_id_request_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
init_producer_id_response.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
init_producer_id_response_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
join_group_request.go
|
e1b85f3400
Added versioning for join-group requests and responses
|
há 6 anos atrás |
join_group_request_test.go
|
e1b85f3400
Added versioning for join-group requests and responses
|
há 6 anos atrás |
join_group_response.go
|
e1b85f3400
Added versioning for join-group requests and responses
|
há 6 anos atrás |
join_group_response_test.go
|
e1b85f3400
Added versioning for join-group requests and responses
|
há 6 anos atrás |
leave_group_request.go
|
90a4cc632e
Fix race in broker version check
|
há 8 anos atrás |
leave_group_request_test.go
|
1621c4959a
Add tests for all new request types.
|
há 9 anos atrás |
leave_group_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
há 8 anos atrás |
leave_group_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
há 8 anos atrás |
length_field.go
|
682468dcc7
Fix partial messages handling
|
há 6 anos atrás |
list_groups_request.go
|
90a4cc632e
Fix race in broker version check
|
há 8 anos atrás |
list_groups_request_test.go
|
1621c4959a
Add tests for all new request types.
|
há 9 anos atrás |
list_groups_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
há 8 anos atrás |
list_groups_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
há 8 anos atrás |
message.go
|
3dd2f63504
Fix build without cgo
|
há 6 anos atrás |
message_set.go
|
8d1bd4c0d6
Handle overflow-only batch
|
há 6 anos atrás |
message_test.go
|
7d77064a4d
Revert "Add workaround for an empty zstd message"
|
há 6 anos atrás |
metadata_request.go
|
46821574be
Fix metadata requests on later versions
|
há 6 anos atrás |
metadata_request_test.go
|
bbdeda9fd2
Added support for Metadata Request/Response up to v5
|
há 7 anos atrás |
metadata_response.go
|
b4a8a4a8f6
add missing error check
|
há 6 anos atrás |
metadata_response_test.go
|
bbdeda9fd2
Added support for Metadata Request/Response up to v5
|
há 7 anos atrás |
metrics.go
|
124e7c647e
Expose producer metrics with go-metrics
|
há 8 anos atrás |
metrics_test.go
|
124e7c647e
Expose producer metrics with go-metrics
|
há 8 anos atrás |
mockbroker.go
|
f933fb4b0b
Add NewMockBrokerListener() so that it's possible to test TLS connections
|
há 7 anos atrás |
mockresponses.go
|
6c7918ef5a
Added OffsetFetch support up to v5
|
há 6 anos atrás |
offset_commit_request.go
|
3f16fb0e7a
Add support for newer OffsetCommit request/response
|
há 6 anos atrás |
offset_commit_request_test.go
|
3f16fb0e7a
Add support for newer OffsetCommit request/response
|
há 6 anos atrás |
offset_commit_response.go
|
3f16fb0e7a
Add support for newer OffsetCommit request/response
|
há 6 anos atrás |
offset_commit_response_test.go
|
3f16fb0e7a
Add support for newer OffsetCommit request/response
|
há 6 anos atrás |
offset_fetch_request.go
|
6c7918ef5a
Added OffsetFetch support up to v5
|
há 6 anos atrás |
offset_fetch_request_test.go
|
6c7918ef5a
Added OffsetFetch support up to v5
|
há 6 anos atrás |
offset_fetch_response.go
|
6c7918ef5a
Added OffsetFetch support up to v5
|
há 6 anos atrás |
offset_fetch_response_test.go
|
6c7918ef5a
Added OffsetFetch support up to v5
|
há 6 anos atrás |
offset_manager.go
|
fde71cc31f
Fix race
|
há 6 anos atrás |
offset_manager_test.go
|
433beec756
Fix test race
|
há 6 anos atrás |
offset_request.go
|
374f0e3cd0
Use a boolean to check that replica ID was set
|
há 6 anos atrás |
offset_request_test.go
|
8869e903fa
Add a getter for replica ID
|
há 6 anos atrás |
offset_response.go
|
e42dc76c4e
Add missing Kafka versions
|
há 7 anos atrás |
offset_response_test.go
|
d65b3fd46b
Support ListOffsetRequest v1 [KIP-79]
|
há 8 anos atrás |
packet_decoder.go
|
b3f149d4d2
add create partitions
|
há 7 anos atrás |
packet_encoder.go
|
b3f149d4d2
add create partitions
|
há 7 anos atrás |
partitioner.go
|
a74fb772b5
update name of partitioner option so it makes more sense
|
há 6 anos atrás |
partitioner_test.go
|
9b2c4d6e2c
Make Partitioner.RequiresConsistency vary per-message
|
há 6 anos atrás |
prep_encoder.go
|
b3f149d4d2
add create partitions
|
há 7 anos atrás |
produce_request.go
|
5468405d94
Expose Records union fields
|
há 7 anos atrás |
produce_request_test.go
|
7ad9a62d7d
Fix TestProduceRequest
|
há 7 anos atrás |
produce_response.go
|
8e2b04b363
Added support for Idempotent Producer
|
há 6 anos atrás |
produce_response_test.go
|
ca457b7003
Support ProduceResponse v1 and v2 encoding
|
há 7 anos atrás |
produce_set.go
|
4e5d477980
Idempotent Producer - batch retry logic
|
há 6 anos atrás |
produce_set_test.go
|
4e5d477980
Idempotent Producer - batch retry logic
|
há 6 anos atrás |
real_decoder.go
|
7957e72eca
factor out getStringLength, use putArrayLength
|
há 7 anos atrás |
real_encoder.go
|
b3f149d4d2
add create partitions
|
há 7 anos atrás |
record.go
|
5fd60c2be0
Add producer support for Kafka 0.11 Records
|
há 7 anos atrás |
record_batch.go
|
3dd2f63504
Fix build without cgo
|
há 6 anos atrás |
record_test.go
|
780ea152be
Fix gzip compression encode/decode test
|
há 7 anos atrás |
records.go
|
8d1bd4c0d6
Handle overflow-only batch
|
há 6 anos atrás |
records_test.go
|
5468405d94
Expose Records union fields
|
há 7 anos atrás |
request.go
|
0f1c3e9b87
Add support for DeleteGroups
|
há 6 anos atrás |
request_test.go
|
f4fbc32080
Simple validation of required version
|
há 7 anos atrás |
response_header.go
|
66411d8222
Cleanup a bunch more error formats
|
há 9 anos atrás |
response_header_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
há 11 anos atrás |
sarama.go
|
7b655373d8
Expose request latency metric
|
há 8 anos atrás |
sasl_handshake_request.go
|
90a4cc632e
Fix race in broker version check
|
há 8 anos atrás |
sasl_handshake_request_test.go
|
c5f4248429
Add support for latest protocol messages
|
há 8 anos atrás |
sasl_handshake_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
há 8 anos atrás |
sasl_handshake_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
há 8 anos atrás |
sync_group_request.go
|
124e7c647e
Expose producer metrics with go-metrics
|
há 8 anos atrás |
sync_group_request_test.go
|
1621c4959a
Add tests for all new request types.
|
há 9 anos atrás |
sync_group_response.go
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
há 8 anos atrás |
sync_group_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
há 8 anos atrás |
sync_producer.go
|
1e2740380a
Do not modify ProducerMessage.MetaData during the whole publishing process.
|
há 6 anos atrás |
sync_producer_test.go
|
cecb3d9807
Formating all files with gofmt -s
|
há 8 anos atrás |
timestamp.go
|
ed80c61d79
Make timestamp fields of type time.Time and time.Duration
|
há 7 anos atrás |
txn_offset_commit_request.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
txn_offset_commit_request_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
txn_offset_commit_response.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
txn_offset_commit_response_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
há 7 anos atrás |
utils.go
|
204142a0b5
Add version defs for patch releases
|
há 6 anos atrás |
utils_test.go
|
a709f2d5ca
String functions for KafkaVersion (#989)
|
há 7 anos atrás |
zstd_cgo.go
|
3dd2f63504
Fix build without cgo
|
há 6 anos atrás |
zstd_fallback.go
|
3dd2f63504
Fix build without cgo
|
há 6 anos atrás |