 |
|
|
|
.. (parent) |
 |
d |
rwxr-xr-x |
121 |
.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-- |
1,725 |
.golangci.yml
|
 |
- |
rw-r--r-- |
1,303 |
.pre-commit-config.yaml
|
 |
- |
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,784 |
acl_create_request.go
|
 |
- |
rw-r--r-- |
1,514 |
acl_create_request_test.go
|
 |
- |
rw-r--r-- |
2,204 |
acl_create_response.go
|
 |
- |
rw-r--r-- |
785 |
acl_create_response_test.go
|
 |
- |
rw-r--r-- |
1,247 |
acl_delete_request.go
|
 |
- |
rw-r--r-- |
2,456 |
acl_delete_request_test.go
|
 |
- |
rw-r--r-- |
3,451 |
acl_delete_response.go
|
 |
- |
rw-r--r-- |
861 |
acl_delete_response_test.go
|
 |
- |
rw-r--r-- |
893 |
acl_describe_request.go
|
 |
- |
rw-r--r-- |
1,517 |
acl_describe_request_test.go
|
 |
- |
rw-r--r-- |
1,906 |
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,403 |
add_offsets_to_txn_request.go
|
 |
- |
rw-r--r-- |
435 |
add_offsets_to_txn_request_test.go
|
 |
- |
rw-r--r-- |
1,306 |
add_offsets_to_txn_response.go
|
 |
- |
rw-r--r-- |
358 |
add_offsets_to_txn_response_test.go
|
 |
- |
rw-r--r-- |
1,873 |
add_partitions_to_txn_request.go
|
 |
- |
rw-r--r-- |
548 |
add_partitions_to_txn_request_test.go
|
 |
- |
rw-r--r-- |
2,570 |
add_partitions_to_txn_response.go
|
 |
- |
rw-r--r-- |
565 |
add_partitions_to_txn_response_test.go
|
 |
- |
rw-r--r-- |
39,313 |
admin.go
|
 |
- |
rw-r--r-- |
51,734 |
admin_test.go
|
 |
- |
rw-r--r-- |
4,168 |
alter_client_quotas_request.go
|
 |
- |
rw-r--r-- |
4,726 |
alter_client_quotas_request_test.go
|
 |
- |
rw-r--r-- |
3,632 |
alter_client_quotas_response.go
|
 |
- |
rw-r--r-- |
2,896 |
alter_client_quotas_response_test.go
|
 |
- |
rw-r--r-- |
2,642 |
alter_configs_request.go
|
 |
- |
rw-r--r-- |
1,911 |
alter_configs_request_test.go
|
 |
- |
rw-r--r-- |
2,765 |
alter_configs_response.go
|
 |
- |
rw-r--r-- |
897 |
alter_configs_response_test.go
|
 |
- |
rw-r--r-- |
3,144 |
alter_partition_reassignments_request.go
|
 |
- |
rw-r--r-- |
1,658 |
alter_partition_reassignments_request_test.go
|
 |
- |
rw-r--r-- |
4,011 |
alter_partition_reassignments_response.go
|
 |
- |
rw-r--r-- |
1,280 |
alter_partition_reassignments_response_test.go
|
 |
- |
rw-r--r-- |
3,585 |
alter_user_scram_credentials_request.go
|
 |
- |
rw-r--r-- |
1,835 |
alter_user_scram_credentials_request_test.go
|
 |
- |
rw-r--r-- |
2,250 |
alter_user_scram_credentials_response.go
|
 |
- |
rw-r--r-- |
1,073 |
alter_user_scram_credentials_response_test.go
|
 |
- |
rw-r--r-- |
1,617 |
api_versions_request.go
|
 |
- |
rw-r--r-- |
586 |
api_versions_request_test.go
|
 |
- |
rw-r--r-- |
3,633 |
api_versions_response.go
|
 |
- |
rw-r--r-- |
1,890 |
api_versions_response_test.go
|
 |
- |
rw-r--r-- |
43,665 |
async_producer.go
|
 |
