Hủy
Đối tác
Thông tin

Tất cả tài liệu

FPT Data Platform

FPT Integration
FPT Data Platform
FPT Security Platform
AI Infrastructure
FPT AI Factory
Billing
Support
Multi Cloud
FPT Database Engine
FPT Cloud Server
FPT DevSecOps Services
FPT Next-Gen Firewall
FPT Cloud Backup & DR
FPT Monitoring
FPT Security
FPT Container
FPT Network
FPT Storage
    2.19 Tạo connector source Kafka
    2.19 Tạo connector source Kafka
    Updated on 24 Jul 2025
    Print: Export: PDF

    Kết nối và ingest dữ liệu từ một hoặc nhiều Kafka topic của một Kafka cluster khác (có thể là nguồn ngoài hoặc hệ thống khác).

    Cho phép đồng bộ, chuyển tiếp dữ liệu giữa các cluster

    Trường hợp tạo connector, Type là source, Database là Kafka

    Pre-condition: Status CDC service Healthy

    Để tạo connector, người dùng thực hiện các bước sau:

    Bước 1: Tại thanh menu chọn Data Platform > chọn Workspace Management > chọn Workspace name

    Bước 2: Tại phần My services chọn CDC service

    Bước 3: Tại màn detail CDC service > Chọn tab Connectors > nhấn Create a connector

    create-connector

    Bước 4: Nhập các thông tin màn connector information:

    • Name (required): tên connector

      Chú ý: Tên connector có thể chứa các kí tự chữ cái thường a-z hoặc các kí tự số 0-9. Đặc biệt không dùng dấu cách có thể thay dấu cách bằng dấu “-”.

    • Type (required): chọn source

    • Database (required): chọn Kafka

    Hình ảnh

    Bước 5: Nhấn Next để chuyển qua màn Properties

    Có hai lựa chọn: From FPT Database Engine, Manual configuration

    • Trường hợp chọn Manual configuration

      Nhập và chọn các thông tin sau:

      • Cluster alias name: Tên alias đại diện cho Kafka cluster, chỉ gồm chữ cái, số, dấu “-”; sử dụng làm tiền tố cho tên topic khi replicate dữ liệu.

      • Bootstrap server endpoint: nhập địa chỉ Bootstrap server endpoint

      • Security protocol: chọn một trong các giao thức bảo mật sau:

      • SASL_PLAINTEXT: là cơ chế xác thực đơn giản thông qua Username và password

        • SASL Mechanism

        • SASL Username

        • SASL Password

      • SASL_SSL: cung cấp một lớp bảo mật toàn diện cho việc xác thực và mã hóa dữ liệu thông qua Username và password

        • SASL Mechanism1

        • SASL Username

        • SASL Password

      • PLAINTEXT: dữ liệu truyền qua mạng không được mã hóa, không khuyến khích sử dụng

      • SSL: là một giao thức bảo mật mạng được sử dụng để bảo vệ dữ liệu khi truyền qua mạng Internet

    Hình ảnh

    • Trường hợp chọn From FPT Database Engine

    Nhập và chọn các thông tin sau:

    • Database Name (required): chọn Database

      • Cluster alias name: Tên alias đại diện cho Kafka cluster, chỉ gồm chữ cái, số, dấu “-”; sử dụng làm tiền tố cho tên topic khi replicate dữ liệu.

      • Bootstrap server endpoint: nhập địa chỉ Bootstrap server endpoint

      • Security protocol: chọn một trong các giao thức bảo mật sau:

      • SASL_PLAINTEXT: là cơ chế xác thực đơn giản thông qua Username và password

        • SASL Mechanism

        • SASL Username

        • SASL Password

      • SASL_SSL: cung cấp một lớp bảo mật toàn diện cho việc xác thực và mã hóa dữ liệu thông qua Username và password

        • SASL Mechanism

        • SASL Username

        • SASL Password

      • PLAINTEXT: dữ liệu truyền qua mạng không được mã hóa, không khuyến khích sử dụng

      • SSL: là một giao thức bảo mật mạng được sử dụng để bảo vệ dữ liệu khi truyền qua mạng Internet

    Hình ảnh

    • Kafka topic

      Nhấn vào dấu ‘+’ để lấy thông tin topic

      Chú ý: giới hạn chỉ lấy tối đa 100 topic

    Nhấn Test Connection để kiểm tra kết nối từ Workspace tới Kafka Cluster

    Bước 6: Nhấn Next để chuyển qua màn Additional properties

    Nhập và chọn các thông tin sau:

    • Task:

      • Number of tasks: Nhập số lượng task cho connector. (Số này thường nhỏ hơn hoặc bằng số partition của Kafka topic.)

    • Replication:

    • Replication policy: Chọn policy khi replicate topic.

      • DefaultReplicationPolicy: Thêm prefix alias cluster nguồn vào tên topic replicate.

      VD: topic-name sẽ thành alias-name.topic-name

      • IdentityReplicationPolicy: Giữ nguyên tên topic.

      VD: topic-name sẽ thành topic-name

    • Replication factor: Nhập số bản sao cho mỗi partition Kafka topic.

      • Nhập -1 nếu muốn sử dụng replication factor mặc định của broker.

    Hình ảnh

    Bước 7: Nhấn Next để chuyển qua màn Review

    Hình ảnh

    Bước 8: Kiểm tra thông tin và nhấn nút Create để hoàn thành việc tạo connector.

    © 2025 FPT Cloud. Đã đăng ký Bản quyền.