[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {{KafkaConsumer}}, but these metrics put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These metrics should instead utilize the tags and put {{key="topic-partition"}} and {{value=${TOPIC-PARTITION_ID}}}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {{key="node/topic"}} and {{value=${NODE_ID}/${TOPIC_NAME} {}}}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {{KafkaConsumer}}, but these metrics put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These metrics should instead utilize the tags and put {{key="topic-partition"}} and {{value=${TOPIC-PARTITION_ID}}}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {{key="node/topic"}} and {{value=${NODE_ID}/${TOPIC_NAME}{}}}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement > Components: metrics >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to {{KafkaConsumer}}, but these metrics > put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These > metrics should instead utilize the tags and put {{key="topic-partition"}} and > {{value=${TOPIC-PARTITION_ID}}}. > Per-broker (node) and per-topic metrics utilize tags in this way by putting > {{key="node/topic"}} and {{value=${NODE_ID}/${TOPIC_NAME} {}}}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {{KafkaConsumer}}, but these metrics put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These metrics should instead utilize the tags and put {{key="topic-partition"}} and {{value=TOPIC-PARTITION_ID}}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {{key="node/topic"}} and {{value=NODE_ID/TOPIC_NAME}}. was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {{KafkaConsumer}}, but these metrics put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These metrics should instead utilize the tags and put {{key="topic-partition"}} and {{value=TOPIC-PARTITION_ID}}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {{key="node/topic"}} and {{value=NODE_ID/TOPIC_NAME}}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement > Components: metrics >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to {{KafkaConsumer}}, but these metrics > put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These > metrics should instead utilize the tags and put {{key="topic-partition"}} and > {{value=TOPIC-PARTITION_ID}}. > Per-broker (node) and per-topic metrics utilize tags in this way by putting > {{key="node/topic"}} and {{value=NODE_ID/TOPIC_NAME}}. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {{KafkaConsumer}}, but these metrics put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These metrics should instead utilize the tags and put {{key="topic-partition"}} and {{value=TOPIC-PARTITION_ID}}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {{key="node/topic"}} and {{value=NODE_ID/TOPIC_NAME}}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {{KafkaConsumer}}, but these metrics put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These metrics should instead utilize the tags and put {{key="topic-partition"}} and {{value=${TOPIC-PARTITION_ID}}}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {{key="node/topic"}} and {{value="NODE_ID/TOPIC_NAME"}}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement > Components: metrics >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to {{KafkaConsumer}}, but these metrics > put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These > metrics should instead utilize the tags and put {{key="topic-partition"}} and > {{value=TOPIC-PARTITION_ID}}. > Per-broker (node) and per-topic metrics utilize tags in this way by putting > {{key="node/topic"}} and {{value=NODE_ID/TOPIC_NAME}}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {{KafkaConsumer}}, but these metrics put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These metrics should instead utilize the tags and put {{key="topic-partition"}} and {{value=${TOPIC-PARTITION_ID}}}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {{key="node/topic"}} and {{value=${NODE_ID}/${TOPIC_NAME}{}}}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {{KafkaConsumer}}, but these metrics put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These metrics should instead utilize the tags and put {{key="topic-partition"}} and {{value="TOPIC-PARTITION_ID"}}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {{key="node/topic"}} and {{value="NODE_ID/TOPIC_NAME"{}}}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement > Components: metrics >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to {{KafkaConsumer}}, but these metrics > put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These > metrics should instead utilize the tags and put {{key="topic-partition"}} and > {{value=${TOPIC-PARTITION_ID}}}. > Per-broker (node) and per-topic metrics utilize tags in this way by putting > {{key="node/topic"}} and {{value=${NODE_ID}/${TOPIC_NAME}{}}}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {{KafkaConsumer}}, but these metrics put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These metrics should instead utilize the tags and put {{key="topic-partition"}} and {{value=${TOPIC-PARTITION_ID}}}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {{key="node/topic"}} and {{value="NODE_ID/TOPIC_NAME"}}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {{KafkaConsumer}}, but these metrics put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These metrics should instead utilize the tags and put {{key="topic-partition"}} and {{value=${TOPIC-PARTITION_ID}}}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {{key="node/topic"}} and {{value=${NODE_ID}/${TOPIC_NAME} {}}}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement > Components: metrics >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to {{KafkaConsumer}}, but these metrics > put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These > metrics should instead utilize the tags and put {{key="topic-partition"}} and > {{value=${TOPIC-PARTITION_ID}}}. > Per-broker (node) and per-topic metrics utilize tags in this way by putting > {{key="node/topic"}} and {{value="NODE_ID/TOPIC_NAME"}}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Component/s: metrics > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement > Components: metrics >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to {{KafkaConsumer}}, but these metrics > put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These > metrics should instead utilize the tags and put {{key="topic-partition"}} and > {{value="TOPIC-PARTITION_ID"}}. > Per-broker (node) and per-topic metrics utilize tags in this way by putting > {{key="node/topic"}} and {{value="NODE_ID/TOPIC_NAME"{}}}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {{KafkaConsumer}}, but these metrics put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These metrics should instead utilize the tags and put {{key="topic-partition"}} and {{value="TOPIC-PARTITION_ID"}}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {{key="node/topic"}} and {{value="NODE_ID/TOPIC_NAME"{}}}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to KafkaConsumer, but these metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to {{KafkaConsumer}}, but these metrics > put the {{TOPIC-PARTITION_ID}} inside of the metric name itself. These > metrics should instead utilize the tags and put {{key="topic-partition"}} and > {{value="TOPIC-PARTITION_ID"}}. > Per-broker (node) and per-topic metrics utilize tags in this way by putting > {{key="node/topic"}} and {{value="NODE_ID/TOPIC_NAME"{}}}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to KafkaConsumer, but these metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to 'KafkaConsumer', but these metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to KafkaConsumer, but these metrics put > the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should > instead utilize the tags and put key="topic-partition" and > value="TOPIC-PARTITION_ID". > Per-broker (node) and per-topic metrics utilize tags in this way by putting > key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to 'KafkaConsumer', but these metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to KafkaConsumer, but these metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to 'KafkaConsumer', but these metrics put > the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should > instead utilize the tags and put key="topic-partition" and > value="TOPIC-PARTITION_ID". > Per-broker (node) and per-topic metrics utilize tags in this way by putting > key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to ```KafkaConsumer```, but these metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to KafkaConsumer, but these metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to ```KafkaConsumer```, but these metrics > put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics > should instead utilize the tags and put key="topic-partition" and > value="TOPIC-PARTITION_ID". > Per-broker (node) and per-topic metrics utilize tags in this way by putting > key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to KafkaConsumer, but these metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to ```KafkaConsumer```, but these metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to KafkaConsumer, but these metrics put > the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should > instead utilize the tags and put key="topic-partition" and > value="TOPIC-PARTITION_ID". > Per-broker (node) and per-topic metrics utilize tags in this way by putting > key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {code}KafkaConsumer{code}, but these metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to KafkaConsumer, but these metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to {code}KafkaConsumer{code}, but these > metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These > metrics should instead utilize the tags and put key="topic-partition" and > value="TOPIC-PARTITION_ID". > Per-broker (node) and per-topic metrics utilize tags in this way by putting > key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to KafkaConsumer, but these metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {code}KafkaConsumer{code}, but these metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to KafkaConsumer, but these metrics put > the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should > instead utilize the tags and put key="topic-partition" and > value="TOPIC-PARTITION_ID". > Per-broker (node) and per-topic metrics utilize tags in this way by putting > key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to KafkaConsumer, but these metrics put the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {noformat}KafkaConsumer{noformat}, but these metrics put the {noformat}TOPIC-PARTITION_ID{noformat} inside of the metric name itself. These metrics should instead utilize the tags and put {noformat}key="topic-partition"{noformat} and {noformat}value="TOPIC-PARTITION_ID"{noformat}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {noformat}key="node/topic"{noformat} and {noformat}value="NODE_ID/TOPIC_NAME"{noformat}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to KafkaConsumer, but these metrics put > the TOPIC-PARTITION_ID inside of the metric name itself. These metrics should > instead utilize the tags and put key="topic-partition" and > value="TOPIC-PARTITION_ID". > Per-broker (node) and per-topic metrics utilize tags in this way by putting > key="node/topic" and value="NODE_ID/TOPIC_NAME"{}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {noformat}KafkaConsumer{noformat}, but these metrics put the {noformat}TOPIC-PARTITION_ID{noformat} inside of the metric name itself. These metrics should instead utilize the tags and put {noformat}key="topic-partition"{noformat} and {noformat}value="TOPIC-PARTITION_ID"{noformat}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {noformat}key="node/topic"{noformat} and {noformat}value="NODE_ID/TOPIC_NAME"{noformat}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {}KafkaConsumer{}, but these metrics put the {}TOPIC-PARTITION_ID{} inside of the metric name itself. These metrics should instead utilize the tags and put {}key="topic-partition"{} and {}value="TOPIC-PARTITION_ID"{}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {}key="node/topic"{} and {}value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to {noformat}KafkaConsumer{noformat}, but > these metrics put the {noformat}TOPIC-PARTITION_ID{noformat} inside of the > metric name itself. These metrics should instead utilize the tags and put > {noformat}key="topic-partition"{noformat} and > {noformat}value="TOPIC-PARTITION_ID"{noformat}. > Per-broker (node) and per-topic metrics utilize tags in this way by putting > {noformat}key="node/topic"{noformat} and > {noformat}value="NODE_ID/TOPIC_NAME"{noformat}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {}KafkaConsumer{}, but these metrics put the {}TOPIC-PARTITION_ID{} inside of the metric name itself. These metrics should instead utilize the tags and put {}key="topic-partition"{} and {}value="TOPIC-PARTITION_ID"{}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {}key="node/topic"{} and {}value="NODE_ID/TOPIC_NAME"{}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {KafkaConsumer}, but these metrics put the {TOPIC-PARTITION_ID} inside of the metric name itself. These metrics should instead utilize the tags and put {key="topic-partition"} and {value="TOPIC-PARTITION_ID"}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {key="node/topic"} and {value="NODE_ID/TOPIC_NAME"}. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to {}KafkaConsumer{}, but these metrics > put the {}TOPIC-PARTITION_ID{} inside of the metric name itself. These > metrics should instead utilize the tags and put {}key="topic-partition"{} and > {}value="TOPIC-PARTITION_ID"{}. > Per-broker (node) and per-topic metrics utilize tags in this way by putting > {}key="node/topic"{} and {}value="NODE_ID/TOPIC_NAME"{}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to {KafkaConsumer}, but these metrics put the {TOPIC-PARTITION_ID} inside of the metric name itself. These metrics should instead utilize the tags and put {key="topic-partition"} and {value="TOPIC-PARTITION_ID"}. Per-broker (node) and per-topic metrics utilize tags in this way by putting {key="node/topic"} and {value="NODE_ID/TOPIC_NAME"}. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to `KafkaConsumer`, but these metrics put the `TOPIC-PARTITION_ID` inside of the metric name itself. These metrics should instead utilize the tags and put `key="topic-partition"` and `value="TOPIC-PARTITION_ID"`. Per-broker (node) and per-topic metrics utilize tags in this way by putting `key="node/topic"` and `value="NODE_ID/TOPIC_NAME"`. I'm guessing a KIP is needed for this as this changes a public API (metric)? > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to {KafkaConsumer}, but these metrics put > the {TOPIC-PARTITION_ID} inside of the metric name itself. These metrics > should instead utilize the tags and put {key="topic-partition"} and > {value="TOPIC-PARTITION_ID"}. > Per-broker (node) and per-topic metrics utilize tags in this way by putting > {key="node/topic"} and {value="NODE_ID/TOPIC_NAME"}. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to `KafkaConsumer`, but these metrics put the `TOPIC-PARTITION_ID` inside of the metric name itself. These metrics should instead utilize the tags and put `key="topic-partition"` and `value="TOPIC-PARTITION_ID"`. Per-broker (node) and per-topic metrics utilize tags in this way by putting `key="node/topic"` and `value="NODE_ID/TOPIC_NAME"`. I'm guessing a KIP is needed for this as this changes a public API (metric)? was: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to KafkaConsumer, but these metrics put the "TOPIC-PARTITION_ID" inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME". > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to `KafkaConsumer`, but these metrics put > the `TOPIC-PARTITION_ID` inside of the metric name itself. These metrics > should instead utilize the tags and put `key="topic-partition"` and > `value="TOPIC-PARTITION_ID"`. > Per-broker (node) and per-topic metrics utilize tags in this way by putting > `key="node/topic"` and `value="NODE_ID/TOPIC_NAME"`. > I'm guessing a KIP is needed for this as this changes a public API (metric)? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name
[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description: [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] brought per partition lag metrics to KafkaConsumer, but these metrics put the "TOPIC-PARTITION_ID" inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME". was: A KIP will be needed for this (?) as this requires a change to the public API (metric). [KIP-92](https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer) brought per partition lag metrics to KafkaConsumer, but these metrics put the "TOPIC-PARTITION_ID" inside of the metric name itself. These metrics should instead utilize the tags and put key="topic-partition" and value="TOPIC-PARTITION_ID". Per-broker (node) and per-topic metrics utilize tags in this way by putting key="node/topic" and value="NODE_ID/TOPIC_NAME". > Change Consumer per partition lag metrics to put topic-partition-id in tags > instead of metric name > -- > > Key: KAFKA-5991 > URL: https://issues.apache.org/jira/browse/KAFKA-5991 > Project: Kafka > Issue Type: Improvement >Affects Versions: 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.2.0, 0.11.0.0 >Reporter: Kevin Lu >Priority: Minor > Labels: metrics > > [KIP-92|https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer] > brought per partition lag metrics to KafkaConsumer, but these metrics put > the "TOPIC-PARTITION_ID" inside of the metric name itself. These metrics > should instead utilize the tags and put key="topic-partition" and > value="TOPIC-PARTITION_ID". > Per-broker (node) and per-topic metrics utilize tags in this way by putting > key="node/topic" and value="NODE_ID/TOPIC_NAME". -- This message was sent by Atlassian JIRA (v6.4.14#64029)