Important

You are viewing documentation for an older version of Confluent Platform. For the latest, click here.

Role-Based Access Control Quick Start¶

Role-based access control (RBAC) is administered by a super user using the Confluent CLI and distributed across an organization. This quick start demonstrates how to create roles and interact with Kafka topics in an RBAC environment.

Log in to Cluster¶

Log in to the Confluent CLI with the RBAC Metadata Service (MDS) URL (<url>) specified. For more information, see confluent login.
```
confluent login --url <url>
```

Specify the super user credentials when prompted.

Enter your Confluent credentials:
Username:
Password:

Your output should resemble:

Logged in as user

Grant the SystemAdmin Role¶

The user you are creating role bindings for (my-user-name) must be created in LDAP before you can actually log in with this user to the system.

Grant the SystemAdmin role (SystemAdmin) to a user (<my-user-name>) on the Kafka cluster (<kafka-cluster-id>). For more information, see confluent iam rolebinding create.
Tip
- This user must also be created in LDAP before they can actually log in to the system, but this is not required for defining the role.
- You can find the cluster ID by running this command: ./bin/zookeeper-shell <host>:2181 get /cluster/id.
```
confluent iam rolebinding create \
--principal User:<my-user-name> \
--role SystemAdmin \
--kafka-cluster-id <kafka-cluster-id>
```

Grant SystemAdmin role for the Confluent Platform components to a user.

Tip

For more information about how to find the cluster ID, see Discover Identifiers for Clusters.

Confluent Control Center

confluent iam rolebinding create \
--principal User:<my-user-name> \
--role SystemAdmin \
--kafka-cluster-id <kafka-cluster-id>

Connect

confluent iam rolebinding create \
--principal User:<my-user-name> \
--role SystemAdmin \
--kafka-cluster-id <kafka-cluster-id> \
--connect-cluster-id <connect-cluster-id>

KSQL

confluent iam rolebinding create \
--principal User:<my-user-name> \
--role SystemAdmin \
--kafka-cluster-id <kafka-cluster-id> \
--ksql-cluster-id <ksql-cluster-id>

Schema Registry

confluent iam rolebinding create \
--principal User:<my-user-name> \
--role SystemAdmin \
--kafka-cluster-id <kafka-cluster-id> \
--schema-registry-cluster-id <schema-registry-cluster-id>

Grant the UserAdmin Role on the Kafka Cluster¶

The UserAdmin role grants the user permission to manage permissions for other users. This command grants UserAdmin to a user.

confluent iam rolebinding create \
--principal User:<my-user-name> \
--role UserAdmin \
--kafka-cluster-id <kafka-cluster-id>

Grant Topic Permissions¶

To interact with topics using the Kafka CLI tools, you must provide a JAAS configuration that enables Kafka CLI tools to authenticate with a broker. You can provide the JAAS configuration using a file (--command-config) or using the command line options --producer-property or --consumer-property for the producer or consumer. This configuration is required for creating topics, producing, consuming, and more. For example:

kafka-console-producer --producer-property sasl.mechanism=OAUTHBEARER

The value you specify in sasl.mechanism depends on your broker’s security configuration for the port. In this case, OAUTHBEARER is used because it is the default configuration in the automated RBAC demo. However, you can use any authentication mechanism, for example, you could have MDS handle authorization only.

To identify which roles provide write access to a topic, see Predefined roles.

Create a configuration file named my-user-name.properties, and specify the MDS service (<metadata_server_urls>), username (<my-user-name>), and password (<my-password>). You can also specify these same properties using the command line.

sasl.mechanism=OAUTHBEARER
# Use SASL_SSL for production environments
security.protocol=SASL_PLAINTEXT
sasl.login.callback.handler.class=io.confluent.kafka.clients.plugins.auth.token.TokenUserLoginCallbackHandler
sasl.jaas.config=org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required \
username="<my-user-name>" \
password="<my-password>" \
metadataServerUrls="<metadata_server_urls>";

Grant a user permissions to a topic (<topic-name>). For example, you can grant topic permissions to ResourceOwner or DeveloperManage roles on the resource level; or to the SystemAdmin role at the cluster level. To create a topic, the DeveloperManage role is required on the topic resource. Other roles that grant the ability to create topics are ResourceOwner on the topic resource, or SystemAdmin at the cluster level.
```
confluent iam rolebinding create \
--principal User:<my-user-name> \
--role ResourceOwner \
--resource Topic:test-topic- \
--prefix \
--kafka-cluster-id <kafka-cluster-id>
```

Create a topic using the Kafka kafka-topics tool with the my-user-name.properties specified.

<path-to-confluent>/kafka-topics \
--bootstrap-server <kafka-hostname>:9092 \
--command-config ~/my-user-name.properties \
--topic test-topic-1 \
--create \
--replication-factor 1 \
--partitions 3

Produce to a Topic¶

To produce to a topic, you must have (minimally) DeveloperWrite role for that topic. You are not required to be an owner of the topic to produce to it.

Grant the user permissions to access the topic. Use DeveloperWrite role on the topic resource.

confluent iam rolebinding create \
--principal User:<my-producer-user> \
--role DeveloperWrite \
--resource Topic:test-topic- \
--prefix \
--kafka-cluster-id <kafka-cluster-id>

Produce to a topic using the kafka-console-producer tool.

echo "test_message" | ./kafka-console-producer \
--broker-list <kafka-hostname>:9092 \
--topic test-topic-1 \
--producer.config ~/my-producer-user.properties \
--property parse.key=false

Consume from a Topic¶

To consume from a topic, you must have DeveloperRead access to the topic resource, and ResourceOwner on the consumer group prefix.

Grant permission to topic resource.

confluent iam rolebinding create \
--principal User:<my-consumer-user> \
--role DeveloperRead \
--resource Topic:test-topic- \
--prefix \
--kafka-cluster-id <kafka-cluster-id>

Grant permission to the consumer group.

To consume from a topic as a member of a consumer group, you must have access to the topic resource and consumer group resource. Grant either the DeveloperRead or ResourceOwner role to the topic resource and consumer group resource.
```
confluent iam rolebinding create \
--principal User:my-consumer-user \
--role DeveloperRead \
--resource Group:console-consumer- \
--prefix \
--kafka-cluster-id <kafka-cluster-id>
```

Consume using the kafka-console-consumer tool.

./kafka-console-consumer \
--bootstrap-server <kafka-hostname>:9092 \
--topic test-topic-1 \
--consumer.config ~/my-consumer-user.properties \
--from-beginning \
--property parse.key=false