kafka安裝Linux

❶ linux shell腳本監控kafka，如果掛了自動重啟

實現Kafka服務監控與自動重啟的Linux shell腳本如下所示。此腳本適用於定時檢查Kafka服務狀態，並在服務未運行時自動啟動服務。

腳本主要分為以下部分：

1. **定義變數**：腳本中定義了Kafka服務的安裝路徑（KAFKA_HOME）、日誌文件路徑（KAFKA_LOG）以及進程ID文件路徑（KAFKA_PID_FILE）。

2. **檢查Kafka服務**：`check_kafka`函數用於驗證進程ID文件是否存在且進程是否仍在運行。如果服務未運行，則執行啟動操作。

3. **啟動Kafka服務**：`start_kafka`函數使用`nohup`命令在後台啟動Kafka，同時將輸出重定向至日誌文件。啟動成功後，腳本會記錄進程ID。

4. **循環檢查**：在主循環中，腳本每隔10秒執行一次`check_kafka`函數，確保Kafka服務始終運行。

注意：此腳本作為示例，根據具體環境可能需進行適當調整。確保在安全的環境下運行，避免執行可能造成數據丟失或其他不可逆操作的命令。

通過上述腳本，可實現Kafka服務的自動化監控與故障恢復，確保服務連續性，提升系統穩定性。

❷ kafka框架在後端開發中如何使用

深入探討 Kafka 框架在後端開發中的應用與實踐

前言：在後端開發中，Kafka 框架作為高效、高可用的消息系統，被廣泛應用於大數據、實時處理、日誌收集等領域。本文將聚焦於在 php 環境下使用 Kafka，通過 PHP 擴展 RdKafka 來實現消息的生產與消費。

安裝：

1. 下載：獲取適合當前系統環境的 Kafka 擴展包。

2. 目錄結構：確保已安裝 librdkafka，對於 Linux，先安裝 librdkafka，然後安裝 php-rdkafka；對於 Windows，將 librdkafka.dll 和 librdkafka.pdb 放入 PHP 根目錄，php_rdkafka.dll 和 php_rdkafka.pdb 放入 PHP 的 ext 目錄。

3. 配置 php.ini：添加 extension=php_rdkafka.dll，重啟 PHP 以完成擴展安裝。

4. 測試：通過 phpinfo() 或 php-m 查看擴展是否成功載入，同時使用 get_declared_classes() 檢查預設函數。

使用：

1. 生產消息：通過 RdKafka 擴展構建生產者實例，配置相關參數後發送消息。

2. 消費消息：創建消費者實例，指定 topic 和 partition 進行消息消費。

附加問題：遇到 Kafka 服務停止時拋出的異常：ERROR Shutdown broker because all log dirs in /tmp/kafka-logs have failed。

解決方法：清理 kafka-logs 目錄下所有日誌文件，重新啟動 Kafka 服務，使用 kafka-server-start.bat 執行 ..\..\config\server.properties 文件。