Add raises_write_error option that does not try to reconnect

toyokazu / fluent-plugin-mqtt-io

Fluent plugin for MQTT Input/Output

Apache License 2.0

17 stars 12 forks source link

Add raises_write_error option that does not try to reconnect #7

Closed toshitanian closed 6 years ago

toshitanian commented 6 years ago

Added raises_write_error to the out plugin with that the plugin does not try to reconnect after failure of publishing. We need this option because fluentd's buffering option works only when out plugin's write option fails. With current reconnect mechanism, fluentd's buffer feature does not work.