From 760ad3e366977b2ff84a811ed840e5af3d8b3255 Mon Sep 17 00:00:00 2001
From: Erikas <erikmnkl@gmail.com>
Date: Thu, 13 May 2021 23:36:46 +0300
Subject: [PATCH] Update kafka.conf (#9263)

---
 plugins/inputs/jolokia2/examples/kafka.conf | 60 +++++++++++++++++++--
 1 file changed, 57 insertions(+), 3 deletions(-)

diff --git a/plugins/inputs/jolokia2/examples/kafka.conf b/plugins/inputs/jolokia2/examples/kafka.conf
index ae34831fc..24053b5ad 100644
--- a/plugins/inputs/jolokia2/examples/kafka.conf
+++ b/plugins/inputs/jolokia2/examples/kafka.conf
@@ -1,6 +1,30 @@
 
 [[inputs.jolokia2_agent]]
   name_prefix = "kafka_"
+  
+  ## If you intend to use "non_negative_derivative(1s)" with "*.count" fields, you don't need precalculated fields.
+  # fielddrop   = [
+  #   "*.EventType",
+  #   "*.FifteenMinuteRate",
+  #   "*.FiveMinuteRate",
+  #   "*.MeanRate",
+  #   "*.OneMinuteRate",
+  #   "*.RateUnit",
+  #   "*.LatencyUnit",
+  #   "*.50thPercentile",
+  #   "*.75thPercentile",
+  #   "*.95thPercentile",
+  #   "*.98thPercentile",
+  #   "*.99thPercentile",
+  #   "*.999thPercentile",
+  #   "*.Min",
+  #   "*.Mean",
+  #   "*.Max",
+  #   "*.StdDev"
+  # ]
+  
+  ## jolokia_agent_url tag is not needed if you have only one instance of Kafka on the server.
+  # tagexclude = ["jolokia_agent_url"]
 
   urls = ["http://localhost:8080/jolokia"]
 
@@ -21,9 +45,15 @@
     field_name   = "$2"
 
   [[inputs.jolokia2_agent.metric]]
-    name     = "client"
-    mbean    = "kafka.server:client-id=*,type=*"
-    tag_keys = ["client-id", "type"]
+    name         = "zookeeper"
+    mbean        = "kafka.server:name=*,type=SessionExpireListener"
+    field_prefix = "$1."
+
+  [[inputs.jolokia2_agent.metric]]
+    name     = "user"
+    mbean    = "kafka.server:user=*,type=Request"
+    field_prefix = ""
+    tag_keys = ["user"]
 
   [[inputs.jolokia2_agent.metric]]
     name         = "request"
@@ -53,3 +83,27 @@
     mbean      = "kafka.cluster:name=UnderReplicated,partition=*,topic=*,type=Partition"
     field_name = "UnderReplicatedPartitions"
     tag_keys   = ["topic", "partition"]
+
+## If you have multiple instances of Kafka on the server, use 'jolokia_agent_url' as identity of each instance
+# [[processors.rename]]
+#   namepass = ["kafka_*"]
+#   order = 1
+#   [[processors.rename.replace]]
+#     tag = "jolokia_agent_url"
+#     dest = "instance"
+# 
+# [[processors.regex]]
+#   namepass = ["kafka_*"]
+#   order = 2
+#   [[processors.regex.tags]]
+#     key = "instance"
+#     pattern = "^.+:8080/.+$"
+#     replacement = "0"
+#   [[processors.regex.tags]]
+#     key = "instance"
+#     pattern = "^.+:8081/.+$"
+#     replacement = "1"
+#   [[processors.regex.tags]]
+#     key = "instance"
+#     pattern = "^.+:8082/.+$"
+#     replacement = "2"