Comments (2)
If the outputs.cratedb buffer fills up to metric_batch_size, the oldest metrics are expected to be dropped. Regardless of this, InfluxDB should never stop writing
Unfortunately, this is not possible when using a service input like MQTT Consumer. Service input plugins use tracking metrics that ensure the delivery of metrics from the input all the way to the output and notify the original source once delivered.
Additionally, these types of inputs will only read up to max_undelivered_messages
, which is 1000 by default. This is because without some sort of limit you could easily overwhelm telegraf and whatever outputs you are using by collecting and sending a huge number of messages all at once.
If your instance has read up to 1000 metrics, which is what your buffer reports, and the messages are unable to be delivered, the mqtt_consumer plugin will not continue to read any further messages until that changes.
One possible alternative is to have two separate mqtt plugins one for each output.
from telegraf.
Ok, so the problem is with the mqtt consumer. Makes sense. Using two inputs could be a valid workaround for me.
Thanks!
from telegraf.
Related Issues (20)
- UINT64 (TotalPhysicalMemory) is displayed as string HOT 2
- TAG column HOT 13
- [[inputs.tail]] Collect full data for each update HOT 6
- chore: support new golang version 1.22.6
- feat(outputs.kafka): Option to add metric name as record header HOT 3
- [bug report] smartctl input plugin reports incorrect device type
- `dedup` processor doesn't dedupe as expected HOT 4
- feat: flag to validate config files HOT 2
- Mongodb Output Plugin Error - Invalid namespace specified HOT 2
- input.http_listener_v2 add possibility to listen over unix socket HOT 2
- internal gnmi selfstat has source label different than gnmi subscription HOT 3
- TeamSpeak plugin "unexpected EOF" error HOT 1
- Template serializer does not work on
- Prevent discarding of messages in AMQP Consumer plugin HOT 2
- Telegraf makes 4 requests for MySQL HOT 3
- Systemd Units config errors on being given scope HOT 2
- chore: support new golang version 1.23.0
- How to optimize ping plugin concurrency HOT 2
- feat(inputs.mysql): Add support gather replica status
- Excessive logging for regex processor HOT 2
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from telegraf.