Как с официальными документами Kafka, так и с океаном блогов, которые произошли во время моих поездок, похоже, что я могу развернуть брокера Kafka, чей файл конфигурации server.properties
содержит:Использование списков ACL суперпользователя Kafka со стороны клиента
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
super.users=User:Bob;User:Alice
Это определяет два суперпользователя (Bob + Алиса), которые затем могут производить сообщения в и потребляющие сообщения от пользователя, тем моего брокера.
Но как я могу использовать этих пользователей с клиентской стороны? Если у меня есть клиент Java, который должен отправлять сообщения моему броузеру Kafka, как этот клиент «аутентифицирует» себя как «Боб» (или «Алиса» или любой другой суперпользователь)?
И где пароли суперпользователя определены/использованы?!?