Я пытаюсь настроить acl для Apache тем Кафки через Java. Я наткнулся на метод setAcl(), присутствующий в клиенте администратора Kafka. Но не уверен, как его использовать. У меня есть кластер Kafka, настроенный с 3 брокерами, и к нему применяется acl (на стороне сервера).
Мне нужно внедрить его в java на стороне клиента (у меня есть необходимые клиентские сертификаты). Обратите внимание, что мне нужна помощь с кодом java (не с помощью сценария оболочки)