Docs.rs
kafka-protocol-0.15.1
kafka-protocol 0.15.1
Permalink
Docs.rs crate page
MIT
/
Apache-2.0
Links
Homepage
Repository
crates.io
Source
Owners
tychedelia
Dependencies
anyhow ^1.0.80
normal
bytes ^1.10.1
normal
crc ^3.0.0
normal
crc32c ^0.6.4
normal
flate2 ^1.0.20
normal
optional
indexmap ^2.0.0
normal
lz4 ^1.24
normal
optional
paste ^1.0.7
normal
snap ^1.0.5
normal
optional
uuid ^1.3.0
normal
zstd ^0.13
normal
optional
testcontainers ^0.20.1
dev
Versions
100%
of the crate is documented
Platform
i686-unknown-linux-gnu
x86_64-unknown-linux-gnu
Feature flags
docs.rs
About docs.rs
Privacy policy
Rust
Rust website
The Book
Standard Library API Reference
Rust by Example
The Cargo Guide
Clippy Documentation
Module controlled_
shutdown_
request
kafka_
protocol
0.15.1
Module controlled_
shutdown_
request
Module Items
Structs
In kafka_
protocol::
messages
Modules
add_offsets_to_txn_request
add_offsets_to_txn_response
add_partitions_to_txn_request
add_partitions_to_txn_response
add_raft_voter_request
add_raft_voter_response
allocate_producer_ids_request
allocate_producer_ids_response
alter_client_quotas_request
alter_client_quotas_response
alter_configs_request
alter_configs_response
alter_partition_reassignments_request
alter_partition_reassignments_response
alter_partition_request
alter_partition_response
alter_replica_log_dirs_request
alter_replica_log_dirs_response
alter_user_scram_credentials_request
alter_user_scram_credentials_response
api_versions_request
api_versions_response
assign_replicas_to_dirs_request
assign_replicas_to_dirs_response
begin_quorum_epoch_request
begin_quorum_epoch_response
broker_heartbeat_request
broker_heartbeat_response
broker_registration_request
broker_registration_response
consumer_group_describe_request
consumer_group_describe_response
consumer_group_heartbeat_request
consumer_group_heartbeat_response
consumer_protocol_assignment
consumer_protocol_subscription
controlled_shutdown_request
controlled_shutdown_response
controller_registration_request
controller_registration_response
create_acls_request
create_acls_response
create_delegation_token_request
create_delegation_token_response
create_partitions_request
create_partitions_response
create_topics_request
create_topics_response
default_principal_data
delete_acls_request
delete_acls_response
delete_groups_request
delete_groups_response
delete_records_request
delete_records_response
delete_topics_request
delete_topics_response
describe_acls_request
describe_acls_response
describe_client_quotas_request
describe_client_quotas_response
describe_cluster_request
describe_cluster_response
describe_configs_request
describe_configs_response
describe_delegation_token_request
describe_delegation_token_response
describe_groups_request
describe_groups_response
describe_log_dirs_request
describe_log_dirs_response
describe_producers_request
describe_producers_response
describe_quorum_request
describe_quorum_response
describe_topic_partitions_request
describe_topic_partitions_response
describe_transactions_request
describe_transactions_response
describe_user_scram_credentials_request
describe_user_scram_credentials_response
elect_leaders_request
elect_leaders_response
end_quorum_epoch_request
end_quorum_epoch_response
end_txn_request
end_txn_response
envelope_request
envelope_response
expire_delegation_token_request
expire_delegation_token_response
fetch_request
fetch_response
fetch_snapshot_request
fetch_snapshot_response
find_coordinator_request
find_coordinator_response
get_telemetry_subscriptions_request
get_telemetry_subscriptions_response
heartbeat_request
heartbeat_response
incremental_alter_configs_request
incremental_alter_configs_response
init_producer_id_request
init_producer_id_response
join_group_request
join_group_response
k_raft_version_record
leader_and_isr_request
leader_and_isr_response
leader_change_message
leave_group_request
leave_group_response
list_client_metrics_resources_request
list_client_metrics_resources_response
list_groups_request
list_groups_response
list_offsets_request
list_offsets_response
list_partition_reassignments_request
list_partition_reassignments_response
list_transactions_request
list_transactions_response
metadata_request
metadata_response
offset_commit_request
offset_commit_response
offset_delete_request
offset_delete_response
offset_fetch_request
offset_fetch_response
offset_for_leader_epoch_request
offset_for_leader_epoch_response
produce_request
produce_response
push_telemetry_request
push_telemetry_response
remove_raft_voter_request
remove_raft_voter_response
renew_delegation_token_request
renew_delegation_token_response
request_header
response_header
sasl_authenticate_request
sasl_authenticate_response
sasl_handshake_request
sasl_handshake_response
snapshot_footer_record
snapshot_header_record
stop_replica_request
stop_replica_response
sync_group_request
sync_group_response
txn_offset_commit_request
txn_offset_commit_response
unregister_broker_request
unregister_broker_response
update_features_request
update_features_response
update_metadata_request
update_metadata_response
update_raft_voter_request
update_raft_voter_response
vote_request
vote_response
voters_record
write_txn_markers_request
write_txn_markers_response
Structs
BrokerId
GroupId
ProducerId
TopicName
TransactionalId
Enums
ApiKey
RequestKind
ResponseKind
kafka_protocol
::
messages
Module
controlled_shutdown_request
Copy item path
Settings
Help
Summary
Source
Expand description
ControlledShutdownRequest
See the schema for this message
here
.
Structs
§
Controlled
Shutdown
Request
Valid versions: 0-3