Apache Kafka - Công cụ
Công cụ Kafka được đóng gói trong “org.apache.kafka.tools. *. Các công cụ được phân loại thành công cụ hệ thống và công cụ tái tạo.
Công cụ hệ thống
Các công cụ hệ thống có thể được chạy từ dòng lệnh bằng cách sử dụng tập lệnh lớp chạy. Cú pháp như sau:
bin/kafka-run-class.sh package.class - - optionsMột số công cụ hệ thống được đề cập dưới đây:
Kafka Migration Tool - Công cụ này được sử dụng để di chuyển một nhà môi giới từ phiên bản này sang phiên bản khác.
Mirror Maker - Công cụ này được sử dụng để cung cấp phản chiếu của một cụm Kafka này sang một cụm Kafka khác.
Consumer Offset Checker - Công cụ này hiển thị Nhóm người tiêu dùng, Chủ đề, Phân vùng, Off-set, logSize, Chủ sở hữu cho tập hợp Chủ đề và Nhóm người tiêu dùng được chỉ định.
Công cụ sao chép
Kafka replication là một công cụ thiết kế cấp cao. Mục đích của việc thêm công cụ sao chép là để có độ bền cao hơn và tính khả dụng cao hơn. Một số công cụ sao chép được đề cập dưới đây:
Create Topic Tool - Điều này tạo ra một chủ đề với số lượng phân vùng mặc định, hệ số nhân bản và sử dụng lược đồ mặc định của Kafka để thực hiện việc gán bản sao.
List Topic Tool- Công cụ này liệt kê thông tin cho một danh sách các chủ đề nhất định. Nếu không có chủ đề nào được cung cấp trong dòng lệnh, công cụ sẽ truy vấn Zookeeper để lấy tất cả các chủ đề và liệt kê thông tin cho chúng. Các trường mà công cụ hiển thị là tên chủ đề, phân vùng, thủ lĩnh, bản sao, isr.
Add Partition Tool- Tạo một chủ đề, số lượng phân vùng cho chủ đề phải được chỉ định. Sau này, có thể cần nhiều phân vùng hơn cho chủ đề, khi đó khối lượng của chủ đề sẽ tăng lên. Công cụ này giúp thêm nhiều phân vùng hơn cho một chủ đề cụ thể và cũng cho phép gán bản sao thủ công các phân vùng đã thêm.