 |
|
|
|
.. (parent) |
 |
d |
rwxr-xr-x |
146 |
.github
|
 |
d |
rwxr-xr-x |
104 |
.pc
|
 |
d |
rwxr-xr-x |
4,096 |
debian
|
 |
d |
rwxr-xr-x |
4,096 |
examples
|
 |
d |
rwxr-xr-x |
30 |
internal
|
 |
d |
rwxr-xr-x |
4,096 |
mocks
|
 |
d |
rwxr-xr-x |
4,096 |
tools
|
 |
- |
rw-r--r-- |
321 |
.gitignore
|
 |
- |
rw-r--r-- |
2,057 |
.golangci.yml
|
 |
- |
rw-r--r-- |
1,303 |
.pre-commit-config.yaml
|
 |
- |
rw-r--r-- |
65 |
.whitesource
|
 |
- |
rw-r--r-- |
92,765 |
CHANGELOG.md
|
 |
- |
rw-r--r-- |
5,226 |
CODE_OF_CONDUCT.md
|
 |
- |
rw-r--r-- |
4,468 |
CONTRIBUTING.md
|
 |
- |
rw-r--r-- |
3,568 |
Dockerfile.kafka
|
 |
- |
rw-r--r-- |
1,102 |
LICENSE.md
|
 |
- |
rw-r--r-- |
1,308 |
Makefile
|
 |
- |
rw-r--r-- |
2,109 |
README.md
|
 |
- |
rw-r--r-- |
752 |
SECURITY.md
|
 |
- |
rw-r--r-- |
354 |
Vagrantfile
|
 |
- |
rw-r--r-- |
2,740 |
acl_bindings.go
|
 |
- |
rw-r--r-- |
1,866 |
acl_create_request.go
|
 |
- |
rw-r--r-- |
1,514 |
acl_create_request_test.go
|
 |
- |
rw-r--r-- |
2,287 |
acl_create_response.go
|
 |
- |
rw-r--r-- |
785 |
acl_create_response_test.go
|
 |
- |
rw-r--r-- |
1,334 |
acl_delete_request.go
|
 |
- |
rw-r--r-- |
2,456 |
acl_delete_request_test.go
|
 |
- |
rw-r--r-- |
3,534 |
acl_delete_response.go
|
 |
- |
rw-r--r-- |
861 |
acl_delete_response_test.go
|
 |
- |
rw-r--r-- |
984 |
acl_describe_request.go
|
 |
- |
rw-r--r-- |
1,517 |
acl_describe_request_test.go
|
 |
- |
rw-r--r-- |
1,993 |
acl_describe_response.go
|
 |
- |
rw-r--r-- |
961 |
acl_describe_response_test.go
|
 |
- |
rw-r--r-- |
1,645 |
acl_filter.go
|
 |
- |
rw-r--r-- |
6,761 |
acl_types.go
|
 |
- |
rw-r--r-- |
1,840 |
acl_types_test.go
|
 |
- |
rw-r--r-- |
1,495 |
add_offsets_to_txn_request.go
|
 |
- |
rw-r--r-- |
435 |
add_offsets_to_txn_request_test.go
|
 |
- |
rw-r--r-- |
1,399 |
add_offsets_to_txn_response.go
|
 |
- |
rw-r--r-- |
358 |
add_offsets_to_txn_response_test.go
|
 |
- |
rw-r--r-- |
1,971 |
add_partitions_to_txn_request.go
|
 |
- |
rw-r--r-- |
548 |
add_partitions_to_txn_request_test.go
|
 |
- |
rw-r--r-- |
2,669 |
add_partitions_to_txn_response.go
|
 |
- |
rw-r--r-- |
565 |
add_partitions_to_txn_response_test.go
|
 |
- |
rw-r--r-- |
38,883 |
admin.go
|
 |
- |
rw-r--r-- |
51,734 |
admin_test.go
|
 |
- |
rw-r--r-- |
4,264 |
alter_client_quotas_request.go
|
 |
- |
rw-r--r-- |
4,726 |
alter_client_quotas_request_test.go
|
 |
- |
rw-r--r-- |
3,729 |
alter_client_quotas_response.go
|
 |
- |
rw-r--r-- |
2,896 |
alter_client_quotas_response_test.go
|
 |
