Skip to content

Commit

Permalink
Add client configs
Browse files Browse the repository at this point in the history
Signed-off-by: Liam Clarke <liam.clarke@adscale.co.nz>
  • Loading branch information
Liam Clarke committed Aug 14, 2019
1 parent cae9f26 commit 30f0563
Show file tree
Hide file tree
Showing 2 changed files with 122 additions and 0 deletions.
42 changes: 42 additions & 0 deletions example_configs/kafka-consumer-1-0.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,42 @@
---
lowercaseOutputName: false
lowercaseOutputLabelNames: false
whitelistObjectNames: ["kafka.consumer:*"]
#All these metrics taken from recommendations in chapter 10 of Kafka: The Definitive Guide
rules:
- pattern: 'kafka.consumer<type=consumer-coordinator-metrics, client-id=(.+)><>commit-latency-avg'
name: kafka_consumer_commit_latency_ms_avg
valueFactor: 0.001
labels:
client_id: $1
help: "How long it takes the consumers to commit offsets to brokers"
type: GAUGE
attrNameSnakeCase: false

- pattern: 'kafka.consumer<type=consumer-coordinator-metrics, client-id=(.+)><>sync-time-avg'
name: kafka_consumer_sync_time_ms_avg
valueFactor: 0.001
labels:
client_id: $1
help: "How much time the consumer is spent in negotiations over who gets what partitions during a rebalance operation"
type: GAUGE
attrNameSnakeCase: false

- pattern: 'kafka.consumer<type=consumer-coordinator-metrics, client-id=(.+)><>sync-rate'
name: kafka_consumer_sync_rate_per_second
valueFactor: 0.001
labels:
client_id: $1
help: "How much sync operations are taking place as part of a consumer rebalance"
type: GAUGE
attrNameSnakeCase: false


- pattern: 'kafka.consumer<type=consumer-coordinator-metrics, client-id=(.+)><>assigned-partitions'
name: kafka_consumer_sync_rate_per_second
valueFactor: 0.001
labels:
client_id: $1
help: "How much sync operations are taking place as part of a consumer rebalance"
type: GAUGE
attrNameSnakeCase: false
80 changes: 80 additions & 0 deletions example_configs/kafka-producer-1-0.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,80 @@
---
lowercaseOutputName: false
lowercaseOutputLabelNames: false
whitelistObjectNames: ["kafka.producer:*"]
#All these metrics taken from recommendations in chapter 10 of Kafka: The Definitive Guide
rules:
- pattern: 'kafka.producer<type=producer-metrics, client-id=(.+)><>record-error-rate'
name: kafka_producer_record_error_rate
valueFactor: 0.001
labels:
client_id: $1
help: "Producer record error rate (should never be above zero)"
type: GAUGE
attrNameSnakeCase: false

- pattern: 'kafka.producer<type=producer-metrics, client-id=(.+)><>request-latency-avg'
name: kafka_producer_request_latency_ms_avg
valueFactor: 0.001
labels:
client_id: $1
help: "Producer average request latency"
type: GAUGE
attrNameSnakeCase: false

- pattern: 'kafka.producer<type=producer-metrics, client-id=(.+)><>outgoing-byte-rate'
name: kafka_producer_outgoing_byte_rate
valueFactor: 0.001
labels:
client_id: $1
help: "Producer outgoing byte rate"
type: GAUGE
attrNameSnakeCase: false

- pattern: 'kafka.producer<type=producer-metrics, client-id=(.+)><>record-send-rate'
name: kafka_producer_record_send_rate
valueFactor: 0.001
labels:
client_id: $1
help: "Producer record send rate"
type: GAUGE
attrNameSnakeCase: false

- pattern: 'kafka.producer<type=producer-metrics, client-id=(.+)><>request-rate'
name: kafka_producer_record_send_rate
valueFactor: 0.001
labels:
client_id: $1
help: "Producer request rate (one request contains multiple batched records)"
type: GAUGE
attrNameSnakeCase: false

# This one isn't in the book, but good to add alerts on to detect buffer exhaustion / network issues etc.
- pattern: 'kafka.producer<type=producer-metrics, client-id=(.+)><>waiting-threads'
name: kafka_producer_waiting_threads_total
valueFactor: 0.001
labels:
client_id: $1
help: "Number of threads blocking on producer"
type: GAUGE
attrNameSnakeCase: false

- pattern: 'kafka.producer<type=producer-metrics, client-id=(.+)><>request-size-avg'
name: kafka_producer_request_size_avg
valueFactor: 0.001
labels:
client_id: $1
help: "Producer request size average"
type: GAUGE
attrNameSnakeCase: false

- pattern: 'kafka.producer<type=producer-metrics, client-id=(.+)><>batch-size-avg'
name: kafka_producer_batch_size_avg
valueFactor: 0.001
labels:
client_id: $1
help: "Producer batch size average"
type: GAUGE
attrNameSnakeCase: false


0 comments on commit 30f0563

Please sign in to comment.