Masahiro Nakagawa

> To fix that we need manually execute something like chmod a+w /var/log/fluentd/data on the host then fluentd starts fine. > Is it possible to fix it somehow? What the...

Hmm... so ECS doesn't use `-u` option to change running user? https://github.com/fluent/fluentd-docker-image#change-running-user

Do you use `FLUENTD_UID` to set uid?

https://github.com/zendesk/ruby-kafka/blob/master/lib/kafka/partitioner.rb Here is an implementation of partitioner. I'm not sure why `rand` returns wrong distribution. One approach is specify partition_key or partition_key_key to use value based distribution.

Could you suggest good way for it?

Fluentd treats data as a binary by default. If you hit the encoding problem, one way is convert encoding by using record_modifier or something. https://docs.fluentd.org/quickstart/faq#i-got-encoding-error-inside-plugin-how-to-fix-it

fluent-plugin-mongo depends on bson gem and bson gem is C extension library. So you need to setup development environment to install it on Windows evironment.

I'm not familiar with recent MSYS2/MINGW relation. From previous issue, you can install related packages via pacman. https://github.com/fluent/fluent-plugin-mongo/issues/103

If this option is also available in `put` method, easy to support i: https://github.com/fluent/fluent-plugin-s3/blob/e6e65e14a4d930bb3cb80ab66974819e71acd544/lib/fluent/plugin/out_s3.rb#L291

Hmm. We seem to do same check in `Fluent::Logger::LoggerBase.open` like `Fluent::Logger.open`. ``` if !args.first.is_a?(Class) || !args.first.ancestors.include?(LoggerBase) args.unshift(self) end ```