Path	Lines of Code
acl_bindings.go	109
acl_create_request.go	73
acl_create_response.go	83
acl_delete_request.go	53
acl_delete_response.go	139
acl_describe_request.go	34
acl_describe_response.go	79
acl_filter.go	63
acl_types.go	202
add_offsets_to_txn_request.go	58
add_offsets_to_txn_response.go	54
add_partitions_to_txn_request.go	77
add_partitions_to_txn_response.go	105
admin.go	941
alter_client_quotas_request.go	146
alter_client_quotas_response.go	112
alter_configs_request.go	113
alter_configs_response.go	119
alter_partition_reassignments_request.go	110
alter_partition_reassignments_response.go	135
alter_user_scram_credentials_request.go	118
alter_user_scram_credentials_response.go	81
api_versions_request.go	63
api_versions_response.go	130
async_producer.go	1043
balance_strategy.go	859
broker.go	1297
broker_fips.go	6
broker_nofips.go	8
client.go	965
compress.go	186
config.go	494
config_resource_type.go	8
consumer.go	805
consumer_group.go	822
consumer_group_members.go	146
consumer_metadata_request.go	42
consumer_metadata_response.go	74
control_record.go	53
crc32_field.go	70
create_partitions_request.go	111
create_partitions_response.go	105
create_topics_request.go	156
create_topics_response.go	118
decompress.go	81
delete_groups_request.go	37
delete_groups_response.go	74
delete_offsets_request.go	80
delete_offsets_response.go	99
delete_records_request.go	115
delete_records_response.go	143
delete_topics_request.go	52
delete_topics_response.go	78
describe_client_quotas_request.go	102
describe_client_quotas_response.go	180
describe_configs_request.go	102
describe_configs_response.go	294
describe_groups_request.go	59
describe_groups_response.go	222
describe_log_dirs_request.go	70
describe_log_dirs_response.go	179
describe_user_scram_credentials_request.go	57
describe_user_scram_credentials_response.go	141
encoder_decoder.go	75
end_txn_request.go	54
end_txn_response.go	52
errors.go	370
fetch_request.go	278
fetch_response.go	476
find_coordinator_request.go	56
find_coordinator_response.go	85
gssapi_config.go	24
gssapi_kerberos.go	200
heartbeat_request.go	67
heartbeat_response.go	58
incremental_alter_configs_request.go	139
incremental_alter_configs_response.go	56
init_producer_id_request.go	91
init_producer_id_response.go	76
interceptors.go	23
join_group_request.go	165
join_group_response.go	146
kerberos_client.go	48
leave_group_request.go	90
leave_group_response.go	97
length_field.go	78
list_groups_request.go	74
list_groups_response.go	150
list_partition_reassignments_request.go	82
list_partition_reassignments_response.go	142
message.go	139
message_set.go	89
metadata_request.go	217
metadata_response.go	441
metrics.go	91
mockbroker.go	352
mockkerberos.go	110
mockresponses.go	1284
offset_commit_request.go	205
offset_commit_response.go	109
offset_fetch_request.go	206
offset_fetch_response.go	252
offset_manager.go	479
offset_request.go	175
offset_response.go	167
packet_decoder.go	43
packet_encoder.go	41
partitioner.go	164
prep_encoder.go	168
produce_request.go	228
produce_response.go	185
produce_set.go	230
quota_types.go	15
real_decoder.go	381
real_encoder.go	174
record.go	94
record_batch.go	189
records.go	186
request.go	178
response_header.go	22
sarama.go	27
sasl_authenticate_request.go	34
sasl_authenticate_response.go	59
sasl_handshake_request.go	37
sasl_handshake_response.go	41
scram_formatter.go	61
sticky_assignor_user_data.go	103
sync_group_request.go	127
sync_group_response.go	64
sync_producer.go	129
timestamp.go	30
transaction_manager.go	750
txn_offset_commit_request.go	133
txn_offset_commit_response.go	87
utils.go	267
version.go	21
zstd.go	58