Hey!
I need help configuring my telegraf values.I have provided my telegraf files below. Can I reduce my max_undelivered messages in this case. From my Internal Stats, I am getting metrics gathered = 950 metrics/min. and metrics written/min= 1090K .
[[inputs.kafka_consumer]]
brokers = ["${LAV_BROKER_ONE}","${LAV_BROKER_TWO}"]
topics = ["${BROKER_TOPIC}"]
offset = “oldest”
#balance_strategy = “roundrobin”
max_message_len = 1000000
max_undelivered_messages = 500000
consumer_group = “iit_metrics_consumers_new”
data_format = “json”
name_override = “${Measurement}”
interval = “1s”
[inputs.kafka_consumer.tags]
setup = “lav1”
brokers = ["${LAV_BROKER_ONE}","${LAV_BROKER_TWO}"]
topics = ["${BROKER_TOPIC}"]
offset = “oldest”
#balance_strategy = “roundrobin”
max_message_len = 1000000
max_undelivered_messages = 500000
consumer_group = “iit_metrics_consumers_new1”
data_format = “json”
json_string_fields = [“counters_*”]
name_override = “${Measurement}”
interval = “1s”
[inputs.kafka_consumer.tags]
setup = “lav2”
[agent]
metric_batch_size = 8000
metric_buffer_limit = 100000
debug = true
omit_hostname = true
[[outputs.influxdb_v2]]
tagexclude = [“method”,“name”,“host”]
fielddrop = [“value”]
urls = [“XXXX”]
token = “XXXXXX”
organization = “${ORGANIZATION}”
bucket = “${BUCKET}”
flush_interval = “1s”
This is how the telegraf logs look like:
I want to reduce memory consumption and also take care that no buffer overflow occurs.
Thanks