- |
rw-r--r-- |
2,728 |
alter_configs_request.go
|
 |
- |
rw-r--r-- |
1,911 |
alter_configs_request_test.go
|
 |
- |
rw-r--r-- |
2,852 |
alter_configs_response.go
|
 |
- |
rw-r--r-- |
897 |
alter_configs_response_test.go
|
 |
- |
rw-r--r-- |
3,260 |
alter_partition_reassignments_request.go
|
 |
- |
rw-r--r-- |
1,658 |
alter_partition_reassignments_request_test.go
|
 |
- |
rw-r--r-- |
4,128 |
alter_partition_reassignments_response.go
|
 |
- |
rw-r--r-- |
1,280 |
alter_partition_reassignments_response_test.go
|
 |
- |
rw-r--r-- |
3,697 |
alter_user_scram_credentials_request.go
|
 |
- |
rw-r--r-- |
1,835 |
alter_user_scram_credentials_request_test.go
|
 |
- |
rw-r--r-- |
2,363 |
alter_user_scram_credentials_response.go
|
 |
- |
rw-r--r-- |
1,073 |
alter_user_scram_credentials_response_test.go
|
 |
- |
rw-r--r-- |
3,412 |
api_versions.go
|
 |
- |
rw-r--r-- |
1,701 |
api_versions_request.go
|
 |
- |
rw-r--r-- |
586 |
api_versions_request_test.go
|
 |
- |
rw-r--r-- |
3,718 |
api_versions_response.go
|
 |
- |
rw-r--r-- |
1,890 |
api_versions_response_test.go
|
 |
- |
rw-r--r-- |
2,750 |
api_versions_test.go
|
 |
- |
rw-r--r-- |
43,665 |
async_producer.go
|
 |
- |
rw-r--r-- |
72,959 |
async_producer_test.go
|
 |
- |
rw-r--r-- |
45,639 |
balance_strategy.go
|
 |
- |
rw-r--r-- |
74,874 |
balance_strategy_test.go
|
 |
- |
rw-r--r-- |
55,610 |
broker.go
|
 |
- |
rw-r--r-- |
43,718 |
broker_test.go
|
 |
- |
rw-r--r-- |
42,311 |
client.go
|
 |
- |
rw-r--r-- |
38,505 |
client_test.go
|
 |
- |
rw-r--r-- |
6,237 |
client_tls_test.go
|
 |
- |
rw-r--r-- |
3,962 |
compress.go
|
 |
- |
rw-r--r-- |
40,663 |
config.go
|
 |
- |
rw-r--r-- |
599 |
config_resource_type.go
|
 |
- |
rw-r--r-- |
17,256 |
config_test.go
|
 |
- |
rw-r--r-- |
36,584 |
consumer.go
|
 |
- |
rw-r--r-- |
35,383 |
consumer_group.go
|
 |
- |
rw-r--r-- |
1,399 |
consumer_group_example_test.go
|
 |
- |
rw-r--r-- |
3,856 |
consumer_group_members.go
|
 |
- |
rw-r--r-- |
3,531 |
consumer_group_members_test.go
|
 |
- |
rw-r--r-- |
7,122 |
consumer_group_test.go
|
 |
- |
rw-r--r-- |
1,207 |
consumer_metadata_request.go
|
 |
- |
rw-r--r-- |
657 |
consumer_metadata_request_test.go
|
 |
- |
rw-r--r-- |
2,158 |
consumer_metadata_response.go
|
 |
- |
rw-r--r-- |
1,215 |
consumer_metadata_response_test.go
|
 |
- |
rw-r--r-- |
64,911 |
consumer_test.go
|
 |
- |
rw-r--r-- |
1,872 |
control_record.go
|
 |
- |
rw-r--r-- |
1,755 |
control_record_test.go
|
 |
- |
rw-r--r-- |
1,774 |
crc32_field.go
|
 |
- |
rw-r--r-- |
2,665 |
create_partitions_request.go
|
 |
- |
rw-r--r-- |
1,149 |
create_partitions_request_test.go
|
 |
- |
rw-r--r-- |
2,652 |
create_partitions_response.go
|
 |
