 |
|
|
|
.. (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,302 |
.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-- |
2,548 |
Dockerfile.kafka
|
 |
- |
rw-r--r-- |
1,102 |
LICENSE.md
|
 |
- |
rw-r--r-- |
1,561 |
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,180 |
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,400 |
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,886 |
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,292 |
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,562 |
add_partitions_to_txn_response.go
|
 |
- |
rw-r--r-- |
565 |
add_partitions_to_txn_response_test.go
|
 |
- |
rw-r--r-- |
39,518 |
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,594 |
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,905 |
alter_configs_response.go
|
 |
- |
rw-r--r-- |
897 |
alter_configs_response_test.go
|
 |
- |
rw-r--r-- |
3,461 |
alter_partition_reassignments_request.go
|
 |
- |
rw-r--r-- |
1,658 |
alter_partition_reassignments_request_test.go
|
 |
- |
rw-r--r-- |
4,258 |
alter_partition_reassignments_response.go
|
 |
- |
rw-r--r-- |
1,280 |
alter_partition_reassignments_response_test.go
|
 |
- |
rw-r--r-- |
3,872 |
alter_user_scram_credentials_request.go
|
 |
- |
rw-r--r-- |
1,835 |
alter_user_scram_credentials_request_test.go
|
 |
- |
rw-r--r-- |
2,438 |
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,820 |
api_versions_request.go
|
 |
- |
rw-r--r-- |
586 |
api_versions_request_test.go
|
 |
- |
rw-r--r-- |
3,974 |
api_versions_response.go
|
 |
- |
rw-r--r-- |
6,091 |
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,189 |
balance_strategy.go
|
 |
- |
rw-r--r-- |
74,717 |
balance_strategy_test.go
|
 |
- |
rw-r--r-- |
56,333 |
broker.go
|
 |
- |
rw-r--r-- |
43,764 |
broker_test.go
|
 |
- |
rw-r--r-- |
41,747 |
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,826 |
config.go
|
 |
- |
rw-r--r-- |
599 |
config_resource_type.go
|
 |
- |
rw-r--r-- |
17,256 |
config_test.go
|
 |
- |
rw-r--r-- |
36,568 |
consumer.go
|
 |
- |
rw-r--r-- |
35,629 |
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,545 |
create_partitions_response.go
|
 |
- |
rw-r--r-- |
2,175 |
create_partitions_response_test.go
|
 |
- |
rw-r--r-- |
5,959 |
create_topics_request.go
|
 |
- |
rw-r--r-- |
1,590 |
create_topics_request_test.go
|
 |
- |
rw-r--r-- |
7,045 |
create_topics_response.go
|
 |
- |
rw-r--r-- |
3,183 |
create_topics_response_test.go
|
 |
- |
rw-r--r-- |
2,215 |
decompress.go
|
 |
- |
rw-r--r-- |
1,359 |
delete_groups_request.go
|
 |
- |
rw-r--r-- |
1,745 |
delete_groups_request_test.go
|
 |
- |
rw-r--r-- |
2,127 |
delete_groups_response.go
|
 |
- |
rw-r--r-- |
3,313 |
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,488 |
delete_offsets_response.go
|
 |
- |
rw-r--r-- |
1,691 |
delete_offsets_response_test.go
|
 |
- |
rw-r--r-- |
2,936 |
delete_records_request.go
|
 |
- |
rw-r--r-- |
638 |
delete_records_request_test.go
|
 |
- |
rw-r--r-- |
3,629 |
delete_records_response.go
|
 |
- |
rw-r--r-- |
765 |
delete_records_response_test.go
|
 |
- |
rw-r--r-- |
1,975 |
delete_topics_request.go
|
 |
- |
rw-r--r-- |
1,010 |
delete_topics_request_test.go
|
 |
- |
rw-r--r-- |
2,179 |
delete_topics_response.go
|
 |
- |
rw-r--r-- |
848 |
delete_topics_response_test.go
|
 |
- |
rw-r--r-- |
4,439 |
describe_client_quotas_request.go
|
 |
- |
rw-r--r-- |
2,932 |
describe_client_quotas_request_test.go
|
 |
- |
rw-r--r-- |
6,499 |
describe_client_quotas_response.go
|
 |
- |
rw-r--r-- |
4,485 |
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,245 |
describe_configs_response.go
|
 |
- |
rw-r--r-- |
6,500 |
describe_configs_response_test.go
|
 |
- |
rw-r--r-- |
1,745 |
describe_groups_request.go
|
 |
- |
rw-r--r-- |
2,919 |
describe_groups_request_test.go
|
 |
- |
rw-r--r-- |
7,575 |
describe_groups_response.go
|
 |
- |
rw-r--r-- |
9,125 |
describe_groups_response_test.go
|
 |
- |
rw-r--r-- |
2,617 |
describe_log_dirs_request.go
|
 |
- |
rw-r--r-- |
1,733 |
describe_log_dirs_request_test.go
|
 |
- |
rw-r--r-- |
6,248 |
describe_log_dirs_response.go
|
 |
- |
rw-r--r-- |
9,169 |
describe_log_dirs_response_test.go
|
 |
- |
rw-r--r-- |
2,164 |
describe_user_scram_credentials_request.go
|
 |
- |
rw-r--r-- |
866 |
describe_user_scram_credentials_request_test.go
|
 |
- |
rw-r--r-- |
4,250 |
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-- |
6,099 |
docker-compose.yml
|
 |
- |
rw-r--r-- |
2,429 |
elect_leaders_request.go
|
 |
- |
rw-r--r-- |
1,107 |
elect_leaders_request_test.go
|
 |
- |
rw-r--r-- |
3,488 |
elect_leaders_response.go
|
 |
- |
rw-r--r-- |
736 |
elect_leaders_response_test.go
|
 |
- |
rw-r--r-- |
190 |
election_type.go
|
 |
- |
rw-r--r-- |
3,231 |
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,093 |
end_txn_response.go
|
 |
- |
rw-r--r-- |
326 |
end_txn_response_test.go
|
 |
- |
rwxr-xr-x |
1,567 |
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,823 |
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,023 |
find_coordinator_response.go
|
 |
- |
rw-r--r-- |
1,944 |
find_coordinator_response_test.go
|
 |
- |
rw-r--r-- |
12,727 |
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-- |
18,546 |
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,673 |
functional_producer_test.go
|
 |
- |
rw-r--r-- |
15,417 |
functional_test.go
|
 |
- |
rw-r--r-- |
1,436 |
go.mod
|
 |
- |
rw-r--r-- |
9,752 |
go.sum
|
 |
- |
rw-r--r-- |
8,765 |
gssapi_kerberos.go
|
 |
- |
rw-r--r-- |
1,825 |
heartbeat_request.go
|
 |
- |
rw-r--r-- |
2,719 |
heartbeat_request_test.go
|
 |
- |
rw-r--r-- |
1,587 |
heartbeat_response.go
|
 |
- |
rw-r--r-- |
1,824 |
heartbeat_response_test.go
|
 |
- |
rw-r--r-- |
1,446 |
helpers_test.go
|
 |
- |
rw-r--r-- |
4,186 |
incremental_alter_configs_request.go
|
 |
- |
rw-r--r-- |
5,098 |
incremental_alter_configs_request_test.go
|
 |
- |
rw-r--r-- |
2,042 |
incremental_alter_configs_response.go
|
 |
- |
rw-r--r-- |
2,554 |
incremental_alter_configs_response_test.go
|
 |
- |
rw-r--r-- |
1,963 |
init_producer_id_request.go
|
 |
- |
rw-r--r-- |
1,182 |
init_producer_id_request_test.go
|
 |
- |
rw-r--r-- |
1,792 |
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-- |
5,361 |
join_group_request.go
|
 |
- |
rw-r--r-- |
5,722 |
join_group_request_test.go
|
 |
- |
rw-r--r-- |
4,575 |
join_group_response.go
|
 |
- |
rw-r--r-- |
8,589 |
join_group_response_test.go
|
 |
- |
rw-r--r-- |
1,792 |
kerberos_client.go
|
 |
- |
rw-r--r-- |
5,985 |
kerberos_client_test.go
|
 |
- |
rw-r--r-- |
2,550 |
leave_group_request.go
|
 |
- |
rw-r--r-- |
1,876 |
leave_group_request_test.go
|
 |
- |
rw-r--r-- |
2,636 |
leave_group_response.go
|
 |
- |
rw-r--r-- |
2,547 |
leave_group_response_test.go
|
 |
- |
rw-r--r-- |
2,100 |
length_field.go
|
 |
- |
rw-r--r-- |
1,951 |
list_groups_request.go
|
 |
- |
rw-r--r-- |
1,291 |
list_groups_request_test.go
|
 |
- |
rw-r--r-- |
3,132 |
list_groups_response.go
|
 |
- |
rw-r--r-- |
3,461 |
list_groups_response_test.go
|
 |
- |
rw-r--r-- |
2,417 |
list_partition_reassignments_request.go
|
 |
- |
rw-r--r-- |
777 |
list_partition_reassignments_request_test.go
|
 |
- |
rw-r--r-- |
4,526 |
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-- |
4,739 |
metadata_request.go
|
 |
- |
rw-r--r-- |
9,766 |
metadata_request_test.go
|
 |
- |
rw-r--r-- |
9,025 |
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,350 |
metrics_test.go
|
 |
- |
rw-r--r-- |
13,248 |
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,565 |
offset_commit_response.go
|
 |
- |
rw-r--r-- |
2,559 |
offset_commit_response_test.go
|
 |
- |
rw-r--r-- |
4,423 |
offset_fetch_request.go
|
 |
- |
rw-r--r-- |
3,445 |
offset_fetch_request_test.go
|
 |
- |
rw-r--r-- |
4,585 |
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,980 |
offset_request.go
|
 |
- |
rw-r--r-- |
2,824 |
offset_request_test.go
|
 |
- |
rw-r--r-- |
4,437 |
offset_response.go
|
 |
- |
rw-r--r-- |
3,830 |
offset_response_test.go
|
 |
- |
rw-r--r-- |
2,892 |
packet_decoder.go
|
 |
- |
rw-r--r-- |
2,546 |
packet_encoder.go
|
 |
- |
rw-r--r-- |
8,713 |
partitioner.go
|
 |
- |
rw-r--r-- |
10,873 |
partitioner_test.go
|
 |
- |
rw-r--r-- |
4,771 |
prep_encoder.go
|
 |
- |
rw-r--r-- |
7,675 |
produce_request.go
|
 |
- |
rw-r--r-- |
2,835 |
produce_request_test.go
|
 |
- |
rw-r--r-- |
4,847 |
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-- |
10,800 |
real_decoder.go
|
 |
- |
rw-r--r-- |
1,655 |
real_decoder_test.go
|
 |
- |
rw-r--r-- |
5,095 |
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,512 |
request.go
|
 |
- |
rw-r--r-- |
22,919 |
request_test.go
|
 |
- |
rw-r--r-- |
717 |
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,519 |
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,051 |
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-- |
4,056 |
sync_group_request.go
|
 |
- |
rw-r--r-- |
2,983 |
sync_group_request_test.go
|
 |
- |
rw-r--r-- |
2,318 |
sync_group_response.go
|
 |
- |
rw-r--r-- |
1,995 |
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,087 |
txn_offset_commit_response.go
|
 |
- |
rw-r--r-- |
577 |
txn_offset_commit_response_test.go
|
 |
- |
rw-r--r-- |
10,332 |
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-- |
618 |
zstd_test.go
|