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
Constant
DEFAULT_SOCKET_TIMEOUT
Copy item path
Settings
Help
Summary
Source
pub const DEFAULT_SOCKET_TIMEOUT:
Duration
;
Expand description
The
rdkafka
default.
https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md