You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mi...@apache.org on 2023/07/06 13:28:14 UTC
[kafka] branch trunk updated: MINOR: Update connector status metric description to include 'stopped' as a potential value (#13967)
This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new a1a3ec0bcb4 MINOR: Update connector status metric description to include 'stopped' as a potential value (#13967)
a1a3ec0bcb4 is described below
commit a1a3ec0bcb4cc64ee1a4582b645d31de16e101cd
Author: Yash Mayya <ya...@gmail.com>
AuthorDate: Thu Jul 6 14:28:07 2023 +0100
MINOR: Update connector status metric description to include 'stopped' as a potential value (#13967)
Reviewers: Mickael Maison <mi...@gmail.com>
---
.../java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java
index b5626358cdd..2a4fe6ae716 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java
@@ -128,7 +128,7 @@ public class ConnectMetricsRegistry {
connectorTags.add(CONNECTOR_TAG_NAME);
connectorStatus = createTemplate("status", CONNECTOR_GROUP_NAME,
- "The status of the connector. One of 'unassigned', 'running', 'paused', 'failed', or " +
+ "The status of the connector. One of 'unassigned', 'running', 'paused', 'stopped', 'failed', or " +
"'restarting'.",
connectorTags);
connectorType = createTemplate("connector-type", CONNECTOR_GROUP_NAME, "The type of the connector. One of 'source' or 'sink'.",