|
.github
|
ad70aac2ad
Merge pull request #1695 from zendesk/ktsanaktsidis/docker_compose_tests
|
il y a 4 ans |
|
examples
|
31886822ab
Fix typos
|
il y a 4 ans |
|
mocks
|
88b0e98974
removes unused fields/methods
|
il y a 4 ans |
|
tools
|
31886822ab
Fix typos
|
il y a 4 ans |
|
vagrant
|
42bbd066c0
Delete vagrant test harness setup
|
il y a 4 ans |
|
.gitignore
|
f33a0afab2
Add docker-composed based functional test harness
|
il y a 4 ans |
|
.golangci.yml
|
db2dbead92
Update golangci-lint to v1.27.0
|
il y a 4 ans |
|
CHANGELOG.md
|
5f7121b03e
Add changelog for 1.26.1
|
il y a 4 ans |
|
LICENSE
|
8da9fa72b8
Technically Shopify owns the repo
|
il y a 6 ans |
|
Makefile
|
d8f6eca924
Run the linter across functional tests as well
|
il y a 4 ans |
|
README.md
|
535a77dcfe
Update supported kafka versions in README
|
il y a 4 ans |
|
Vagrantfile
|
b8c5f7cfe1
Add GitHub Actions workflows, use golangci-lint
|
il y a 4 ans |
|
acl_bindings.go
|
29d30a3c4c
Refactor misspelled word Resouce to Resource
|
il y a 5 ans |
|
acl_create_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
acl_create_request_test.go
|
29d30a3c4c
Refactor misspelled word Resouce to Resource
|
il y a 5 ans |
|
acl_create_response.go
|
31886822ab
Fix typos
|
il y a 4 ans |
|
acl_create_response_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
il y a 7 ans |
|
acl_delete_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
acl_delete_request_test.go
|
66abce6c25
Implements v1 of {Create,Describe,Delete}AclRequest
|
il y a 5 ans |
|
acl_delete_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
acl_delete_response_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
il y a 7 ans |
|
acl_describe_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
acl_describe_request_test.go
|
66abce6c25
Implements v1 of {Create,Describe,Delete}AclRequest
|
il y a 5 ans |
|
acl_describe_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
acl_describe_response_test.go
|
86d6f390cf
add Describe/Create/DeleteAcls
|
il y a 7 ans |
|
acl_filter.go
|
66abce6c25
Implements v1 of {Create,Describe,Delete}AclRequest
|
il y a 5 ans |
|
acl_types.go
|
483263c182
using iota for constants and some style fixes
|
il y a 5 ans |
|
add_offsets_to_txn_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
add_offsets_to_txn_request_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
il y a 7 ans |
|
add_offsets_to_txn_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
add_offsets_to_txn_response_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
il y a 7 ans |
|
add_partitions_to_txn_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
add_partitions_to_txn_request_test.go
|
07ff436a6d
Fix linter errors
|
il y a 4 ans |
|
add_partitions_to_txn_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
add_partitions_to_txn_response_test.go
|
07ff436a6d
Fix linter errors
|
il y a 4 ans |
|
admin.go
|
9c1c364bbc
Merge pull request #1639 from agriffaut/patch/handle-errors-without-message
|
il y a 4 ans |
|
admin_test.go
|
9c1c364bbc
Merge pull request #1639 from agriffaut/patch/handle-errors-without-message
|
il y a 4 ans |
|
alter_configs_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
alter_configs_request_test.go
|
07ff436a6d
Fix linter errors
|
il y a 4 ans |
|
alter_configs_response.go
|
31886822ab
Fix typos
|
il y a 4 ans |
|
alter_configs_response_test.go
|
07ff436a6d
Fix linter errors
|
il y a 4 ans |
|
alter_partition_reassignments_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
alter_partition_reassignments_request_test.go
|
31886822ab
Fix typos
|
il y a 4 ans |
|
alter_partition_reassignments_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
alter_partition_reassignments_response_test.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
api_versions_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
api_versions_request_test.go
|
574371b50a
removes var when assigning a value immediately
|
il y a 4 ans |
|
api_versions_response.go
|
31886822ab
Fix typos
|
il y a 4 ans |
|
api_versions_response_test.go
|
574371b50a
removes var when assigning a value immediately
|
il y a 4 ans |
|
async_producer.go
|
ab2cd98eff
Initial pass at a basic SerDe implementation
|
il y a 4 ans |
|
async_producer_test.go
|
9df3038ad4
Fix "broker received out of order sequence" when brokers die
|
il y a 4 ans |
|
balance_strategy.go
|
88b0e98974
removes unused fields/methods
|
il y a 4 ans |
|
balance_strategy_test.go
|
f6fb4afcdd
simple compare statement
|
il y a 4 ans |
|
broker.go
|
5ff9581b10
more go like code, returning earlier
|
il y a 4 ans |
|
broker_test.go
|
c6eb1d42e7
fix: Allow TLS to work over socks proxy. (#1666)
|
il y a 4 ans |
|
client.go
|
26bbb0417c
bugfix: remove broker which is not exist in metadata
|
il y a 4 ans |
|
client_test.go
|
31886822ab
Fix typos
|
il y a 4 ans |
|
client_tls_test.go
|
1628dc1dbf
use net.SplitHostPort and don't separate conf var
|
il y a 4 ans |
|
compress.go
|
c6ac2d9ca8
Revert "refresh 3rdparty dependencies"
|
il y a 4 ans |
|
config.go
|
ab2cd98eff
Initial pass at a basic SerDe implementation
|
il y a 4 ans |
|
config_resource_type.go
|
fb8b9b5a10
fix: use the broker for any admin on BrokerConfig
|
il y a 5 ans |
|
config_test.go
|
159fd52ba1
rm validation and the corresponding test
|
il y a 4 ans |
|
consumer.go
|
ab2cd98eff
Initial pass at a basic SerDe implementation
|
il y a 4 ans |
|
consumer_group.go
|
cb9d1e8b85
Add support for manual commit to ConsumerGroup
|
il y a 4 ans |
|
consumer_group_members.go
|
12fa6736bd
fixed some typo and added some comments
|
il y a 6 ans |
|
consumer_group_members_test.go
|
cecb3d9807
Formating all files with gofmt -s
|
il y a 7 ans |
|
consumer_group_test.go
|
8b72385c90
adds a note about consumer groups Consume method
|
il y a 4 ans |
|
consumer_metadata_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
consumer_metadata_request_test.go
|
a5a9b835af
refactor ConsumerMetadataRequest/Response to FindCoordinatorRequest/Response
|
il y a 7 ans |
|
consumer_metadata_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
consumer_metadata_response_test.go
|
e6c029ff1a
Revert "Synced error names and descriptions with the kafka's protocol"
|
il y a 6 ans |
|
consumer_test.go
|
6159078aac
Merge pull request #1644 from zendesk/ktsanaktsidis/fix_session_id_thrashing
|
il y a 4 ans |
|
control_record.go
|
3328055d57
another pull request to please lint gods
|
il y a 5 ans |
|
control_record_test.go
|
57215a08ac
midway on consumer test
|
il y a 5 ans |
|
crc32_field.go
|
47ae433aa8
Reuse lengthFields
|
il y a 5 ans |
|
create_partitions_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
create_partitions_request_test.go
|
07ff436a6d
Fix linter errors
|
il y a 4 ans |
|
create_partitions_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
create_partitions_response_test.go
|
07ff436a6d
Fix linter errors
|
il y a 4 ans |
|
create_topics_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
create_topics_request_test.go
|
07ff436a6d
Fix linter errors
|
il y a 4 ans |
|
create_topics_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
create_topics_response_test.go
|
07ff436a6d
Fix linter errors
|
il y a 4 ans |
|
decompress.go
|
c6ac2d9ca8
Revert "refresh 3rdparty dependencies"
|
il y a 4 ans |
|
delete_groups_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
delete_groups_request_test.go
|
0f1c3e9b87
Add support for DeleteGroups
|
il y a 6 ans |
|
delete_groups_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
delete_groups_response_test.go
|
7d531e2557
Use native time type for ThrottleTime
|
il y a 6 ans |
|
delete_records_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
delete_records_request_test.go
|
76a6b90ec2
Add DeleteRecords operation to Broker
|
il y a 6 ans |
|
delete_records_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
delete_records_response_test.go
|
76a6b90ec2
Add DeleteRecords operation to Broker
|
il y a 6 ans |
|
delete_topics_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
delete_topics_request_test.go
|
796e8cc60f
Added support for DeleteTopicsRequest V1
|
il y a 6 ans |
|
delete_topics_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
delete_topics_response_test.go
|
620549d3ed
add DeleteTopicsRequest/Response
|
il y a 7 ans |
|
describe_configs_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
describe_configs_request_test.go
|
574371b50a
removes var when assigning a value immediately
|
il y a 4 ans |
|
describe_configs_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
describe_configs_response_test.go
|
6d92277014
Sets ConfigEntry.Default flag in addition to the ConfigEntry.Source for Kafka versions > V1_1_0_0 (#1594)
|
il y a 4 ans |
|
describe_groups_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
describe_groups_request_test.go
|
1621c4959a
Add tests for all new request types.
|
il y a 9 ans |
|
describe_groups_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
describe_groups_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
il y a 8 ans |
|
describe_log_dirs_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
describe_log_dirs_request_test.go
|
07ff436a6d
Fix linter errors
|
il y a 4 ans |
|
describe_log_dirs_response.go
|
d89fa9dc14
Add DescribeLogDirs to admin client
|
il y a 4 ans |
|
describe_log_dirs_response_test.go
|
07ff436a6d
Fix linter errors
|
il y a 4 ans |
|
deserializer.go
|
ab2cd98eff
Initial pass at a basic SerDe implementation
|
il y a 4 ans |
|
dev.yml
|
97156e8036
Bump Go to version 1.14.3
|
il y a 4 ans |
|
docker-compose.yml
|
75ff946b52
Map confluent platform -> kafka version
|
il y a 4 ans |
|
encoder_decoder.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
end_txn_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
end_txn_request_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
il y a 7 ans |
|
end_txn_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
end_txn_response_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
il y a 7 ans |
|
errors.go
|
ab2cd98eff
Initial pass at a basic SerDe implementation
|
il y a 4 ans |
|
fetch_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
fetch_request_test.go
|
48ba0ca84f
feat: protocol support for V11 fetch w/ rackID
|
il y a 4 ans |
|
fetch_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
fetch_response_test.go
|
48ba0ca84f
feat: protocol support for V11 fetch w/ rackID
|
il y a 4 ans |
|
find_coordinator_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
find_coordinator_request_test.go
|
a5a9b835af
refactor ConsumerMetadataRequest/Response to FindCoordinatorRequest/Response
|
il y a 7 ans |
|
find_coordinator_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
find_coordinator_response_test.go
|
e6c029ff1a
Revert "Synced error names and descriptions with the kafka's protocol"
|
il y a 6 ans |
|
functional_client_test.go
|
f33a0afab2
Add docker-composed based functional test harness
|
il y a 4 ans |
|
functional_consumer_group_test.go
|
f33a0afab2
Add docker-composed based functional test harness
|
il y a 4 ans |
|
functional_consumer_test.go
|
f33a0afab2
Add docker-composed based functional test harness
|
il y a 4 ans |
|
functional_offset_manager_test.go
|
f33a0afab2
Add docker-composed based functional test harness
|
il y a 4 ans |
|
functional_producer_test.go
|
ad70aac2ad
Merge pull request #1695 from zendesk/ktsanaktsidis/docker_compose_tests
|
il y a 4 ans |
|
functional_test.go
|
cfd5999fa1
Remove redundant hard-coding of env.KafkaVersion
|
il y a 4 ans |
|
go.mod
|
5933302b8b
updated zstd dependency to latest (#1741)
|
il y a 4 ans |
|
go.sum
|
5933302b8b
updated zstd dependency to latest (#1741)
|
il y a 4 ans |
|
gssapi_kerberos.go
|
b5764af1c4
Merge pull request #1697 from kvch/revert-removing-for-of-asn1
|
il y a 4 ans |
|
heartbeat_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
heartbeat_request_test.go
|
574371b50a
removes var when assigning a value immediately
|
il y a 4 ans |
|
heartbeat_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
heartbeat_response_test.go
|
574371b50a
removes var when assigning a value immediately
|
il y a 4 ans |
|
init_producer_id_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
init_producer_id_request_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
il y a 7 ans |
|
init_producer_id_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
init_producer_id_response_test.go
|
d81319704e
add transaction-related request/responses (22, 24, 25, 26, 28)
|
il y a 7 ans |
|
join_group_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
join_group_request_test.go
|
e1b85f3400
Added versioning for join-group requests and responses
|
il y a 6 ans |
|
join_group_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
join_group_response_test.go
|
e1b85f3400
Added versioning for join-group requests and responses
|
il y a 6 ans |
|
kerberos_client.go
|
dd2a9df207
Formar NewKerberosClient comments acording to golang standad, added test for DisablePAFXFast
|
il y a 4 ans |
|
kerberos_client_test.go
|
dd2a9df207
Formar NewKerberosClient comments acording to golang standad, added test for DisablePAFXFast
|
il y a 4 ans |
|
leave_group_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
leave_group_request_test.go
|
574371b50a
removes var when assigning a value immediately
|
il y a 4 ans |
|
leave_group_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
leave_group_response_test.go
|
e6c029ff1a
Revert "Synced error names and descriptions with the kafka's protocol"
|
il y a 6 ans |
|
length_field.go
|
47ae433aa8
Reuse lengthFields
|
il y a 5 ans |
|
list_groups_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
list_groups_request_test.go
|
1621c4959a
Add tests for all new request types.
|
il y a 9 ans |
|
list_groups_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
list_groups_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
il y a 8 ans |
|
list_partition_reassignments_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
list_partition_reassignments_request_test.go
|
31886822ab
Fix typos
|
il y a 4 ans |
|
list_partition_reassignments_response.go
|
89f6240301
fix decoding response with empty topic list
|
il y a 4 ans |
|
list_partition_reassignments_response_test.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
message.go
|
07ff436a6d
Fix linter errors
|
il y a 4 ans |
|
message_set.go
|
47ae433aa8
Reuse lengthFields
|
il y a 5 ans |
|
message_test.go
|
7d77064a4d
Revert "Add workaround for an empty zstd message"
|
il y a 6 ans |
|
metadata_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
metadata_request_test.go
|
ac7342c248
fix tests
|
il y a 4 ans |
|
metadata_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
metadata_response_test.go
|
e6c029ff1a
Revert "Synced error names and descriptions with the kafka's protocol"
|
il y a 6 ans |
|
metrics.go
|
82be3b4da9
Unregister all broker metrics on broker stop
|
il y a 6 ans |
|
metrics_test.go
|
2db8d8aea2
Add requests-in-flight metric
|
il y a 4 ans |
|
mockbroker.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
mockkerberos.go
|
c6ac2d9ca8
Revert "refresh 3rdparty dependencies"
|
il y a 4 ans |
|
mockresponses.go
|
9c1c364bbc
Merge pull request #1639 from agriffaut/patch/handle-errors-without-message
|
il y a 4 ans |
|
offset_commit_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
offset_commit_request_test.go
|
3f16fb0e7a
Add support for newer OffsetCommit request/response
|
il y a 6 ans |
|
offset_commit_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
offset_commit_response_test.go
|
3f16fb0e7a
Add support for newer OffsetCommit request/response
|
il y a 6 ans |
|
offset_fetch_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
offset_fetch_request_test.go
|
6c7918ef5a
Added OffsetFetch support up to v5
|
il y a 6 ans |
|
offset_fetch_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
offset_fetch_response_test.go
|
6c7918ef5a
Added OffsetFetch support up to v5
|
il y a 6 ans |
|
offset_manager.go
|
cb9d1e8b85
Add support for manual commit to ConsumerGroup
|
il y a 4 ans |
|
offset_manager_test.go
|
cb9d1e8b85
Add support for manual commit to ConsumerGroup
|
il y a 4 ans |
|
offset_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
offset_request_test.go
|
8869e903fa
Add a getter for replica ID
|
il y a 6 ans |
|
offset_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
offset_response_test.go
|
d65b3fd46b
Support ListOffsetRequest v1 [KIP-79]
|
il y a 8 ans |
|
packet_decoder.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
packet_encoder.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
partitioner.go
|
a74fb772b5
update name of partitioner option so it makes more sense
|
il y a 6 ans |
|
partitioner_test.go
|
9b2c4d6e2c
Make Partitioner.RequiresConsistency vary per-message
|
il y a 6 ans |
|
prep_encoder.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
produce_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
produce_request_test.go
|
7ad9a62d7d
Fix TestProduceRequest
|
il y a 6 ans |
|
produce_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
produce_response_test.go
|
37faed7ffc
enables zstd bumping the right things
|
il y a 5 ans |
|
produce_set.go
|
9df3038ad4
Fix "broker received out of order sequence" when brokers die
|
il y a 4 ans |
|
produce_set_test.go
|
07ff436a6d
Fix linter errors
|
il y a 4 ans |
|
real_decoder.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
real_encoder.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
record.go
|
b68420a29b
control record + isTransactional bit parsing
|
il y a 5 ans |
|
record_batch.go
|
47ae433aa8
Reuse lengthFields
|
il y a 5 ans |
|
record_test.go
|
31886822ab
Fix typos
|
il y a 4 ans |
|
records.go
|
88b0e98974
removes unused fields/methods
|
il y a 4 ans |
|
records_test.go
|
6b86562f5c
ut transactional flag
|
il y a 5 ans |
|
request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
request_test.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
response_header.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
response_header_test.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
sarama.go
|
2db8d8aea2
Add requests-in-flight metric
|
il y a 4 ans |
|
sasl_authenticate_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
sasl_authenticate_request_test.go
|
574371b50a
removes var when assigning a value immediately
|
il y a 4 ans |
|
sasl_authenticate_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
sasl_authenticate_response_test.go
|
31886822ab
Fix typos
|
il y a 4 ans |
|
sasl_handshake_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
sasl_handshake_request_test.go
|
574371b50a
removes var when assigning a value immediately
|
il y a 4 ans |
|
sasl_handshake_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
sasl_handshake_response_test.go
|
574371b50a
removes var when assigning a value immediately
|
il y a 4 ans |
|
serde.go
|
ab2cd98eff
Initial pass at a basic SerDe implementation
|
il y a 4 ans |
|
serializer.go
|
ab2cd98eff
Initial pass at a basic SerDe implementation
|
il y a 4 ans |
|
sticky_assignor_user_data.go
|
01915cf82e
Add sticky partition assignor
|
il y a 5 ans |
|
sticky_assignor_user_data_test.go
|
01915cf82e
Add sticky partition assignor
|
il y a 5 ans |
|
sync_group_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
sync_group_request_test.go
|
1621c4959a
Add tests for all new request types.
|
il y a 9 ans |
|
sync_group_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
sync_group_response_test.go
|
37654da7e1
Add support for decoding versioned responses
|
il y a 8 ans |
|
sync_producer.go
|
1e2740380a
Do not modify ProducerMessage.MetaData during the whole publishing process.
|
il y a 6 ans |
|
sync_producer_test.go
|
e3ecf7b088
added offline replicas operation to client for kafka version >= 1.x
|
il y a 5 ans |
|
timestamp.go
|
ed80c61d79
Make timestamp fields of type time.Time and time.Duration
|
il y a 7 ans |
|
txn_offset_commit_request.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
txn_offset_commit_request_test.go
|
07ff436a6d
Fix linter errors
|
il y a 4 ans |
|
txn_offset_commit_response.go
|
2d2326efcf
feat: Add alter and list partition reassignments
|
il y a 4 ans |
|
txn_offset_commit_response_test.go
|
07ff436a6d
Fix linter errors
|
il y a 4 ans |
|
utils.go
|
98976f5904
Add support for kafka 2.5.0
|
il y a 4 ans |
|
utils_test.go
|
a709f2d5ca
String functions for KafkaVersion (#989)
|
il y a 7 ans |
|
zstd.go
|
8a56b725ac
enables goimports lint
|
il y a 4 ans |
Lourens Naudé
