fluent-plugin-druid-log

Fluentd plugin for Apache Druid.

plugins

format-druid-audit-log-1 (filter)

Filter plugin to reformat Druid audit log

Example:

<source>
  @type tail
  path /.../log/audit.log
  pos_file /.../audit_log.pos
  read_from_head true
  tag druid_audit_log

  <parse>
    @type regexp
    expression /^(?<timestamp>[^\t]+)\t(?<remote_addr>[^\t]*)\t{1,2}(?<query_result>[^\t]+)\t(?<raw_query>.*)$/
    time_key timestamp
    keep_time_key true
  </parse>
</source>

<filter druid_audit_log>
  @type format_druid_audit_log_1
</filter>

<match druid_audit_log>
  @type stdout
</match>

Installation

RubyGems

$ gem install fluent-plugin-druid-log

Bundler

Add following line to your Gemfile:

gem "fluent-plugin-druid-log"

And then execute:

$ bundle

Copyright

• Copyright(c) 2026- Thomas Tych