We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
I am using a custom context with below code
struct CustomContext; impl ConsumerContext for CustomContext {} impl ClientContext for CustomContext { fn stats(&self, statistics: rdkafka::Statistics) { log::info!("{:?}", statistics); } }
This context is then passed to create a BaseConsumer client . The statistics.interval.ms is being set to 10000 in ClientConfig
BaseConsumer
statistics.interval.ms
10000
client_config.set("statistics.interval.ms", "10000");
let context = CustomContext; let base_consumer = BaseConsumer::from_config_and_context(config, context)?;
loop { //sleep 1 sec }
stats
v0.36.2
"OS_ARCH=amd64", "OS_FLAVOUR=debian-12", "OS_NAME=linux", "APP_VERSION=3.7.0", "BITNAMI_APP_NAME=kafka",
statistics.interval.ms=10000
Ubuntu
The text was updated successfully, but these errors were encountered:
Hello, did you subscribe the consumer to a topic first? Try that and then call poll().
Sorry, something went wrong.
No branches or pull requests
Description
I am using a custom context with below code
This context is then passed to create a
BaseConsumer
client . Thestatistics.interval.ms
is being set to10000
in ClientConfigHow to reproduce
client_config.set("statistics.interval.ms", "10000");
stats
method every 10 secsChecklist
v0.36.2
statistics.interval.ms=10000
Ubuntu
The text was updated successfully, but these errors were encountered: