fluent-plugin-kafka-status

Fluentd input plugin for kafka status.

plugins

in - kafka_status

Poll kafka cluster status.

configuration

Example:

<source>
  @type kafka_status
  tag kafka_status
</source>

Options are:

  • tag: Tag to emit events on
  • brokers: list of borkers :,...
  • connect_timeout: timeout for connecting to brokers
  • ssl_ca_cert: CA cert to use for SSL connection
  • ssl_client_cert: client cert for the SSL connection
  • ssl_client_cert_key: client key for the SSL connection
  • ssl_verify_hostname: verify certificate hostname
  • interval: interval between execution
  • timestamp_format: iso, epochmillis timestamp format (iso)
  • event_prefix: metric event prefix for extra dimension

output

Generated metrics are :

Installation

Manual install, by executing:

$ gem install fluent-plugin-kafka-status

Add to Gemfile with:

$ bundle add fluent-plugin-kafka-status

Compatibility

should work with:

  • ruby >= 2.4.0
  • ruby-kafka >= 1.3.0
  • Copyright(c) 2024- Thomas Tych
  • License
    • Apache License, Version 2.0