- |
rw-r--r-- |
2,175 |
create_partitions_response_test.go
|
 |
- |
rw-r--r-- |
5,301 |
create_topics_request.go
|
 |
- |
rw-r--r-- |
1,052 |
create_topics_request_test.go
|
 |
- |
rw-r--r-- |
2,965 |
create_topics_response.go
|
 |
- |
rw-r--r-- |
1,607 |
create_topics_response_test.go
|
 |
- |
rw-r--r-- |
2,215 |
decompress.go
|
 |
- |
rw-r--r-- |
962 |
delete_groups_request.go
|
 |
- |
rw-r--r-- |
835 |
delete_groups_request_test.go
|
 |
- |
rw-r--r-- |
1,768 |
delete_groups_response.go
|
 |
- |
rw-r--r-- |
1,621 |
delete_groups_response_test.go
|
 |
- |
rw-r--r-- |
1,925 |
delete_offsets_request.go
|
 |
- |
rw-r--r-- |
1,005 |
delete_offsets_request_test.go
|
 |
- |
rw-r--r-- |
2,620 |
delete_offsets_response.go
|
 |
- |
rw-r--r-- |
1,691 |
delete_offsets_response_test.go
|
 |
- |
rw-r--r-- |
2,975 |
delete_records_request.go
|
 |
- |
rw-r--r-- |
638 |
delete_records_request_test.go
|
 |
- |
rw-r--r-- |
3,769 |
delete_records_response.go
|
 |
- |
rw-r--r-- |
765 |
delete_records_response_test.go
|
 |
- |
rw-r--r-- |
1,599 |
delete_topics_request.go
|
 |
- |
rw-r--r-- |
635 |
delete_topics_request_test.go
|
 |
- |
rw-r--r-- |
1,864 |
delete_topics_response.go
|
 |
- |
rw-r--r-- |
616 |
delete_topics_response_test.go
|
 |
- |
rw-r--r-- |
3,326 |
describe_client_quotas_request.go
|
 |
- |
rw-r--r-- |
2,379 |
describe_client_quotas_request_test.go
|
 |
- |
rw-r--r-- |
5,442 |
describe_client_quotas_response.go
|
 |
- |
rw-r--r-- |
3,252 |
describe_client_quotas_response_test.go
|
 |
- |
rw-r--r-- |
2,261 |
describe_configs_request.go
|
 |
- |
rw-r--r-- |
2,781 |
describe_configs_request_test.go
|
 |
- |
rw-r--r-- |
6,325 |
describe_configs_response.go
|
 |
- |
rw-r--r-- |
6,500 |
describe_configs_response_test.go
|
 |
- |
rw-r--r-- |
1,422 |
describe_groups_request.go
|
 |
- |
rw-r--r-- |
1,801 |
describe_groups_request_test.go
|
 |
- |
rw-r--r-- |
7,108 |
describe_groups_response.go
|
 |
- |
rw-r--r-- |
7,062 |
describe_groups_response_test.go
|
 |
- |
rw-r--r-- |
2,109 |
describe_log_dirs_request.go
|
 |
- |
rw-r--r-- |
887 |
describe_log_dirs_request_test.go
|
 |
- |
rw-r--r-- |
5,102 |
describe_log_dirs_response.go
|
 |
- |
rw-r--r-- |
2,102 |
describe_log_dirs_response_test.go
|
 |
- |
rw-r--r-- |
1,967 |
describe_user_scram_credentials_request.go
|
 |
- |
rw-r--r-- |
866 |
describe_user_scram_credentials_request_test.go
|
 |
- |
rw-r--r-- |
4,185 |
describe_user_scram_credentials_response.go
|
 |
- |
rw-r--r-- |
1,549 |
describe_user_scram_credentials_response_test.go
|
 |
- |
rw-r--r-- |
115 |
dev.yml
|
 |
- |
rw-r--r-- |
11,132 |
docker-compose.yml
|
 |
- |
rw-r--r-- |
2,588 |
elect_leaders_request.go
|
 |
- |
rw-r--r-- |
684 |
elect_leaders_request_test.go
|
 |
- |
rw-r--r-- |
3,764 |
elect_leaders_response.go
|
 |
- |
rw-r--r-- |
736 |
elect_leaders_response_test.go
|
 |