- |
rw-r--r-- |
72,970 |
async_producer_test.go
|
 |
- |
rw-r--r-- |
45,639 |
balance_strategy.go
|
 |
- |
rw-r--r-- |
74,995 |
balance_strategy_test.go
|
 |
- |
rw-r--r-- |
53,089 |
broker.go
|
 |
- |
rw-r--r-- |
43,815 |
broker_test.go
|
 |
- |
rw-r--r-- |
42,049 |
client.go
|
 |
- |
rw-r--r-- |
36,173 |
client_test.go
|
 |
- |
rw-r--r-- |
6,248 |
client_tls_test.go
|
 |
- |
rw-r--r-- |
4,588 |
compress.go
|
 |
- |
rw-r--r-- |
40,154 |
config.go
|
 |
- |
rw-r--r-- |
599 |
config_resource_type.go
|
 |
- |
rw-r--r-- |
17,221 |
config_test.go
|
 |
- |
rw-r--r-- |
36,594 |
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,114 |
consumer_metadata_request.go
|
 |
- |
rw-r--r-- |
657 |
consumer_metadata_request_test.go
|
 |
- |
rw-r--r-- |
2,064 |
consumer_metadata_response.go
|
 |
- |
rw-r--r-- |
1,215 |
consumer_metadata_response_test.go
|
 |
- |
rw-r--r-- |
64,956 |
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,571 |
create_partitions_request.go
|
 |
- |
rw-r--r-- |
1,149 |
create_partitions_request_test.go
|
 |
- |
rw-r--r-- |
2,557 |
create_partitions_response.go
|
 |
- |
rw-r--r-- |
2,175 |
create_partitions_response_test.go
|
 |
- |
rw-r--r-- |
4,796 |
create_topics_request.go
|
 |
- |
rw-r--r-- |
1,052 |
create_topics_request_test.go
|
 |
- |
rw-r--r-- |
2,878 |
create_topics_response.go
|
 |
- |
rw-r--r-- |
1,607 |
create_topics_response_test.go
|
 |
- |
rw-r--r-- |
2,215 |
decompress.go
|
 |
- |
rw-r--r-- |
876 |
delete_groups_request.go
|
 |
- |
rw-r--r-- |
835 |
delete_groups_request_test.go
|
 |
- |
rw-r--r-- |
1,681 |
delete_groups_response.go
|
 |
- |
rw-r--r-- |
1,621 |
delete_groups_response_test.go
|
 |
- |
rw-r--r-- |
1,838 |
delete_offsets_request.go
|
 |
- |
rw-r--r-- |
1,005 |
delete_offsets_request_test.go
|
 |
- |
rw-r--r-- |
2,532 |
delete_offsets_response.go
|
 |
- |
rw-r--r-- |
1,691 |
delete_offsets_response_test.go
|
 |
- |
rw-r--r-- |
2,887 |
delete_records_request.go
|
 |
- |
rw-r--r-- |
638 |
delete_records_request_test.go
|
 |
- |
rw-r--r-- |
3,680 |
delete_records_response.go
|
 |
- |
rw-r--r-- |
765 |
delete_records_response_test.go
|
 |
- |
rw-r--r-- |
1,513 |
delete_topics_request.go
|
 |
- |
rw-r--r-- |
635 |
delete_topics_request_test.go
|
 |
- |
rw-r--r-- |
1,777 |
delete_topics_response.go
|
 |
- |
rw-r--r-- |
616 |
delete_topics_response_test.go
|
 |
- |
rw-r--r-- |
3,215 |
describe_client_quotas_request.go
|
 |
- |
rw-r--r-- |
2,363 |
describe_client_quotas_request_test.go
|
 |
- |
rw-r--r-- |
5,339 |
describe_client_quotas_response.go
|
 |
- |
rw-r--r-- |
3,252 |
describe_client_quotas_response_test.go
|
 |
- |
rw-r--r-- |
2,169 |
describe_configs_request.go
|
 |
- |
rw-r--r-- |
2,781 |
describe_configs_request_test.go
|
 |
