Ranger Authorization–related configuration is necessary at the Fluentd end, or should the authorization be enforced on the Kafka end?

[anupg336]

What is a problem?

We need to use Ranger Authorization with the Fluentd Kafka output plugin, but I couldn’t find any details or configuration options for this in the Fluentd documentation.

Could anyone confirm if Ranger Authorization–related configuration is necessary at the Fluentd end, or should the authorization be enforced on the Kafka end?

Describe the configuration of Fluentd

No response

Describe the logs of Fluentd

No response

Environment

- Fluentd version: 1.16.6
- Package version: 5.0.5-1
- fluent-plugin-kafka version: 0.19.2
- ruby-kafka version: 1.5.0
- TD Agent version:
- Docker image (tag):
- Operating system:
- Kernel version:

[anupg336]

Could someone please share an update on this? It would be really helpful.