- |
rw-r--r-- |
190 |
election_type.go
|
 |
- |
rw-r--r-- |
2,218 |
encoder_decoder.go
|
 |
- |
rw-r--r-- |
1,309 |
encoder_decoder_fuzz_test.go
|
 |
- |
rw-r--r-- |
1,298 |
end_txn_request.go
|
 |
- |
rw-r--r-- |
364 |
end_txn_request_test.go
|
 |
- |
rw-r--r-- |
1,200 |
end_txn_response.go
|
 |
- |
rw-r--r-- |
326 |
end_txn_response_test.go
|
 |
- |
rwxr-xr-x |
957 |
entrypoint.sh
|
 |
- |
rw-r--r-- |
26,095 |
errors.go
|
 |
- |
rw-r--r-- |
1,635 |
errors_test.go
|
 |
- |
rw-r--r-- |
8,175 |
fetch_request.go
|
 |
- |
rw-r--r-- |
2,944 |
fetch_request_test.go
|
 |
- |
rw-r--r-- |
14,922 |
fetch_response.go
|
 |
- |
rw-r--r-- |
17,635 |
fetch_response_test.go
|
 |
- |
rw-r--r-- |
1,378 |
find_coordinator_request.go
|
 |
- |
rw-r--r-- |
757 |
find_coordinator_request_test.go
|
 |
- |
rw-r--r-- |
2,130 |
find_coordinator_response.go
|
 |
- |
rw-r--r-- |
1,944 |
find_coordinator_response_test.go
|
 |
- |
rw-r--r-- |
6,612 |
functional_admin_test.go
|
 |
- |
rw-r--r-- |
2,416 |
functional_client_test.go
|
 |
- |
rw-r--r-- |
2,582 |
functional_consumer_follower_fetch_test.go
|
 |
- |
rw-r--r-- |
17,004 |
functional_consumer_group_test.go
|
 |
- |
rw-r--r-- |
6,713 |
functional_consumer_staticmembership_test.go
|
 |
- |
rw-r--r-- |
17,609 |
functional_consumer_test.go
|
 |
- |
rw-r--r-- |
1,096 |
functional_offset_manager_test.go
|
 |
- |
rw-r--r-- |
36,375 |
functional_producer_test.go
|
 |
- |
rw-r--r-- |
15,212 |
functional_test.go
|
 |
- |
rw-r--r-- |
1,436 |
go.mod
|
 |
- |
rw-r--r-- |
10,162 |
go.sum
|
 |
- |
rw-r--r-- |
7,414 |
gssapi_kerberos.go
|
 |
- |
rw-r--r-- |
1,512 |
heartbeat_request.go
|
 |
- |
rw-r--r-- |
1,821 |
heartbeat_request_test.go
|
 |
- |
rw-r--r-- |
1,299 |
heartbeat_response.go
|
 |
- |
rw-r--r-- |
1,277 |
heartbeat_response_test.go
|
 |
- |
rw-r--r-- |
1,446 |
helpers_test.go
|
 |
- |
rw-r--r-- |
3,650 |
incremental_alter_configs_request.go
|
 |
- |
rw-r--r-- |
2,440 |
incremental_alter_configs_request_test.go
|
 |
- |
rw-r--r-- |
1,752 |
incremental_alter_configs_response.go
|
 |
- |
rw-r--r-- |
985 |
incremental_alter_configs_response_test.go
|
 |
- |
rw-r--r-- |
2,115 |
init_producer_id_request.go
|
 |
- |
rw-r--r-- |
1,182 |
init_producer_id_request_test.go
|
 |
- |
rw-r--r-- |
1,796 |
init_producer_id_response.go
|
 |
- |
rw-r--r-- |
912 |
init_producer_id_response_test.go
|
 |
- |
rw-r--r-- |
1,634 |
interceptors.go
|
 |
- |
rw-r--r-- |
4,911 |
join_group_request.go
|
 |
- |
rw-r--r-- |
4,733 |
join_group_request_test.go
|
 |
- |
rw-r--r-- |
4,137 |
join_group_response.go
|
 |
- |
rw-r--r-- |
7,188 |
join_group_response_test.go
|
 |
- |
rw-r--r-- |
1,792 |
kerberos_client.go
|
 |
