Apache Kafka

Nhấp chuột phải trong cây ▸ Thêm ▸ Yêu cầu Kafka.

Cấu hình chung

Trường	Vai trò
URL	Danh sách các broker, ngăn cách bằng dấu phẩy: hote1:9092,hote2:9092 — toàn bộ chuỗi được Handlebars giải quyết trước khi bị cắt nhỏ
Định danh client	clientId được thông báo tới các broker
Topic	Topic, ở mọi chế độ
Chế độ	produce, consume hoặc browse

Xác thực

Trường	Giá trị
Cơ chế SASL	none, plain, scram-sha-256, scram-sha-512
Người dùng SASL / Mật khẩu SASL	Mật khẩu chấp nhận một giá trị kiểu Bí mật
TLS	Bật được độc lập — một broker dùng TLS mà không dùng SASL vẫn hoạt động với cơ chế none

Chế độ produce

Khóa, giá trị, header của bản ghi và, tùy chọn, phân vùng. Nếu không chỉ định phân vùng, bộ phân vùng mặc định của thư viện client sẽ được áp dụng. Phản hồi trả về metadata của bản ghi đã ghi: topic, phân vùng, offset.

Chế độ consume

Trường	Vai trò
Nhóm	groupId của consumer
Offset khởi đầu	earliest, latest hoặc specific
Offset cụ thể	Một chuỗi — offset của Kafka là số nguyên 64 bit
Phân vùng	Một bộ lọc ở phía client: việc gán phân vùng vẫn do nhóm thực hiện

Chế độ browse

Kiểm tra một phân vùng mà không cần nhóm consumer: Restorm lấy ra một số lượng thông điệp có giới hạn rồi ngắt kết nối. Ở chế độ này, phân vùng là bắt buộc.

Đây là công cụ phù hợp để xem trong một topic có gì mà không phải tạo nhóm hay dịch chuyển offset.

Trong một kịch bản

• Sản xuất Kafka — hành động đơn lẻ, trả về metadata của bản ghi;
• Tiêu thụ Kafka — đăng ký qua nhóm consumer và phát ra một sự kiện cho mỗi thông điệp;
• Đóng kết nối Kafka — dừng việc tiêu thụ.

Xem Kết nối và luồng.

Đoạn mã

Năm đích: JavaScript (kafkajs, ở chế độ sản xuất và tiêu thụ) và kcat (sản xuất, tiêu thụ, kiểm tra không cần nhóm).