- |
rw-r--r-- |
6,232 |
describe_configs_response.go
|
 |
- |
rw-r--r-- |
6,500 |
describe_configs_response_test.go
|
 |
- |
rw-r--r-- |
1,332 |
describe_groups_request.go
|
 |
- |
rw-r--r-- |
1,801 |
describe_groups_request_test.go
|
 |
- |
rw-r--r-- |
7,017 |
describe_groups_response.go
|
 |
- |
rw-r--r-- |
7,062 |
describe_groups_response_test.go
|
 |
- |
rw-r--r-- |
2,017 |
describe_log_dirs_request.go
|
 |
- |
rw-r--r-- |
887 |
describe_log_dirs_request_test.go
|
 |
- |
rw-r--r-- |
5,009 |
describe_log_dirs_response.go
|
 |
- |
rw-r--r-- |
2,102 |
describe_log_dirs_response_test.go
|
 |
- |
rw-r--r-- |
1,849 |
describe_user_scram_credentials_request.go
|
 |
- |
rw-r--r-- |
866 |
describe_user_scram_credentials_request_test.go
|
 |
- |
rw-r--r-- |
4,066 |
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,131 |
docker-compose.yml
|
 |
- |
rw-r--r-- |
2,502 |
elect_leaders_request.go
|
 |
- |
rw-r--r-- |
684 |
elect_leaders_request_test.go
|
 |
- |
rw-r--r-- |
3,677 |
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,224 |
end_txn_request.go
|
 |
- |
rw-r--r-- |
364 |
end_txn_request_test.go
|
 |
- |
rw-r--r-- |
1,125 |
end_txn_response.go
|
 |
- |
rw-r--r-- |
326 |
end_txn_response_test.go
|
 |
- |
rwxr-xr-x |
957 |
entrypoint.sh
|
 |
- |
rw-r--r-- |
26,255 |
errors.go
|
 |
- |
rw-r--r-- |
1,635 |
errors_test.go
|
 |
- |
rw-r--r-- |
8,102 |
fetch_request.go
|
 |
- |
rw-r--r-- |
2,944 |
fetch_request_test.go
|
 |
- |
rw-r--r-- |
14,692 |
fetch_response.go
|
 |
- |
rw-r--r-- |
17,640 |
fetch_response_test.go
|
 |
- |
rw-r--r-- |
1,286 |
find_coordinator_request.go
|
 |
- |
rw-r--r-- |
757 |
find_coordinator_request_test.go
|
 |
- |
rw-r--r-- |
2,037 |
find_coordinator_response.go
|
 |
- |
rw-r--r-- |
1,944 |
find_coordinator_response_test.go
|
 |
- |
rw-r--r-- |
6,463 |
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,670 |
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,143 |
functional_test.go
|
 |
- |
rw-r--r-- |
1,527 |
go.mod
|
 |
- |
rw-r--r-- |
9,804 |
go.sum
|
 |
- |
rw-r--r-- |
7,414 |
gssapi_kerberos.go
|
 |
- |
rw-r--r-- |
1,432 |
heartbeat_request.go
|
 |
- |
rw-r--r-- |
1,821 |
heartbeat_request_test.go
|
 |
- |
rw-r--r-- |
1,218 |
heartbeat_response.go
|
 |
- |
rw-r--r-- |
1,277 |
heartbeat_response_test.go
|
 |
- |
rw-r--r-- |
1,446 |
helpers_test.go
|
 |
- |
rw-r--r-- |
3,542 |
incremental_alter_configs_request.go
|
 |
- |
rw-r--r-- |
2,440 |
incremental_alter_configs_request_test.go
|
 |
- |
rw-r--r-- |
1,643 |
incremental_alter_configs_response.go
|
 |
- |
rw-r--r-- |
985 |
incremental_alter_configs_response_test.go
|
 |
- |
rw-r--r-- |
2,025 |
init_producer_id_request.go
|
 |
- |
rw-r--r-- |
1,182 |
init_producer_id_request_test.go
|
 |
- |
rw-r--r-- |
1,705 |
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,831 |
join_group_request.go
|
 |