- |
rw-r--r-- |
5,958 |
kerberos_client_test.go
|
 |
- |
rw-r--r-- |
2,121 |
leave_group_request.go
|
 |
- |
rw-r--r-- |
1,303 |
leave_group_request_test.go
|
 |
- |
rw-r--r-- |
2,285 |
leave_group_response.go
|
 |
- |
rw-r--r-- |
1,854 |
leave_group_response_test.go
|
 |
- |
rw-r--r-- |
2,100 |
length_field.go
|
 |
- |
rw-r--r-- |
1,621 |
list_groups_request.go
|
 |
- |
rw-r--r-- |
869 |
list_groups_request_test.go
|
 |
- |
rw-r--r-- |
3,234 |
list_groups_response.go
|
 |
- |
rw-r--r-- |
2,373 |
list_groups_response_test.go
|
 |
- |
rw-r--r-- |
2,236 |
list_partition_reassignments_request.go
|
 |
- |
rw-r--r-- |
777 |
list_partition_reassignments_request_test.go
|
 |
- |
rw-r--r-- |
4,423 |
list_partition_reassignments_response.go
|
 |
- |
rw-r--r-- |
984 |
list_partition_reassignments_response_test.go
|
 |
- |
rw-r--r-- |
670 |
logger_test.go
|
 |
- |
rw-r--r-- |
4,654 |
message.go
|
 |
- |
rw-r--r-- |
2,418 |
message_set.go
|
 |
- |
rw-r--r-- |
9,346 |
message_test.go
|
 |
- |
rw-r--r-- |
7,709 |
metadata.go
|
 |
- |
rw-r--r-- |
5,370 |
metadata_request.go
|
 |
- |
rw-r--r-- |
9,766 |
metadata_request_test.go
|
 |
- |
rw-r--r-- |
10,556 |
metadata_response.go
|
 |
- |
rw-r--r-- |
20,234 |
metadata_response_test.go
|
 |
- |
rw-r--r-- |
2,711 |
metadata_test.go
|
 |
- |
rw-r--r-- |
3,618 |
metrics.go
|
 |
- |
rw-r--r-- |
5,180 |
metrics_helpers_test.go
|
 |
- |
rw-r--r-- |
1,404 |
metrics_test.go
|
 |
- |
rw-r--r-- |
13,360 |
mockbroker.go
|
 |
- |
rw-r--r-- |
4,181 |
mockkerberos.go
|
 |
- |
rw-r--r-- |
41,661 |
mockresponses.go
|
 |
- |
rw-r--r-- |
6,669 |
offset_commit_request.go
|
 |
- |
rw-r--r-- |
6,145 |
offset_commit_request_test.go
|
 |
- |
rw-r--r-- |
2,592 |
offset_commit_response.go
|
 |
- |
rw-r--r-- |
2,559 |
offset_commit_response_test.go
|
 |
- |
rw-r--r-- |
5,137 |
offset_fetch_request.go
|
 |
- |
rw-r--r-- |
3,445 |
offset_fetch_request_test.go
|
 |
- |
rw-r--r-- |
5,436 |
offset_fetch_response.go
|
 |
- |
rw-r--r-- |
2,382 |
offset_fetch_response_test.go
|
 |
- |
rw-r--r-- |
18,132 |
offset_manager.go
|
 |
- |
rw-r--r-- |
21,635 |
offset_manager_test.go
|
 |
- |
rw-r--r-- |
4,168 |
offset_request.go
|
 |
- |
rw-r--r-- |
2,824 |
offset_request_test.go
|
 |
- |
rw-r--r-- |
4,435 |
offset_response.go
|
 |
- |
rw-r--r-- |
3,830 |
offset_response_test.go
|
 |
- |
rw-r--r-- |
2,839 |
packet_decoder.go
|
 |
- |
rw-r--r-- |
2,668 |
packet_encoder.go
|
 |
- |
rw-r--r-- |
8,713 |
partitioner.go
|
 |
- |
rw-r--r-- |
10,873 |
partitioner_test.go
|
 |
- |
rw-r--r-- |
3,992 |
prep_encoder.go
|
 |
- |
rw-r--r-- |
7,675 |
produce_request.go
|
 |
