Kafka MM2 (MirrorMaker 2) là một công cụ dùng để đồng bộ dữ liệu giữa các cụm Kafka khác nhau (multi-cluster replication)
Trường hợp tạo Kafka MM2, Type là source
Pre-condition: Status CDC service healthy
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 Kafka MM2> nhấn Create a Kafka MM2
Bước 4: Nhập các thông tin màn Connector Information:
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 “-”.
Bước 5: Nhấn Next để chuyển qua màn Properties
Nhập các thông tin sau:
Kafka cluster information
Cluster alias name (required): nhập tên định danh của cluster
Bootstrap server endpoint (required): nhập địa chỉ kết nối Kafka
Security protocol (required): lựa chọn giao thức bảo vệ
SASL Mechanism (optional): tùy thuộc vào lựa chọn giao thức bảo vệ
Username (required): tên đăng nhập
Password (required): mật khẩu
Nhấn Test connection để kiểm tra kết nối từ Workspace tới Cluster đã nhập
Topics
Group
Bước 6: nhấn Next để chuyển qua màn Additional Properties
Nhập các thông tin sau:
Number of tasks: số lượng tác vụ tối đa có thể thực hiện song song
Replication policy: lựa chọn thêm
Replication factor: số lượng bản sao của mỗi topic sau khi replication
Offset lag max: độ trễ tối đa của offset giữ source và target
Bước 7: Nhấn Next để chuyển qua màn Review
Bước 8: Kiểm tra thông tin sau đó nhấn Create để hoàn thành việc tạo Kafka MM2 source
Để sửa Kafka MM2 source, 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 Kafka MM2 source > chọn Kafka MM2 name
Bước 4: Sửa thông tin Kafka MM2 source
Kafka Cluster Information
Tại màn chi tiết Kafka MM2, chọn biểu tượng ở mục Kafka Cluster Information.
Popup Update Database Info hiện ra, cho phép chỉnh:
Security protocol (required): lựa chọn giao thức bảo vệ
SASL Mechanism (optional): tùy thuộc vào lựa chọn giao thức bảo vệ
Username (required): tên đăng nhập
Password (required): mật khẩu
Nhấn Test connection để kiểm tra kết nối.
Nếu OK → nhấn Save để lưu.
Muốn thoát → nhấn Cancel.
Task
Tại màn chi tiết Kafka MM2, chọn biểu tượng ở mục Task.
Popup Update Number of Tasks hiện ra, cho phép chỉnh:
Number of tasks: số lượng tác vụ tối đa có thể thực hiện song song
Nếu OK → nhấn Save để lưu.
Muốn thoát → nhấn Cancel.
Replication
Tại màn chi tiết Kafka MM2, chọn biểu tượng ở mục Replication.
Popup Update Replication hiện ra, cho phép chỉnh:
Replication policy: lựa chọn thêm
Replication factor: số lượng bản sao của mỗi topic sau khi replication
Offset lag max: độ trễ tối đa của offset giữ source và target
Nếu OK → nhấn Save để lưu.
Muốn thoát → nhấn Cancel.
Để xóa Kafka MM2 source, 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 Kafka MM2 source > chọn Kafka MM2 name > chọn Action > chọn Delete
Bước 4: Hiển thị hôp thoại Delete Kafka MM2 > nhập Delete > nhấn Confirm để xóa Kafka MM2 source, chọn Cancel để hủy bỏ thao tác.