Kafla connect integration

guilhemmarchand · Oct 18, 2018 · cc30ce8 · cc30ce8
1 parent 14fdd8f
commit cc30ce8
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/DA-ITSI-TELEGRAF-KAFKA/default/data/ui/views/DA-ITSI-TELEGRAF-KAFKA_Kafka-Connect-view.xml b/DA-ITSI-TELEGRAF-KAFKA/default/data/ui/views/DA-ITSI-TELEGRAF-KAFKA_Kafka-Connect-view.xml
@@ -1,4 +1,4 @@
-<form stylesheet="DA-ITSI-TELEGRAF-KAFKA:common.css" hideEdit="false" isVisible="False">
+<form stylesheet="DA-ITSI-TELEGRAF-KAFKA:common.css" hideEdit="True" isVisible="False">
     <label>Kafka Connect - Entity health view</label>
 
     <search id="connect_state_summary">

diff --git a/DA-ITSI-TELEGRAF-KAFKA/default/inputs.conf b/DA-ITSI-TELEGRAF-KAFKA/default/inputs.conf
@@ -86,9 +86,9 @@ interval = 14400
 #
 
 [itsi_csv_import://DA-ITSI-TELEGRAF-KAFKA-entity_import_kafka_connect_tasks]
-entity_identifier_fields = kafka_connect_task,kafka_connect_nodes
+entity_identifier_fields = kafka_task,kafka_task_nodes
 entity_informational_fields = itsi_role
-entity_title_field = kafka_connect_task
+entity_title_field = kafka_task
 import_from_search = 1
 index_earliest = -4h
 index_latest = now

diff --git a/DA-ITSI-TELEGRAF-KAFKA/default/savedsearches.conf b/DA-ITSI-TELEGRAF-KAFKA/default/savedsearches.conf
@@ -77,10 +77,10 @@ request.ui_dispatch_view = search
 
 [DA-ITSI-TELEGRAF-KAFKA-Inventory_Search_kafka_connect_tasks]
 search = | mcatalog values(jolokia_agent_url) as jolokia_agent_url values(metric_name) as metric_name where `telegraf_kafka_index` metric_name="kafka_connect.source-task.source-record-poll-total" OR metric_name="kafka_connect.sink-task.sink-record-read-total" connector=* by connector\
-| eval itsi_role=case(match(metric_name, "sink-task"), "kafka_connect_sink_connector", match(metric_name, "source-task"), "kafka_connect_source_connector")\
-| fields - metric_name | rename jolokia_agent_url as kafka_connect_nodes, connector as kafka_connect_task\
-| nomv kafka_connect_nodes | rex field=kafka_connect_nodes mode=sed "s/ /|/g"\
-| fields itsi_role, kafka_connect_task, kafka_connect_nodes
+| eval itsi_role=case(match(metric_name, "sink-task"), "kafka_sink_task", match(metric_name, "source-task"), "kafka_source_task")\
+| fields - metric_name | rename jolokia_agent_url as kafka_connect_nodes, connector as kafka_task\
+| nomv kafka_task_nodes | rex field=kafka_task_nodes mode=sed "s/ /|/g"\
+| fields itsi_role, kafka_task, kafka_task_nodes
 request.ui_dispatch_app = itsi
 request.ui_dispatch_view = search
 

diff --git a/DA-ITSI-TELEGRAF-KAFKA_100.tgz b/DA-ITSI-TELEGRAF-KAFKA_100.tgz