Wonderful呀 2025-04-10 17:15 采纳率: 0%
浏览 38

pluemelog3.5.3 使用redis做队列,不消费

pluemelog 使用redis做队列,不消费

使用 plumelog的 3.5.3的版本收到数据不消费,服务端的“管理”菜单模块下面,能看到队列中的数量,但是没有存储到es中。
修改了很多参数没有解决掉。
更换到3.5版本解决。
3.5版本下载地址:
https://gitee.com/plumeorg/plumelog/releases/tag/v3.5

  • 写回答

4条回答 默认 最新

  • 阿里嘎多学长 2025-04-10 17:15
    关注

    阿里嘎多学长整理AIGC生成,因移动端显示问题导致当前答案未能完全显示,请使用PC端查看更加详细的解答过程

    问题解答

    您使用 PlumeLog 3.5.3 版本,使用 Redis 作为队列,不消费数据,但是数据并没有存储到 Elasticsearch 中。您已经尝试了多种参数修改,但是问题仍然存在。

    可能的解决方案:

    1. 检查 Redis 队列中的数据是否正确。您可以使用 Redis 命令 LRANGELLEN 来检查队列中的数据是否正确。
    2. 检查 PlumeLog 配置文件中的队列配置是否正确。确保队列的名称、Redis 服务器地址、端口号等配置正确。
    3. 检查 Elasticsearch 配置文件中的索引配置是否正确。确保索引的名称、类型、Mapping 等配置正确。
    4. 检查 PlumeLog 服务端的日志文件是否正确。您可以检查日志文件中的错误信息,了解可能的错误原因。
    5. 尝试使用 PlumeLog 的 debug 模式来 debug 问题。您可以在 PlumeLog 配置文件中添加 debug 参数,启用 debug 模式,然后检查日志文件中的错误信息。

    核心代码:

    // 检查 Redis 队列中的数据
    Redis redis = new Redis("localhost", 6379);
    List<String> data = redis.lrange("plumelog_queue", 0, -1);
    System.out.println(data);
    
    // 检查 PlumeLog 配置文件中的队列配置
    PlumeLogConfig config = new PlumeLogConfig();
    config.setQueueName("plumelog_queue");
    config.setRedisHost("localhost");
    config.setRedisPort(6379);
    // ...
    
    // 检查 Elasticsearch 配置文件中的索引配置
    ElasticsearchConfig esConfig = new ElasticsearchConfig();
    esConfig.setIndexName("plumelog_index");
    esConfig.setIndexType("doc");
    // ...
    

    希望这些解决方案能够帮助您解决问题。如果您需要更多帮助,请提供更多的日志信息和配置文件内容。

    评论

报告相同问题?

问题事件

  • 创建了问题 4月10日