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 文件。