![\"\"](\"https:\/\/adrianotanaka.com.br\/wp-content\/uploads\/2025\/10\/image.png\")
<\/figure>\n\n\n\nAp\u00f3s o cluster criado<\/h2>\n\n\n\n
Caso o seu cluster j\u00e1 esteja no ar e queira ativar as ACLs, o processo atualmente precisa ser feito via oci cli ou API, no nosso caso vamos usar o OCI CLI.<\/p>\n\n\n\n
Vamos pegar qual a configura\u00e7\u00e3o que est\u00e1 aplicada ao cluster<\/p>\n\n\n\n
oci kafka cluster get --kafka-cluster-id ocid1.kafkacluster.oc1.uk-london-1.xxxxx | grep config<\/code><\/pre>\n\n\n\nCom o OCID da configura\u00e7\u00e3o podemos pegar quais os par\u00e2metros atuais, isso \u00e9 importante pois o processo para atualizar a config faz um replace da configura\u00e7\u00e3o atual!<\/p>\n\n\n\n
oci kafka cluster-config get --kafka-cluster-config-id ocid1.kafkaclusterconfig.oc1.uk-london-1.xxxxx<\/code><\/pre>\n\n\n\nPara facilitar as coisas, vamos salvar os properties em um arquivo json e adicionar os par\u00e2metros que precisamos:<\/p>\n\n\n\n
{\n\"properties\": {\n\"allow.everyone.if.no.acl.found\": \"false\",<\/strong>\n\"auto.create.topics.enable\": \"true\",\n\"default.replication.factor\": \"1\",\n\"leader.imbalance.per.broker.percentage\": \"1\",\n\"min.insync.replicas\": \"1\",\n\"offsets.topic.replication.factor\": \"1\",\n\"transaction.state.log.min.isr\": \"1\",\n\"transaction.state.log.replication.factor\": \"1\",\n\"authorizer\":\"kafka.security.authorizer.AclAuthorizer\"<\/strong>\n}\n}<\/code><\/pre>\n\n\n\nE agora podemos fazer um update da configura\u00e7\u00e3o passando esse .json como parametro:<\/p>\n\n\n\n
oci kafka cluster-config update --kafka-cluster-config-id ocid1.kafkaclusterconfig.oc1.uk-london-1.xxxxx --latest-config file:\/\/params.json<\/code><\/pre>\n\n\n\nEsse comando vai gerar uma nova vers\u00e3o da configura\u00e7\u00e3o, veja no campo version-number.<\/p>\n\n\n\n
Agora podemos atualizar a configura\u00e7\u00e3o no cluster com o seguinte comando:<\/p>\n\n\n\n
oci kafka cluster update --kafka-cluster-id ocid1.kafkacluster.oc1.uk-london-1.xxxxxx --cluster-config-id ocid1.kafkaclusterconfig.oc1.uk-london-1.xxxxxxx --cluster-config-version XXX<\/code><\/pre>\n\n\n\nOnde o –cluster-config-version deve ser o version-number retornado pelo comando de update, aqui vai uma dica importante: Voc\u00ea pode reverter a configura\u00e7\u00e3o aplicada usando um version-number anterior.<\/p>\n\n\n\n
Com os parametros configurados j\u00e1 podemos criar as ACLs, aqui para facilitar estou usando um arquivo de configura\u00e7\u00e3o para meu superuser e outro para meu usu\u00e1rio comum. <\/p>\n\n\n\n
[opc@b-tnk config]$ cat consumer_super_user.properties\nsecurity.protocol=SASL_SSL\nsasl.mechanism=SCRAM-SHA-512\nsasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username=\"super-user-xxxx\" password=\"xxxxx\";\n\n\n[opc@b-tnk config]$ cat consumer_tanaka.properties\nsecurity.protocol=SASL_SSL\nsasl.mechanism=SCRAM-SHA-512\nsasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username=\"tanaka\" password=\"xxxxx\";\n\n<\/code><\/pre>\n\n\n\nPara criar um usu\u00e1rio no cluster voc\u00ea pode usar o seguinte comando, perceba que estou passando o properties do superuser:<\/p>\n\n\n\n
.\/kafka-configs.sh --bootstrap-server bootstrap-clstr-xxxx.kafka.uk-london-1.oci.oraclecloud.com:9092 \\\n--alter --add-config 'SCRAM-SHA-512=[iterations=8192,password=xxxx]' \\\n--entity-type users \\\n--entity-name tanaka \\\n--command-config ..\/config\/consumer_super_user.properties<\/code><\/pre>\n\n\n\nPodemos criar um t\u00f3pico de teste<\/p>\n\n\n\n
.\/kafka-topics.sh --bootstrap-server bootstrap-clstr-xxxxx.kafka.uk-london-1.oci.oraclecloud.com:9092 \\\n--command-config ..\/config\/consumer_super_user.properties \\\n--create --topic topico-tanaka2<\/code><\/pre>\n\n\n\nE uma ACL permitindo que o usu\u00e1rio tanaka possa escrever em t\u00f3picos que comecem com topico-tanaka:<\/p>\n\n\n\n
.\/kafka-acls.sh --bootstrap-server bootstrap-clstr-xxxxx.kafka.uk-london-1.oci.oraclecloud.com:9092 \\\n--command-config ..\/config\/consumer_super_user.properties \\\n--add \\\n--allow-principal User:tanaka \\\n--operation Write \\\n--topic topico-tanaka \\\n--resource-pattern-type prefixed<\/code><\/pre>\n\n\n\nE agora podemos validar que a ACL est\u00e1 funcionando, aqui como superuser eu consigo ver mais t\u00f3picos do que com o usu\u00e1rio normal:<\/p>\n\n\n\n
[opc@b-tnk bin]$ .\/kafka-topics.sh --bootstrap-server bootstrap-clstr-xxxxxx.kafka.uk-london-1.oci.oraclecloud.com:9092 --list\n--command-config ..\/config\/consumer_super_user.properties\nlogs-app\nteste<\/strong>\ntopico-tanaka\ntopico-tanaka1\ntopico-tanaka2<\/code><\/pre>\n\n\n\nE quando eu listo com o usu\u00e1rio tanaka:<\/p>\n\n\n\n
[opc@b-tnk bin]$ .\/kafka-topics.sh --bootstrap-server bootstrap-clstr-xxxxxxx.kafka.uk-london-1.oci.oraclecloud.com:9092 --list --command-config ..\/config\/consumer_tanaka.properties\ntopico-tanaka\ntopico-tanaka1\ntopico-tanaka2<\/code><\/pre>\n\n\n\nE com um terceiro usu\u00e1rio, com menos permiss\u00f5es(outras ACLs aplicadas):<\/p>\n\n\n\n
[opc@b-tnk bin]$ .\/kafka-topics.sh --bootstrap-server bootstrap-clstr-xxxxx.kafka.uk-london-1.oci.oraclecloud.com:9092 --list --command-config ..\/config\/consumer_user.properties\nlogs-app<\/code><\/pre>\n\n\n\n<\/p>\n\n\n\n