fluent.conf

<source>
  @type udp
  tag application.logs # required
  <parse>
    @type json
  </parse>
  port 24224   # optional. 5170 by default
  bind 0.0.0.0 # optional. 0.0.0.0 by default
  delimiter "\n" # optional. "\n" (newline) by default
</source>

<match *.*>
  @type copy
  <store>
    @type stdout
  </store>
  <store>
    @type elasticsearch_dynamic
    host elastic
    port 9200
    index_name fluentd.${record['ApplicationName']}.${record['level']}.${Time.parse(record['timestamp']).strftime('%Y%m%d')}
    #
    include_timestamp true
    verify_es_version_at_startup true
    reconnect_on_error true
    flush_interval 10s
    #with_transporter_log true
    default_elasticsearch_version 8
  </store>
</match>