an error in td-agent.log i don't understand related to elasticsearch plugin

[uken]

an error in td-agent.log i don't understand related to elasticsearch plugin

[ker2x]

  <source>
    type forward
  </source>

  ## Output to Amazon S3 with fluent-plugin-s3
  ## Match tag=snowplow.event and upload every hour
  <match snowplow.event>
    type copy
    <store>
    type s3

    aws_key_id secret
    aws_sec_key something
    s3_bucket something
    s3_endpoint s3.amazonaws.com
    path snowplow/
    buffer_path /var/log/td-agent/buffer/snowplow

    time_slice_format %Y%m%d-%H:%M:%S
    time_slice_wait 5m
    utc
    </store>
    <store>
    type elasticsearch
    host ec2-*-*-*-*.compute-1.amazonaws.com
    port 9200
    index_name fluentd
    type_name fluentd
    logstash_format true
    </store>
  </match>

[pitr]

it looks like you sent a string instead of hash to fluentD, something like

Fluent::Logger.post('my.key', "hello world")

as opposed to something like

Fluent::Logger.post('my.key', hello: "world", foo: "bar")

Not sure if sending a string to fluentD is even allowed, but this plugin requires that you send it a Hash object.

[ker2x]

Thank you for your help. that helped me to find a problem i had with SnowCannon, the json was "stringified"