6.4. 認可

前提条件

• ユーザーが作成され、Kafka リソースにアクセスするための適切な権限が付与されています。
• Streams for Apache Kafka が 各ホストにインストールされており、設定ファイルが使用可能である。
• Kafka ブローカーで 認可が有効 になっている。

手順

• --add オプションを指定して kafka-acls.sh を実行します。

  例:

• MyConsumerGroup コンシューマーグループを使用して、user1 および user2 の myTopic からの読み取りを許可します。

  opt/kafka/bin/kafka-acls.sh --bootstrap-server localhost:9092 --add --operation Read --topic myTopic --allow-principal User:user1 --allow-principal User:user2
  
  opt/kafka/bin/kafka-acls.sh --bootstrap-server localhost:9092 --add --operation Describe --topic myTopic --allow-principal User:user1 --allow-principal User:user2
  
  opt/kafka/bin/kafka-acls.sh --bootstrap-server localhost:9092 --add --operation Read --operation Describe --group MyConsumerGroup --allow-principal User:user1 --allow-principal User:user2

  Copy to Clipboard Toggle word wrap

• user1 が IP アドレスホスト 127.0.0.1 から myTopic を読むためのアクセスを拒否します。

  opt/kafka/bin/kafka-acls.sh --bootstrap-server localhost:9092 --add --operation Describe --operation Read --topic myTopic --group MyConsumerGroup --deny-principal User:user1 --deny-host 127.0.0.1

  Copy to Clipboard Toggle word wrap

• MyConsumerGroup で myTopic のコンシューマーとして user1 を追加します。

  opt/kafka/bin/kafka-acls.sh --bootstrap-server localhost:9092 --add --consumer --topic myTopic --group MyConsumerGroup --allow-principal User:user1

  Copy to Clipboard Toggle word wrap

前提条件

• ACL が追加 されている。

手順

• --list オプションを指定して kafka-acls.sh を実行します。

  以下に例を示します。

  opt/kafka/bin/kafka-acls.sh --bootstrap-server localhost:9092 --list --topic myTopic
  
  Current ACLs for resource `Topic:myTopic`:
  
  User:user1 has Allow permission for operations: Read from hosts: *
  User:user2 has Allow permission for operations: Read from hosts: *
  User:user2 has Deny permission for operations: Read from hosts: 127.0.0.1
  User:user1 has Allow permission for operations: Describe from hosts: *
  User:user2 has Allow permission for operations: Describe from hosts: *
  User:user2 has Deny permission for operations: Describe from hosts: 127.0.0.1

  Copy to Clipboard Toggle word wrap

前提条件

• ACL が追加 されている。

手順

• --remove オプションを指定して kafka-acls.sh を実行します。

  例:

• MyConsumerGroup コンシューマーグループを使用して、user1 および user2 の myTopic からの読み取りを許可する ACL を削除します。

  opt/kafka/bin/kafka-acls.sh --bootstrap-server localhost:9092 --remove --operation Read --topic myTopic --allow-principal User:user1 --allow-principal User:user2
  
  opt/kafka/bin/kafka-acls.sh --bootstrap-server localhost:9092 --remove --operation Describe --topic myTopic --allow-principal User:user1 --allow-principal User:user2
  
  opt/kafka/bin/kafka-acls.sh --bootstrap-server localhost:9092 --remove --operation Read --operation Describe --group MyConsumerGroup --allow-principal User:user1 --allow-principal User:user2

  Copy to Clipboard Toggle word wrap

• MyConsumerGroup で myTopic のコンシューマーとして user1 を追加する ACL を削除します。

  opt/kafka/bin/kafka-acls.sh --bootstrap-server localhost:9092 --remove --consumer --topic myTopic --group MyConsumerGroup --allow-principal User:user1

  Copy to Clipboard Toggle word wrap

• user1 が IP アドレスホスト 127.0.0.1 から myTopic を読むためのアクセスを拒否する ACL を削除します。

  opt/kafka/bin/kafka-acls.sh --bootstrap-server localhost:9092 --remove --operation Describe --operation Read --topic myTopic --group MyConsumerGroup --deny-principal User:user1 --deny-host 127.0.0.1

  Copy to Clipboard Toggle word wrap