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