List of all items

Structs

• ApiVersionTable
• BrokerHandle
• BrokerInfo
• BrokerPool
• Client
• ClientDnsTimeout
• ClientFrameMax
• Connection
• ConnectionDispatchQueueCapacity
• ConnectionOptions
• CoordinatorEndpoint
• EpochEndOffset
• ExponentialBackoff
• FetchMinBytes
• FetchPartitionResult
• FetchedRecord
• FinalizedFeatures
• IsolatedFetch
• MetadataRecoveryRebootstrapTrigger
• MetadataTopics
• VersionBoundedRequest
• oauth::ClientCredentialsConfig
• oauth::ClientCredentialsTokenProvider
• oauth::JwtBearerConfig
• oauth::JwtBearerTokenProvider
• sasl::SaslSession
• security::ClientSecurity
• security::Password
• security::TlsConnectorConfig
• telemetry::ClientMetrics
• telemetry::ClientTelemetry
• telemetry::ClientTelemetryConfig
• telemetry::Counter
• telemetry::Gauge
• telemetry::MetricKey
• telemetry::NetworkMetrics
• telemetry::TelemetryTiming
• telemetry::otlp::KeyValue
• telemetry::otlp::Metric
• telemetry::otlp::MetricsData
• telemetry::otlp::NumberDataPoint
• telemetry::otlp::OtlpDecodeError
• telemetry::otlp::Resource
• telemetry::otlp::ResourceMetrics
• telemetry::otlp::ScopeMetrics
• transport::ConnectorAlreadyInstalled
• transport::SocketOptions

Enums

• AuthenticationError
• ClientDnsLookup
• ClientError
• CoordinatorKeyType
• MetadataRecoveryStrategy
• MetadataScope
• sasl::OAuthBearerTokenSource
• sasl::OutboundSaslError
• sasl::SaslAuthenticationError
• sasl::SaslCredentials
• security::KeyStore
• security::TlsConfigError
• security::TlsVersion
• security::TrustStore
• telemetry::TelemetryClientType
• telemetry::otlp::AggregationTemporality
• telemetry::otlp::MetricData
• telemetry::otlp::NumberValue

Traits

• ClientDuplex
• ProtocolRequest
• oauth::OAuthBearerTokenProvider
• telemetry::TelemetryConnections
• transport::Connector

Functions

• all_topics_request
• build_find_coordinator
• coordinator_endpoint
• fetch_partition
• fetch_partition_with_isolation
• fetch_partition_with_isolation_progress
• find_coordinator
• oauth::spawn_background_refresh
• offset_for_leader_epoch
• sasl::outbound_sasl
• security::connection_target_host
• telemetry::client_instance_id
• topics_request
• transport::dial
• transport::install_connector
• transport::resolve

Type Aliases

• AllTopicsOffsetFetch
• FetchedHeader
• MembersOnlyLeaveGroup
• TopicNameOffsetCommit
• TopicNameOffsetFetch
• oauth::RefreshFuture
• oauth::TokenFuture
• transport::ConnectFuture

Constants

• DEFAULT_CLIENT_DNS_TIMEOUT
• DEFAULT_CLIENT_FRAME_MAX
• DEFAULT_CLIENT_REQUEST_TIMEOUT
• DEFAULT_CONNECTIONS_MAX_IDLE
• DEFAULT_CONNECTION_DISPATCH_QUEUE_CAPACITY
• DEFAULT_FETCH_MIN
• DEFAULT_FETCH_RESPONSE_MAX
• DEFAULT_METADATA_RECOVERY_REBOOTSTRAP_TRIGGER
• DEFAULT_RECEIVE_BUFFER
• DEFAULT_RECONNECT_BACKOFF
• DEFAULT_RECONNECT_BACKOFF_MAX
• DEFAULT_SEND_BUFFER
• DEFAULT_SOCKET_CONNECTION_SETUP_TIMEOUT
• DEFAULT_SOCKET_CONNECTION_SETUP_TIMEOUT_MAX
• KAFKA_BACKOFF_JITTER
• KAFKA_BACKOFF_MULTIPLIER
• MAX_CLIENT_FRAME_BYTES
• UNKNOWN_FINALIZED_FEATURES_EPOCH
• oauth::DEFAULT_LOGIN_REFRESH_BUFFER
• oauth::DEFAULT_LOGIN_REFRESH_MIN_PERIOD
• oauth::DEFAULT_LOGIN_REFRESH_WINDOW_FACTOR
• oauth::DEFAULT_LOGIN_REFRESH_WINDOW_JITTER
• oauth::DEFAULT_LOGIN_RETRY_BACKOFF
• oauth::DEFAULT_LOGIN_RETRY_BACKOFF_MAX
• telemetry::TELEMETRY_METRIC_DOMAIN