hhru/kafka-consumer-lag

kafka-consumer-lag

Return kafka lag in influxdb format

./kafka-consumer-lag --config config.yml

---
clusters:
  - name: main
    brokers:
      - localhost:9092
    auth:
      username: user
      password:
    checks:
      - group: test1
        topics:
          - test1

      - group: test2
        topics:
          - test2
  - name: old
    brokers:
      - localhost:9093
    auth:
    checks:
      - group: test2
        topics:
          - test2

kafka_lag,cluster=main,group=test1,topic=test1 lag=1323 1576214316

kafka_lag,cluster=old,group=test2,topic=test2 lag=214 1576214316