mz_
kafka_
util
0.0.0
In mz_
kafka_
util::
client
Structs
BrokerAddr
BrokerRewrite
MzClientContext
TimeoutConfig
TunnelingClientContext
Enums
BrokerRewriteHandle
GetPartitionsError
MzKafkaError
TunnelConfig
Constants
DEFAULT_FETCH_METADATA_TIMEOUT
DEFAULT_KEEPALIVE
DEFAULT_PROGRESS_RECORD_FETCH_TIMEOUT
DEFAULT_SOCKET_CONNECTION_SETUP_TIMEOUT
DEFAULT_SOCKET_TIMEOUT
DEFAULT_TOPIC_METADATA_REFRESH_INTERVAL
DEFAULT_TRANSACTION_TIMEOUT
Functions
create_new_client_config
create_new_client_config_simple
get_partitions
Type Aliases
PartitionId
mz_kafka_util
::
client
Type Alias
PartitionId
Copy item path
Settings
Help
Summary
Source
pub type PartitionId =
i32
;
Expand description
Id of a partition in a topic.