Shizuo Fujita
Shizuo Fujita
## ⚠️ Breaking Change in v1.19: default UID Changed Starting from version 1.19, the default UID (User ID) of the fluent user in the container image has been changed. This...
Can you add test cases?
Why do you use sso short-term credentials? Can you use instance profile credential? https://github.com/fluent/fluent-plugin-s3/blob/master/docs/credentials.md#instance_profile_credentials-section
Isn't the pattern of using the out_copy and out_forward plugins sufficient in this use case?
If the log data you sent contains a key named `partition`, it will be used as the destination partition number by default. ## Reproduce Create topic ```sh $ kafka-topics --create...
I assume this isn't intended for installing plugins in other locations. Can you let us your use case?
The concept of allowing users to manage installed plugins in a separate directory is interesting but likely challenging to implement. Fluent Package 5 uses Ruby 3.2. Fluent Package 6 uses...
> I just wanted to confirm that the hard coding of GEM_PATH in wrapper is intended or not. Because if that is intended, then it leaves us with no option...
I understand your point that we should be able to disable SSL during Kerberos authentication. However, based on my investigation, `in_kafka_group` (which depends on `ruby-kafka`) fails to authenticate with Kerberos...
hmm... The records processed by exec_filter seem to be being output. However, it took about 80 seconds for the first output, and I'm still unsure if it's correct behavior... *...