When will it support amqp ? we got performance issue when use https.

[gaussye]

We collected large of logs through fluentd azure eventhub plugins, however the problem is that this plugin use https instead of amqp. Any plan to implement amqp?

[sputnik13]

We were also having performance issues until we switched to persistent connection and tweaked the output buffer settings, below is the output buffer setting we're using

<match **>
   @type azureeventhubs_buffered
   @id out_aeh_docker
   connection_string "#{ENV['FLUENT_EVENTHUB_CONNECTION_STRING']}"
   hub_name "#{ENV['FLUENT_EVENTHUB_HUB_NAME']}"
   include_tag true
   type https
   message_properties {"Type": "fluentd"}
   <buffer>
      total_limit_size "2GB"
      chunk_full_threshold "0.8"
      compress gzip
      flush_interval "5s"
      flush_thread_count "10"
   </buffer>
</match>

If this doesn't help you might also want to try https://github.com/sputnik13/fluent-plugin-azureeventhubs a try? You'd have to put it in your Gemfile as

gem "fluent-plugin-azureeventhubs", :git => 'https://github.com/sputnik13/fluent-plugin-azureeventhubs', :ref => 'persistent_connection'

[danmassie]

Using the persistent connection from @sputnik13 fork fixed it for me too.