- |
rw-r--r-- |
4,733 |
join_group_request_test.go
|
 |
- |
rw-r--r-- |
4,056 |
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,039 |
leave_group_request.go
|
 |
- |
rw-r--r-- |
1,303 |
leave_group_request_test.go
|
 |
- |
rw-r--r-- |
2,202 |
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,539 |
list_groups_request.go
|
 |
- |
rw-r--r-- |
869 |
list_groups_request_test.go
|
 |
- |
rw-r--r-- |
3,151 |
list_groups_response.go
|
 |
- |
rw-r--r-- |
2,373 |
list_groups_response_test.go
|
 |
- |
rw-r--r-- |
2,122 |
list_partition_reassignments_request.go
|
 |
- |
rw-r--r-- |
777 |
list_partition_reassignments_request_test.go
|
 |
- |
rw-r--r-- |
4,308 |
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,349 |
message_test.go
|
 |
- |
rw-r--r-- |
5,291 |
metadata_request.go
|
 |
- |
rw-r--r-- |
9,766 |
metadata_request_test.go
|
 |
- |
rw-r--r-- |
10,476 |
metadata_response.go
|
 |
- |
rw-r--r-- |
20,234 |
metadata_response_test.go
|
 |
- |
rw-r--r-- |
3,608 |
metrics.go
|
 |
- |
rw-r--r-- |
5,180 |
metrics_helpers_test.go
|
 |
- |
rw-r--r-- |
907 |
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,582 |
offset_commit_request.go
|
 |
- |
rw-r--r-- |
6,145 |
offset_commit_request_test.go
|
 |
- |
rw-r--r-- |
2,504 |
offset_commit_response.go
|
 |
- |
rw-r--r-- |
2,559 |
offset_commit_response_test.go
|
 |
- |
rw-r--r-- |
5,052 |
offset_fetch_request.go
|
 |
- |
rw-r--r-- |
3,445 |
offset_fetch_request_test.go
|
 |
- |
rw-r--r-- |
5,350 |
offset_fetch_response.go
|
 |
- |
rw-r--r-- |
2,382 |
offset_fetch_response_test.go
|
 |
- |
rw-r--r-- |
18,200 |
offset_manager.go
|
 |
- |
rw-r--r-- |
21,646 |
offset_manager_test.go
|
 |
- |
rw-r--r-- |
4,088 |
offset_request.go
|
 |
- |
rw-r--r-- |
2,824 |
offset_request_test.go
|
 |
- |
rw-r--r-- |
4,354 |
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,598 |
produce_request.go
|
 |
- |
rw-r--r-- |
2,835 |
produce_request_test.go
|
 |
- |
rw-r--r-- |
4,865 |
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,077 |
real_decoder.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-- |
7,412 |
record_test.go
|
 |
- |
rw-r--r-- |
5,094 |
records.go
|
 |
- |
rw-r--r-- |
2,904 |
records_test.go
|
 |
- |
rw-r--r-- |
5,625 |
request.go
|
 |
- |
rw-r--r-- |
11,730 |
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-- |
1,001 |
sasl_authenticate_request.go
|
 |
- |
rw-r--r-- |
531 |
sasl_authenticate_request_test.go
|
 |
- |
rw-r--r-- |
1,466 |
sasl_authenticate_response.go
|
 |
- |
rw-r--r-- |
970 |
sasl_authenticate_response_test.go
|
 |
- |
rw-r--r-- |
846 |
sasl_handshake_request.go
|
 |
- |
rw-r--r-- |
290 |
sasl_handshake_request_test.go
|
 |
- |
rw-r--r-- |
984 |
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,592 |
sync_group_request.go
|
 |
- |
rw-r--r-- |
2,253 |
sync_group_request_test.go
|
 |
- |
rw-r--r-- |
1,866 |
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,431 |
txn_offset_commit_request.go
|
 |
- |
rw-r--r-- |
1,555 |
txn_offset_commit_request_test.go
|
 |
- |
rw-r--r-- |
2,015 |
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
|