Bắt đầu với Apache Kafka
Trước khi cài đặt Apache Kafka, bạn phải cài đặt Java và tài khoản người dùng có đặc quyền sudo. Hơn nữa, bạn nên có RAM từ 2GB trở lên để Kafka chạy đúng cách.
Các bước sau đây sẽ hướng dẫn bạn cách cài đặt Apache Kafka.
Cài đặt Java
Cần có Java để cài đặt Kafka. Kiểm tra xem Ubuntu của bạn có cài đặt Java hay không bằng cách kiểm tra phiên bản bằng lệnh sau:
$ java --phiên bản
Nếu Java chưa được cài đặt, hãy sử dụng các lệnh sau để cài đặt Java OpenJDK.
$ sudo đúng cách Tải về default-jdk
Tạo tài khoản người dùng
Với Java đã được cài đặt, hãy tạo một tài khoản người dùng không phải root. Chúng tôi cũng cần cung cấp cho nó một số đặc quyền sudo bằng cách thêm người dùng vào nhóm sudo bằng lệnh sau:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Đăng nhập vào tài khoản người dùng mới tạo.
Cài đặt Kafka
Bạn cần tải xuống Apache Kafka mới nhất từ trang tải xuống chính thức. Tải xuống các tệp nhị phân của nó bằng cách sử dụng wget lệnh như sau:
$ wget https: // Download.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Khi tệp nhị phân được tải xuống, hãy giải nén nó bằng cách sử dụng nhận lệnh và di chuyển thư mục đã giải nén vào / opt / kafka.
Tiếp theo, tạo tập lệnh systemd cho Người giữ vườn thú và Kafka các dịch vụ giúp bắt đầu và dừng các dịch vụ.
Sử dụng một trình soạn thảo mà bạn chọn để tạo các tập lệnh systemd và dán các nội dung sau. Bắt đầu với Zookeeper:
$ sudo nano / vân vân / systemd / hệ thống / Zookeeper.serviceDán những thứ sau:
[ Đơn vị ]Sự mô tả = Máy chủ Apache Zookeeper
Tài liệu = http: // Zookeeper.apache.org
Đòi hỏi = network.target remote-fs.target
Sau = network.target remote-fs.target
[ Dịch vụ ]
Loại hình = đơn giản
ExecStart = / opt / kafka / thùng rác / Zookeeper-server-start.sh / opt / kafka / cấu hình / Zookeeper.properties
ExecStop = / opt / kafka / thùng rác / Zookeeper-server-stop.sh
Khởi động lại = bất thường
[ Cài đặt ]
WantedBy = multi-user.target
Lưu các tập tin. Tạo tệp systemd cho Kafka và dán các nội dung sau:
Khi dán, hãy đảm bảo rằng bạn đặt đúng đường dẫn cho Java mà bạn đã cài đặt trong hệ thống của mình.
[ Đơn vị ]Sự mô tả = Máy chủ Apache Kafka
Tài liệu = http: // kafka.apache.org / document.html
Đòi hỏi = Zookeeper.service
[ Dịch vụ ]
Loại hình = đơn giản
Môi trường = 'JAVA_HOME = / usr / lib / jvm / java-11-openjdk-amd64'
ExecStart = / opt / kafka / thùng rác / kafka-server-start.sh / opt / kafka / cấu hình / server.properties
ExecStop = / opt / kafka / thùng rác / kafka-server-stop.sh
Khởi động lại = bất thường
[ Cài đặt ]
WantedBy = multi-user.target
Sau khi hoàn tất, hãy áp dụng các thay đổi bằng cách tải lại daemon systemd:
Tiếp theo, kích hoạt dịch vụ Zookeeper và khởi động nó bằng các lệnh sau:
$ sudo systemctl start Zookeepe < mạnh > r mạnh >
Bạn cũng cần làm như vậy đối với Kafka:
$ sudo systemctl start kafka
Khi bạn bắt đầu các dịch vụ, bạn có thể xác minh trạng thái của chúng trước khi chúng tôi tạo một chủ đề trong Kafka.
Điều tốt với Kafka là có nhiều tập lệnh mà bạn có thể sử dụng.
Hãy tạo một chủ đề mới có tên linuxhint1 sử dụng kafka-topics.sh script với một phân vùng và một bản sao. Sử dụng lệnh sau:
$ sudo -Trong linuxhint / opt / kafka / thùng rác / kafka-topics.sh --tạo ra --bootstrap-server localhost: 9092 - hệ số nhân bản 1 --partitions 1 --chủ đề linuxhint1 
Lưu ý rằng chủ đề của chúng tôi được tạo ra. Chúng ta có thể xem tin nhắn trước đó để xác minh điều đó.
Ngoài ra, bạn có thể liệt kê các chủ đề có sẵn bằng cách sử dụng -danh sách trong lệnh sau. Nó sẽ trả về chủ đề mà chúng tôi đã tạo: S
$ sudo -Trong linuxhint / opt / kafka / thùng rác / kafka-topics.sh --danh sách --bootstrap-server localhost: 9092 
Với chủ đề Kafka đang được tạo, bạn có thể bắt đầu ghi dữ liệu luồng trên Kafka-console-producer.sh và kiểm tra xem nó có phản ánh trong người tiêu dùng.sh.
Mở trình bao của bạn và truy cập chủ đề mà chúng tôi đã tạo bằng cách sử dụng producer.sh như được hiển thị trong hình sau:
$ sudo -Trong linuxhint / opt / kafka / thùng rác / kafka-console-producer.sh - danh sách môi giới localhost: 9092 --chủ đề linuxhint1 
Tiếp theo, mở một trình bao khác và truy cập chủ đề Kafka bằng cách sử dụng Consumer.sh.
Khi mở hai shell, bạn có thể nhắn tin trên bảng điều khiển của nhà sản xuất. Bất cứ điều gì bạn nhập đều được phản ánh trong bảng điều khiển dành cho người tiêu dùng xác nhận rằng Apache Kafka của chúng tôi đang hoạt động.
Sự kết luận
Với hướng dẫn này, bây giờ bạn có tất cả các bước mà bạn có thể làm theo để cài đặt Apache Kafka trong Ubuntu 22.04 của mình. Hy vọng rằng bạn đã quản lý để làm theo từng bước và cài đặt Apache Kafka của mình và tạo các chủ đề để điều hành sản xuất đơn giản của người tiêu dùng và nhà sản xuất. Bạn có thể thực hiện tương tự trong sản xuất lớn.