Struct rdkafka::client::DefaultClientContext

pub struct DefaultClientContext;

An empty ClientContext that can be used when no customizations are needed.

Uses the default callback implementations provided by ClientContext.

Trait Implementations

impl ClientContext for DefaultClientContext

const ENABLE_REFRESH_OAUTH_TOKEN: bool = false

Whether to periodically refresh the SASL OAUTHBEARER token by calling ClientContext::generate_oauth_token.

fn log(&self, level: RDKafkaLogLevel, fac: &str, log_message: &str)

Receives log lines from librdkafka.

fn stats(&self, statistics: Statistics)

Receives the decoded statistics of the librdkafka client. To enable, the statistics.interval.ms configuration parameter must be specified.

fn stats_raw(&self, statistics: &[u8])

Receives the JSON-encoded statistics of the librdkafka client. To enable, the statistics.interval.ms configuration parameter must be specified.

fn error(&self, error: KafkaError, reason: &str)

Receives global errors from the librdkafka client.

fn rewrite_broker_addr(&self, addr: BrokerAddr) -> BrokerAddr

Rewrites a broker address for DNS resolution.

fn generate_oauth_token( &self, _oauthbearer_config: Option<&str> ) -> Result<OAuthToken, Box<dyn Error>>

Generates an OAuth token from the provided configuration.

impl Clone for DefaultClientContext

fn clone(&self) -> DefaultClientContext

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DefaultClientContext

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for DefaultClientContext

fn default() -> DefaultClientContext

Returns the “default value” for a type.