Skip to content

Commit f97b2fa

Browse files
tlsdnwn55신우주(롯데쇼핑 e커머스-클라우드플랫폼팀)
and
신우주(롯데쇼핑 e커머스-클라우드플랫폼팀)
authored
fix: Confluent Platform Intergration - Correct Mbean regex stream thread metric (#17490)
* fix: stream client metric to thread metric * Add: change log * add better change log * add: legacy stream theard metric for backwards compatibility with at least version 5 of confluent platform * fix: appropriate change log --------- Co-authored-by: 신우주(롯데쇼핑 e커머스-클라우드플랫폼팀) <woojoo.shin@lotte.net>
1 parent 2e308c9 commit f97b2fa

File tree

2 files changed

+103
-1
lines changed

2 files changed

+103
-1
lines changed
Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
2+
Add a Bean regex for stream thread metrics for Confluent version >=5.5.0. Previously, Stream Thread Metrics were not collected. Also added one useful attribute for debugging stream thread performance.

confluent_platform/datadog_checks/confluent_platform/data/metrics.yaml

Lines changed: 101 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1600,7 +1600,107 @@ jmx_metrics:
16001600

16011601

16021602
# Components Metrics:
1603-
# - Confluent Streams Thread: https://docs.confluent.io/current/streams/monitoring.html#built-in-metrics
1603+
# - Confluent Streams Thread: https://docs.confluent.io/current/streams/monitoring.html#thread-metrics
1604+
- include:
1605+
domain: kafka.streams
1606+
bean_regex: kafka\.streams:type=stream-thread-metrics,thread-id=.*
1607+
attribute:
1608+
blocked-time-ns-total:
1609+
# The total time the Kafka Streams thread spent blocked on Kafka since it was started, in nanoseconds (ns).
1610+
alias: confluent.$domain.stream.$attribute
1611+
metric_type: gauge
1612+
commit-latency-avg:
1613+
# The average value of commit-latency.
1614+
alias: confluent.$domain.stream.$attribute
1615+
metric_type: gauge
1616+
commit-latency-max:
1617+
# The maximum value of commit-latency.
1618+
alias: confluent.$domain.stream.$attribute
1619+
metric_type: gauge
1620+
commit-rate:
1621+
# The average per-second number of commit calls
1622+
alias: confluent.$domain.stream.$attribute
1623+
metric_type: gauge
1624+
commit-total:
1625+
# The total number of commit calls
1626+
alias: confluent.$domain.stream.$attribute
1627+
metric_type: gauge
1628+
poll-latency-avg:
1629+
# The average value of poll-latency.
1630+
alias: confluent.$domain.stream.$attribute
1631+
metric_type: gauge
1632+
poll-latency-max:
1633+
# The maximum value of poll-latency.
1634+
alias: confluent.$domain.stream.$attribute
1635+
metric_type: gauge
1636+
poll-rate:
1637+
# The average per-second number of poll calls
1638+
alias: confluent.$domain.stream.$attribute
1639+
metric_type: gauge
1640+
poll-total:
1641+
# The total number of poll calls
1642+
alias: confluent.$domain.stream.$attribute
1643+
metric_type: gauge
1644+
process-latency-avg:
1645+
# The average value of process-latency.
1646+
alias: confluent.$domain.stream.$attribute
1647+
metric_type: gauge
1648+
process-latency-max:
1649+
# The maximum value of process-latency.
1650+
alias: confluent.$domain.stream.$attribute
1651+
metric_type: gauge
1652+
process-rate:
1653+
# The average per-second number of process calls
1654+
alias: confluent.$domain.stream.$attribute
1655+
metric_type: gauge
1656+
process-total:
1657+
# The total number of process calls
1658+
alias: confluent.$domain.stream.$attribute
1659+
metric_type: gauge
1660+
punctuate-latency-avg:
1661+
# The average value of punctuate-latency.
1662+
alias: confluent.$domain.stream.$attribute
1663+
metric_type: gauge
1664+
punctuate-latency-max:
1665+
# The maximum value of punctuate-latency.
1666+
alias: confluent.$domain.stream.$attribute
1667+
metric_type: gauge
1668+
punctuate-rate:
1669+
# The average per-second number of punctuate calls
1670+
alias: confluent.$domain.stream.$attribute
1671+
metric_type: gauge
1672+
punctuate-total:
1673+
# The total number of punctuate calls
1674+
alias: confluent.$domain.stream.$attribute
1675+
metric_type: gauge
1676+
skipped-records-rate:
1677+
# The average per-second number of skipped records
1678+
alias: confluent.$domain.stream.$attribute
1679+
metric_type: gauge
1680+
skipped-records-total:
1681+
# The total number of skipped records
1682+
alias: confluent.$domain.stream.$attribute
1683+
metric_type: gauge
1684+
task-closed-rate:
1685+
# The average per-second number of closed tasks
1686+
alias: confluent.$domain.stream.$attribute
1687+
metric_type: gauge
1688+
task-closed-total:
1689+
# The total number of closed tasks
1690+
alias: confluent.$domain.stream.$attribute
1691+
metric_type: gauge
1692+
task-created-rate:
1693+
# The average per-second number of newly created tasks
1694+
alias: confluent.$domain.stream.$attribute
1695+
metric_type: gauge
1696+
task-created-total:
1697+
# The total number of newly created tasks
1698+
alias: confluent.$domain.stream.$attribute
1699+
metric_type: gauge
1700+
1701+
# Components Metrics:
1702+
# - Confluent Streams Thread: https://docs.confluent.io/legacy/platform/5.4.10/streams/monitoring.html#built-in-metrics
1703+
# For backwards compatibility with at least version 5.4.10 of confluent platform
16041704
- include:
16051705
domain: kafka.streams
16061706
bean_regex: kafka\.streams:type=stream-metrics,client-id=.*

0 commit comments

Comments
 (0)