PricingLoginStart free
Advanced Spring Boot 4: Event-Driven Architecture (Kafka) · درس

التفويض باستخدام ACLs

نفّذ قوائم التحكم في الوصول (ACLs) على وسطاء Kafka لتحديد أذونات دقيقة للمنتجين والمستهلكين

الدرس 2 من 411 خطوة

التفويض باستخدام ACLs درس مجاني في Advanced Spring Boot 4: Event-Driven Architecture (Kafka) على CoddyKit. هذا هو الدرس 2 من أصل 4. يمكنك قراءة الدرس كاملاً أدناه مجاناً — ثم تمرن عليه مباشرة في المتصفح باستخدام محرر أكواد مدمج ومدرس ذكاء اصطناعي متاح 24/7. هذا الدرس جزء من مسار التعلم في Advanced Spring Boot 4: Event-Driven Architecture (Kafka)، وتقدمك يتزامن عبر الويب وتطبيق CoddyKit. تتضمن دورة Advanced Spring Boot 4: Event-Driven Architecture (Kafka) 4 دروس في المجموع.

بعض أجزاء هذا الدرس لم تُترجم بعد وتظهر باللغة الإنجليزية.

What are Kafka ACLs?

In our last lesson, we learned about authenticating with Kafka using SASL. But authentication just verifies who you are.

Authorization determines what you are allowed to do. This is where Access Control Lists (ACLs) come in.

Kafka ACLs provide fine-grained permissions, letting you control which users (or principals) can perform specific actions on Kafka resources.

The Core of Kafka Authorization

Authorization in Kafka revolves around three key concepts:

  • Principal: The authenticated user or client attempting an action (e.g., User:Alice, User:ProducerApp).
  • Operation: The action being attempted (e.g., READ, WRITE, CREATE, DELETE).
  • Resource: The Kafka entity the operation is performed on (e.g., a specific topic, a consumer group).

ACLs define which principals can perform which operations on which resources.

Different Types of Kafka Resources

Kafka allows you to set permissions on several types of resources:

  • Topic: For producing messages to or consuming from specific topics.
  • Group: For managing consumer group memberships and offset commits.
  • Cluster: For cluster-wide operations like describing brokers or creating topics.
  • TransactionalId: For using Kafka transactions.
  • DelegationToken: For managing delegation tokens (advanced).

Most common are Topic, Group, and Cluster resources.

ACL Syntax with `kafka-acls.sh`

ACLs are typically managed using the kafka-acls.sh command-line tool. You'll specify the principal, operation, and resource.

Here's a basic structure:

kafka-acls.sh --authorizer-properties ... \ --add --allow-principal 'User:Alice' \ --operation Read --topic 'my-topic'

This grants User:Alice permission to Read from my-topic.

ACLs for a Kafka Producer

A Kafka producer needs permissions to:

  • Write messages: To a specific topic.
  • Describe the cluster: To discover broker metadata.

Example commands to grant these permissions for a producer named User:ProducerApp on topic orders:

kafka-acls.sh --add --allow-principal 'User:ProducerApp' --operation Write --topic 'orders' --authorizer-properties ... kafka-acls.sh --add --allow-principal 'User:ProducerApp' --operation Describe --cluster --authorizer-properties ...

Spring Producer & ACLs

This Spring Boot producer sends a message to my-secured-topic. For it to work, the principal associated with this application (e.g., User:my-producer via SASL) must have the necessary ACLs configured on the Kafka broker.

Specifically, it needs WRITE permission on the topic and DESCRIBE permission on the cluster resource.

import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.context.annotation.Bean;

@SpringBootApplication
public class KafkaProducerAclApp {

    public static void main(String[] args) {
        SpringApplication.run(KafkaProducerAclApp.class, args);
    }

    @Bean
    public CommandLineRunner runner(KafkaTemplate<String, String> kafkaTemplate) {
        return args -> {
            String topic = "my-secured-topic";
            String message = "Hello from secured producer!";
            kafkaTemplate.send(topic, message);
            System.out.println("Sent message: '" + message + "' to topic: '" + topic + "'");
            System.out.println("Check Kafka broker logs for successful message receipt.");
        };
    }
}

ACLs for a Kafka Consumer

A Kafka consumer needs permissions to:

  • Read messages: From a specific topic.
  • Read from its consumer group: To manage offsets and join the group.
  • Describe the cluster: Like producers, for metadata.

Example commands for User:ConsumerApp on topic payments and group payment-processors:

kafka-acls.sh --add --allow-principal 'User:ConsumerApp' --operation Read --topic 'payments' --authorizer-properties ... kafka-acls.sh --add --allow-principal 'User:ConsumerApp' --operation Read --group 'payment-processors' --authorizer-properties ... kafka-acls.sh --add --allow-principal 'User:ConsumerApp' --operation Describe --cluster --authorizer-properties ...

Spring Consumer & ACLs

