Хай. А помогите научиться в acl kafka. Я добавил группу /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server

Question

Хай. А помогите научиться в acl kafka. Я добавил группу /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server

dev-app-kafka11:9093 --topic pay-events-test --group pet-wh --consumer.config client.prop

нужному юзеру накинул прав
${KAFKA_DIR}/bin/kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --add --allow-principal "User: ${KAFKA_USER}" --consumer --topic "${KAFKA_TOPIC_NAME}" --group "${KAFKA_CONSUMER_GROUP}"

При подключении ловлю
# /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server dev-app-kafka11:9093 --topic pay-events-test --group pet-wh --consumer.config wh.prop
[2021-03-02 13:56:09,153] ERROR Error processing message, terminating consumer process: (kafka.tools.ConsoleConsumer$)
org.apache.kafka.common.errors.GroupAuthorizationException: Not authorized to access group: pet-wh

Первый день с кафкой. помогите отдебажить, что я упустил?

#devops #programming #russian

0

02.03.2021

4 ответов

25 просмотров

666admin

Вообще конеш сначала нужно документацию прочитать а потом городить ACLи https://docs.confluent.io/platform/current/kafka/authorization.html

0

02.03.2021

Viktor Автор вопроса

666admin
А права то какие ты дал? (—operation)

на группу или топик? # /opt/kafka/bin/kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --group pet-wh --add --allow-principal user:${KAFKA_USER} --operation ALL --resource-pattern-type prefixed

0

02.03.2021

Viktor Автор вопроса

666admin
Вообще конеш сначала нужно документацию прочитать ...

Внезапно, User: username и User:username генерит разные acl! Спасибо

0

02.03.2021

666admin · Accepted Answer

666admin

А права то какие ты дал? (—operation)

0

02.03.2021

172 похожих чатов

Хай. А помогите научиться в acl kafka. Я добавил группу /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server

4 ответов

Похожие вопросы