我正在尝试在 Spring Boot 应用程序中设置 Kafka 生产者以将消息发送到特定主题。我收到 SerializationException。我已经检查了我的序列化器和消息的架构,但我无法弄清楚出了什么问题。有什么想法吗?
Zookeeper 没有成功。当服务器尝试启动时,在此过程中遇到错误。以下是问题的细分:
我尝试修改 Kafka 属性文件中的 log.dirs 配置。具体来说,我将目录路径从 /tmp/kafka-logs 更改为 /tmp1/kafka-logs 。
预期结果: 人们期望 Kafka 现在可能会将其日志文件存储在新目录 /tmp1/kafka-logs 中。通过删除旧的 tmp 和 tmp1 目录,我可能希望清理所有旧的日志数据。
############################## 日志基础知识 ################# ############
#log.dirs=/tmp/kafka-logs log.dirs=/var/log/kafka
这里我们需要一个kafka目录 你可以跑 sudo mkdir -p /var/log/kafka 进而 须藤 chmod 777 /var/log/kafka
ps:它最初指向的 tmp 文件夹是一个临时文件夹,所以不太稳定,您可能缺少权限或某些东西,并且您的 kafka 无法在那里创建日志。
从现在开始您无需更改文件夹
您在 /var/logs/ 位置创建了一个 kafka 文件夹,从现在起 kafka 将在那里存储日志
如果文件夹又满了怎么办? rm -rf /var/log/kafka/*