This Spring Boot consumer listens to my-secured-topic as part of my-secured-group. Its associated principal (e.g., User:my-consumer) needs specific ACLs.

It requires READ permission on the topic, READ permission on the consumer group, and DESCRIBE permission on the cluster resource.

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.kafka.annotation.KafkaListener;

@SpringBootApplication
public class KafkaConsumerAclApp {

    public static void main(String[] args) {
        SpringApplication.run(KafkaConsumerAclApp.class, args);
    }

    @KafkaListener(topics = "my-secured-topic", groupId = "my-secured-group")
    public void listen(String message) {
        System.out.println("Received secured message: " + message);
    }
}

Listing & Revoking ACLs

It's important to manage ACLs effectively. You can list all ACLs or specific ones:

kafka-acls.sh --list --topic 'my-topic' --authorizer-properties ...

To remove an ACL, use the --remove flag instead of --add, specifying the exact ACL you wish to revoke:

kafka-acls.sh --remove --allow-principal 'User:Alice' --operation Read --topic 'my-topic' --authorizer-properties ...

Regularly review and remove unnecessary permissions for security best practices.

ACLs Quick Check

Which of the following permissions are typically required for a Kafka consumer to successfully read messages from a topic and join a consumer group?

أجب عليها في الدرس التفاعلي

Recap: Securing with ACLs

Great job! You've learned how Kafka's authorization works using Access Control Lists (ACLs).

  • ACLs define who (principal) can do what (operation) on where (resource).
  • Key resources include topics, consumer groups, and the cluster itself.
  • You use kafka-acls.sh to manage these permissions on the broker.
  • Spring Boot Kafka applications implicitly rely on these ACLs being in place for their authenticated principals.

Next, we'll explore how to encrypt data in transit using SSL/TLS.

البدء مجانًا

تعلم Advanced Spring Boot 4: Event-Driven Architecture (Kafka) مع معلم ذكاء اصطناعي — مجانًا

اكتب وقم بتشغيل أكوادك الفعلية في المتصفح، واحصل على مساعدة فورية من معلم ذكاء اصطناعي متاح 24/7، واستمر من حيث توقفت على الويب أو في التطبيق.

الدورات
12
الدروس
48
ابدأ التعلم مجانًاعرض الدورة الكاملة

الأسئلة الشائعة

هل درس «التفويض باستخدام ACLs» مجاني؟

نعم — نص درس «التفويض باستخدام ACLs» كامل متاح مجاناً هنا على الويب. لتمرينه بشكل تفاعلي (محرر أكواد مدمج ومدرس ذكاء اصطناعي متاح 24/7) وفتح باقي دورة Advanced Spring Boot 4: Event-Driven Architecture (Kafka)، انتقل إلى CoddyKit PRO. تتضمن دورة Advanced Spring Boot 4: Event-Driven Architecture (Kafka) 4 دروس في المجموع.

ماذا ستتعلم في «التفويض باستخدام ACLs»؟

نفّذ قوائم التحكم في الوصول (ACLs) على وسطاء Kafka لتحديد أذونات دقيقة للمنتجين والمستهلكين تتمرن على Advanced Spring Boot 4: Event-Driven Architecture (Kafka) مع أكواد عملية تشغلها مباشرة في المتصفح، ومدرس ذكاء اصطناعي متاح 24/7 يجيب على أسئلتك أثناء عملك.

هل أحتاج إلى خبرة سابقة لأبدأ Advanced Spring Boot 4: Event-Driven Architecture (Kafka)؟

لا تُشترط خبرة سابقة. Advanced Spring Boot 4: Event-Driven Architecture (Kafka) على CoddyKit منظم للمبتدئين حتى المتقدمين، لذا يمكنك البدء من هنا أو من البداية والتقدم بسرعتك الخاصة. هذا هو الدرس 2 من أصل 4.

كم من الوقت يستغرق درس «التفويض باستخدام ACLs»؟

معظم دروس CoddyKit تستغرق حوالي 5–10 دقائق. كل منها موجز وتفاعلي، لذا تحرز تقدماً مستمراً وتستأنف من حيث توقفت عبر الويب والتطبيق.

هل يمكنني كتابة وتشغيل أكواد في درس Advanced Spring Boot 4: Event-Driven Architecture (Kafka) هذا؟

نعم. كل درس في Advanced Spring Boot 4: Event-Driven Architecture (Kafka) يتضمن محرر أكواد مدمج، لذا تكتب وتشغل أكواداً حقيقية مباشرة في متصفحك وتحصل على تعليقات فورية من الذكاء الاصطناعي — بدون إعداد محلي.

جميع الدروس في هذه الدورة

  1. المصادقة باستخدام SASL
  2. التفويض باستخدام ACLs
  3. التشفير باستخدام SSL/TLS
  4. تدقيق الوصول إلى Schema Registry وتأمينه
← العودة إلى Advanced Spring Boot 4: Event-Driven Architecture (Kafka)