Skip to content

Commit

Permalink
sink tasks monitoring in progress
Browse files Browse the repository at this point in the history
  • Loading branch information
@guilhemmarchand
guilhemmarchand committed Oct 20, 2018
1 parent cc3652c commit 620b55b
Show file tree
Hide file tree
Showing 8 changed files with 2,275 additions and 92 deletions.
89 changes: 2 additions & 87 deletions DA-ITSI-TELEGRAF-KAFKA/default/data/ui/views/DA-ITSI-TELEGRAF-KAFKA_Kafka-Connect-view.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -95,119 +95,34 @@
<unset token="chart3"></unset>
<unset token="chart4"></unset>
<unset token="chart5"></unset>
<unset token="chart6"></unset>
<unset token="chart7"></unset>
<unset token="chart8"></unset>
<unset token="chart9"></unset>
<unset token="chart10"></unset>
</condition>
<condition value="chart2">
<set token="chart2">true</set>
<unset token="chart1"></unset>
<unset token="chart3"></unset>
<unset token="chart4"></unset>
<unset token="chart5"></unset>
<unset token="chart6"></unset>
<unset token="chart7"></unset>
<unset token="chart8"></unset>
<unset token="chart9"></unset>
<unset token="chart10"></unset>
</condition>
<condition value="chart3">
<set token="chart3">true</set>
<unset token="chart1"></unset>
<unset token="chart2"></unset>
<unset token="chart4"></unset>
<unset token="chart5"></unset>
<unset token="chart6"></unset>
<unset token="chart7"></unset>
<unset token="chart8"></unset>
<unset token="chart9"></unset>
<unset token="chart10"></unset>
</condition>
<condition value="chart4">
<set token="chart4">true</set>
<unset token="chart1"></unset>
<unset token="chart2"></unset>
<unset token="chart3"></unset>
<unset token="chart5"></unset>
<unset token="chart6"></unset>
<unset token="chart7"></unset>
<unset token="chart8"></unset>
<unset token="chart9"></unset>
<unset token="chart10"></unset>
</condition>
<condition value="chart5">
<set token="chart5">true</set>
<unset token="chart1"></unset>
<unset token="chart2"></unset>
<unset token="chart3"></unset>
<unset token="chart4"></unset>
<unset token="chart6"></unset>
<unset token="chart7"></unset>
<unset token="chart8"></unset>
<unset token="chart9"></unset>
<unset token="chart10"></unset>
</condition>
<condition value="chart6">
<set token="chart6">true</set>
<unset token="chart1"></unset>
<unset token="chart2"></unset>
<unset token="chart3"></unset>
<unset token="chart4"></unset>
<unset token="chart5"></unset>
<unset token="chart7"></unset>
<unset token="chart8"></unset>
<unset token="chart9"></unset>
<unset token="chart10"></unset>
</condition>
<condition value="chart7">
<set token="chart7">true</set>
<unset token="chart1"></unset>
<unset token="chart2"></unset>
<unset token="chart3"></unset>
<unset token="chart4"></unset>
<unset token="chart5"></unset>
<unset token="chart6"></unset>
<unset token="chart8"></unset>
<unset token="chart9"></unset>
<unset token="chart10"></unset>
</condition>
<condition value="chart8">
<set token="chart8">true</set>
<unset token="chart1"></unset>
<unset token="chart2"></unset>
<unset token="chart3"></unset>
<unset token="chart4"></unset>
<unset token="chart5"></unset>
<unset token="chart6"></unset>
<unset token="chart7"></unset>
<unset token="chart9"></unset>
<unset token="chart10"></unset>
</condition>
<condition value="chart9">
<set token="chart9">true</set>
<unset token="chart1"></unset>
<unset token="chart2"></unset>
<unset token="chart3"></unset>
<unset token="chart4"></unset>
<unset token="chart5"></unset>
<unset token="chart6"></unset>
<unset token="chart7"></unset>
<unset token="chart8"></unset>
<unset token="chart10"></unset>
</condition>
<condition value="chart10">
<set token="chart10">true</set>
<unset token="chart1"></unset>
<unset token="chart2"></unset>
<unset token="chart3"></unset>
<unset token="chart4"></unset>
<unset token="chart5"></unset>
<unset token="chart6"></unset>
<unset token="chart7"></unset>
<unset token="chart8"></unset>
<unset token="chart9"></unset>
</condition>
</change>
</input>
Expand Down Expand Up @@ -756,7 +671,7 @@
</chart>
</panel>
<panel>
<title>The number of failed writes to the dead letter queue</title>
<title>The number of attempted writes to the dead letter queue</title>
<chart>
<search depends="$chart5$">
<query>| mstats avg(_value) prestats=true where `telegraf_kafka_index` metric_name="kafka_connect.error-task.deadletterqueue-produce-requests" jolokia_agent_url=$jolokia_agent_url$ by connector span=10s
Expand All @@ -778,7 +693,7 @@

<row depends="$chart5$">
<panel>
<title>The number of attempted writes to the dead letter queue</title>
<title>The number of failed writes to the dead letter queue</title>
<chart>
<search depends="$chart5$">
<query>| mstats avg(_value) prestats=true where `telegraf_kafka_index` metric_name="kafka_connect.error-task.deadletterqueue-produce-failures" jolokia_agent_url=$jolokia_agent_url$ by connector span=10s
Expand Down
4 changes: 2 additions & 2 deletions DA-ITSI-TELEGRAF-KAFKA/default/inputs.conf
View file
Original file line number Diff line number Diff line change
Expand Up @@ -85,14 +85,14 @@ interval = 14400
# \_\ /_/
#

[itsi_csv_import://DA-ITSI-TELEGRAF-KAFKA-entity_import_kafka_connect_tasks]
[itsi_csv_import://DA-ITSI-TELEGRAF-KAFKA-entity_import_kafka_tasks]
entity_identifier_fields = kafka_task,kafka_task_nodes
entity_informational_fields = itsi_role
entity_title_field = kafka_task
import_from_search = 1
index_earliest = -4h
index_latest = now
search_string = | savedsearch DA-ITSI-TELEGRAF-KAFKA-Inventory_Search_kafka_connect_tasks
search_string = | savedsearch DA-ITSI-TELEGRAF-KAFKA-Inventory_Search_kafka_tasks
service_title_field = null
update_type = UPSERT
interval = 14400
Expand Down

0 comments on commit 620b55b

Please sign in to comment.