krabka-protocol-0.7.0
Platform
- x86_64-unknown-linux-gnu
Feature flags

docs.rs

Rust

krabka-protocol 0.7.0

Apache Kafka wire-protocol codec (4.3.0), with typed RecordBatch and zero-copy borrowed decode

Crate
Source
Builds
Feature flags

..
common
access_control_entry_record.rs
add_offsets_to_txn_request.rs
add_offsets_to_txn_response.rs
add_partitions_to_txn_request.rs
add_partitions_to_txn_response.rs
add_raft_voter_request.rs
add_raft_voter_response.rs
allocate_producer_ids_request.rs
allocate_producer_ids_response.rs
alter_client_quotas_request.rs
alter_client_quotas_response.rs
alter_configs_request.rs
alter_configs_response.rs
alter_partition_reassignments_request.rs
alter_partition_reassignments_response.rs
alter_partition_request.rs
alter_partition_response.rs
alter_replica_log_dirs_request.rs
alter_replica_log_dirs_response.rs
alter_share_group_offsets_request.rs
alter_share_group_offsets_response.rs
alter_user_scram_credentials_request.rs
alter_user_scram_credentials_response.rs
api_versions_request.rs
api_versions_response.rs
assign_replicas_to_dirs_request.rs
assign_replicas_to_dirs_response.rs
begin_quorum_epoch_request.rs
begin_quorum_epoch_response.rs
begin_transaction_record.rs
broker_heartbeat_request.rs
broker_heartbeat_response.rs
broker_registration_change_record.rs
broker_registration_request.rs
broker_registration_response.rs
client_quota_record.rs
config_record.rs
consumer_group_describe_request.rs
consumer_group_describe_response.rs
consumer_group_heartbeat_request.rs
consumer_group_heartbeat_response.rs
consumer_protocol_assignment.rs
consumer_protocol_subscription.rs
control_record_type_schema.rs
controller_registration_request.rs
controller_registration_response.rs
create_acls_request.rs
create_acls_response.rs
create_delegation_token_request.rs
create_delegation_token_response.rs
create_partitions_request.rs
create_partitions_response.rs
create_topics_request.rs
create_topics_response.rs
default_principal_data.rs
delegation_token_record.rs
delete_acls_request.rs
delete_acls_response.rs
delete_groups_request.rs
delete_groups_response.rs
delete_records_request.rs
delete_records_response.rs
delete_share_group_offsets_request.rs
delete_share_group_offsets_response.rs
delete_share_group_state_request.rs
delete_share_group_state_response.rs
delete_topics_request.rs
delete_topics_response.rs
describe_acls_request.rs
describe_acls_response.rs
describe_client_quotas_request.rs
describe_client_quotas_response.rs
describe_cluster_request.rs
describe_cluster_response.rs
describe_configs_request.rs
describe_configs_response.rs
describe_delegation_token_request.rs
describe_delegation_token_response.rs
describe_groups_request.rs
describe_groups_response.rs
describe_log_dirs_request.rs
describe_log_dirs_response.rs
describe_producers_request.rs
describe_producers_response.rs
describe_quorum_request.rs
describe_quorum_response.rs
describe_share_group_offsets_request.rs
describe_share_group_offsets_response.rs
describe_topic_partitions_request.rs
describe_topic_partitions_response.rs
describe_transactions_request.rs
describe_transactions_response.rs
describe_user_scram_credentials_request.rs
describe_user_scram_credentials_response.rs
elect_leaders_request.rs
elect_leaders_response.rs
end_quorum_epoch_request.rs
end_quorum_epoch_response.rs
end_transaction_record.rs
end_txn_marker.rs
end_txn_request.rs
end_txn_response.rs
envelope_request.rs
envelope_response.rs
expire_delegation_token_request.rs
expire_delegation_token_response.rs
feature_level_record.rs
fetch_request.rs
fetch_response.rs
fetch_snapshot_request.rs
fetch_snapshot_response.rs
find_coordinator_request.rs
find_coordinator_response.rs
get_replica_log_info_request.rs
get_replica_log_info_response.rs
get_telemetry_subscriptions_request.rs
get_telemetry_subscriptions_response.rs
heartbeat_request.rs
heartbeat_response.rs
incremental_alter_configs_request.rs
incremental_alter_configs_response.rs
init_producer_id_request.rs
init_producer_id_response.rs
initialize_share_group_state_request.rs
initialize_share_group_state_response.rs
join_group_request.rs
join_group_response.rs
k_raft_version_record.rs
leader_change_message.rs
leave_group_request.rs
leave_group_response.rs
list_config_resources_request.rs
list_config_resources_response.rs
list_groups_request.rs
list_groups_response.rs
list_offsets_request.rs
list_offsets_response.rs
list_partition_reassignments_request.rs
list_partition_reassignments_response.rs
list_transactions_request.rs
list_transactions_response.rs
metadata_request.rs
metadata_response.rs
mod.rs
no_op_record.rs
offset_commit_key.rs
offset_commit_request.rs
offset_commit_response.rs
offset_commit_value.rs
offset_delete_request.rs
offset_delete_response.rs
offset_fetch_request.rs
offset_fetch_response.rs
offset_for_leader_epoch_request.rs
offset_for_leader_epoch_response.rs
partition_change_record.rs
partition_record.rs
produce_request.rs
produce_response.rs
producer_ids_record.rs
push_telemetry_request.rs
push_telemetry_response.rs
read_share_group_state_request.rs
read_share_group_state_response.rs
read_share_group_state_summary_request.rs
read_share_group_state_summary_response.rs
register_broker_record.rs
register_controller_record.rs
remote_log_segment_metadata_record.rs
remote_log_segment_metadata_snapshot_record.rs
remote_log_segment_metadata_update_record.rs
remote_partition_delete_metadata_record.rs
remove_access_control_entry_record.rs
remove_delegation_token_record.rs
remove_raft_voter_request.rs
remove_raft_voter_response.rs
remove_topic_record.rs
remove_user_scram_credential_record.rs
renew_delegation_token_request.rs
renew_delegation_token_response.rs
request_header.rs
response_header.rs
sasl_authenticate_request.rs
sasl_authenticate_response.rs
sasl_handshake_request.rs
sasl_handshake_response.rs
share_acknowledge_request.rs
share_acknowledge_response.rs
share_fetch_request.rs
share_fetch_response.rs
share_group_describe_request.rs
share_group_describe_response.rs
share_group_heartbeat_request.rs
share_group_heartbeat_response.rs
snapshot_footer_record.rs
snapshot_header_record.rs
streams_group_describe_request.rs
streams_group_describe_response.rs
streams_group_heartbeat_request.rs
streams_group_heartbeat_response.rs
streams_group_topology_description_update_request.rs
streams_group_topology_description_update_response.rs
sync_group_request.rs
sync_group_response.rs
topic_record.rs
txn_offset_commit_request.rs
txn_offset_commit_response.rs
unregister_broker_record.rs
unregister_broker_request.rs
unregister_broker_response.rs
unregister_controller_record.rs
unregister_controller_request.rs
unregister_controller_response.rs
update_features_request.rs
update_features_response.rs
update_raft_voter_request.rs
update_raft_voter_response.rs
user_scram_credential_record.rs
vote_request.rs
vote_response.rs
voters_record.rs
write_share_group_state_request.rs
write_share_group_state_response.rs
write_txn_markers_request.rs
write_txn_markers_response.rs