- |
rw-r--r-- |
2,835 |
produce_request_test.go
|
 |
- |
rw-r--r-- |
4,943 |
produce_response.go
|
 |
- |
rw-r--r-- |
4,716 |
produce_response_test.go
|
 |
- |
rw-r--r-- |
9,178 |
produce_set.go
|
 |
- |
rw-r--r-- |
10,854 |
produce_set_test.go
|
 |
- |
rw-r--r-- |
571 |
quota_types.go
|
 |
- |
rw-r--r-- |
9,047 |
real_decoder.go
|
 |
- |
rw-r--r-- |
1,655 |
real_decoder_test.go
|
 |
- |
rw-r--r-- |
4,258 |
real_encoder.go
|
 |
- |
rw-r--r-- |
2,232 |
record.go
|
 |
- |
rw-r--r-- |
4,783 |
record_batch.go
|
 |
- |
rw-r--r-- |
8,697 |
record_test.go
|
 |
- |
rw-r--r-- |
5,123 |
records.go
|
 |
- |
rw-r--r-- |
2,898 |
records_test.go
|
 |
- |
rw-r--r-- |
6,373 |
request.go
|
 |
- |
rw-r--r-- |
18,134 |
request_test.go
|
 |
- |
rw-r--r-- |
553 |
response_header.go
|
 |
- |
rw-r--r-- |
989 |
response_header_test.go
|
 |
- |
rw-r--r-- |
11,350 |
sarama.go
|
 |
- |
rw-r--r-- |
295 |
sarama_test.go
|
 |
- |
rw-r--r-- |
980 |
sasl_authenticate_request.go
|
 |
- |
rw-r--r-- |
531 |
sasl_authenticate_request_test.go
|
 |
- |
rw-r--r-- |
1,541 |
sasl_authenticate_response.go
|
 |
- |
rw-r--r-- |
970 |
sasl_authenticate_response_test.go
|
 |
- |
rw-r--r-- |
934 |
sasl_handshake_request.go
|
 |
- |
rw-r--r-- |
290 |
sasl_handshake_request_test.go
|
 |
- |
rw-r--r-- |
1,073 |
sasl_handshake_response.go
|
 |
- |
rw-r--r-- |
601 |
sasl_handshake_response_test.go
|
 |
- |
rw-r--r-- |
1,565 |
scram_formatter.go
|
 |
- |
rw-r--r-- |
2,514 |
scram_formatter_test.go
|
 |
- |
rw-r--r-- |
6,896 |
server.properties
|
 |
- |
rw-r--r-- |
3,304 |
sticky_assignor_user_data.go
|
 |
- |
rw-r--r-- |
1,799 |
sticky_assignor_user_data_test.go
|
 |
- |
rw-r--r-- |
3,672 |
sync_group_request.go
|
 |
- |
rw-r--r-- |
2,253 |
sync_group_request_test.go
|
 |
- |
rw-r--r-- |
1,947 |
sync_group_response.go
|
 |
- |
rw-r--r-- |
1,601 |
sync_group_response_test.go
|
 |
- |
rw-r--r-- |
6,332 |
sync_producer.go
|
 |
- |
rw-r--r-- |
9,340 |
sync_producer_test.go
|
 |
- |
rw-r--r-- |
744 |
timestamp.go
|
 |
- |
rw-r--r-- |
29,934 |
transaction_manager.go
|
 |
- |
rw-r--r-- |
30,731 |
transaction_manager_test.go
|
 |
- |
rw-r--r-- |
3,523 |
txn_offset_commit_request.go
|
 |
- |
rw-r--r-- |
1,555 |
txn_offset_commit_request_test.go
|
 |
- |
rw-r--r-- |
2,108 |
txn_offset_commit_response.go
|
 |
- |
rw-r--r-- |
577 |
txn_offset_commit_response_test.go
|
 |
- |
rw-r--r-- |
10,226 |
utils.go
|
 |
- |
rw-r--r-- |
3,231 |
utils_test.go
|
 |
- |
rw-r--r-- |
463 |
version.go
|
 |
- |
rw-r--r-- |
1,965 |
zstd.go
|
 |
- |
rw-r--r-- |
630 |
zstd_test.go
|