从 activemq 主题获取消息时,logstash 输入速度非常慢

2023-12-26

我已经在logstash中配置了JMS输入来订阅JMS主题消息并将消息推送到弹性搜索。

input {

  jms {
      id => "my_first_jms"
      yaml_file => "D:\softwares\logstash-6.4.0\config\jms-amq.yml"
      yaml_section => "dev"
      use_jms_timestamp => true
      pub_sub => true
      destination => "mytopic"
#     threads => 50
    }
}

filter {
    json{
      source => "message"
    }

}

output {
    stdout { codec => json }

    elasticsearch {
      hosts => ['http://localhost:9401']
      index => "jmsindex"
  }
}

系统规格:

RAM: 16 GB
Type: 64 bit
Processor: Intel i5-4570T CPU @ 2.9 GHz

这非常慢。比如每 3-4 分钟 1 条消息。我应该如何调试以找出缺少的内容?

注意:在此之前,我在 java 中使用 @JMSListener 执行此操作,每秒可以轻松处理 200-300 条记录。


None

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

从 activemq 主题获取消息时,logstash 输入速度非常慢 的相关文章

随机推荐

  • 将 PreBuiltTransportClient 与 elasticsearch 5 结合使用

    我正在尝试按照官方 Elasticsearch 5 文档来设置传输客户端 https www elastic co guide en elasticsearch client java api 5 0 transport client ht
  • PHP 和 Composer,如何组合composer.json 文件

    有人可以解释一下我应该如何将 Composer 与 php ini 一起使用吗 我的文档根目录中有一个composer json文件 它下载我的项目的核心包 但是当我想添加另一个项目 例如在这里找到的google php sdk 时http
  • [13]:Array 的未定义方法“assign_attributes”

    我的应用程序设置为 当 Product sold 属性为 1 时 表示商品已售出 并且不会显示在商店视图中 我正在尝试获取它 以便当客户签出时 购买商品时会更新product sold 属性 以下是我的控制器中应将 Product sold
  • 如何使用CSS在图像上添加覆盖颜色

    如果我有这样的图像 img src inshot1 jpg width 100px height 100px 悬停时我希望该块被某种颜色覆盖 例如 当您将鼠标悬停在其上时 您会看到一块具有相同高度和宽度的红色块 那么基本上是叠加吗 您可以通
  • 单个应用程序二进制文件如何支持 64 位和 32 位应用程序

    我们可以看到苹果的公告here https developer apple com news 根据这个文档 我们可以提交相同的二进制文件 支持 32 位和 64 位 我找到了一个堆栈溢出答案here https stackoverflow
  • 输入字段问题 - 关闭窗口但保持 Python 运行 [重复]

    这个问题在这里已经有答案了 有点长的问题 我正在创建一个输入字段 在 skrx 的主要帮助下 该字段显示在定制屏幕上 我已经对其进行了编程 以便当我按 Enter 键时 屏幕应该自行关闭 目前这个 pygame display quit 感
  • 如何在 TensorFlow 中有效地分配给张量的切片

    我想为 TensorFlow 2 x 中的一个模型中的输入张量切片分配一些值 我正在使用 2 2 但准备接受 2 1 的解决方案 我想做的一个非工作模板是 import tensorflow as tf from tensorflow ke
  • 如何调试通过 Windows Scheduler 运行的 exe? [复制]

    这个问题在这里已经有答案了 我正在使用 Windows Scheduler 来运行我编写的 exe 当调度程序启动我的 exe 时 如何跳入调试会话 更新1 我曾想过执行 Thread Sleep 然后附加到进程 当我尝试时 它说调试器已经
  • 加载 php 模块时出错

    我在 etc php 7 0 cli php ini 中添加了curl模块 extension usr lib php5 20121212 curl so 但是当我重新启动 php 时 我会 php m 我收到此错误 curl Unable
  • 如何在maven2中进行ear build?

    我对maven2很陌生 直到昨天我才成功地从maven2构建了war 我的下一个目标是为 war 文件构建 Ear 文件 其中还包括一些 jar 文件 你能帮忙吗 我将非常感激 问候 咬伤85 的官方文档Maven EAR 插件 http
  • msdeploy 的 Manifest.xml 文件中的 runCommand 提供程序

    我试图通过使用清单文件中的 runCommand 提供程序 通过 msdeploy 将运行批处理脚本 更多 前提是我能弄清楚 作为部署过程的一部分 这就是我的清单文件的样子
  • 如何加速 R 中的“expand.grid()”?

    我正在尝试加快创建包含两个向量之间所有可能组合的表 我们可以从以下位置获取此功能base R当我们使用expand grid 然而 我想知道我们是否可以使用以下工具实现相同的结果 但速度更快 collapse 包裹 StackOverflo
  • 在 PHPUnit (CIUnit) 中使用 YAML 文件作为数据提供者

    我正在使用 PHP CodeIgniter 框架编写一个应用程序 我正在尝试使用 CI Unit 扩展名为 PHPUnit 来测试应用程序 为了测试模型 我尝试加载 PHPUnit 文档中定义的 YAML 数据提供程序 但收到错误 如果我伪
  • Android Studio 不显示按钮的属性

    我在 Android Studio 中打开了一个空白的 Android 应用程序 当我尝试编辑按钮时 属性不存在 我是 Android 开发新手 正在遵循显示如何更改按钮中的文本的指南 但属性菜单缺少指南中看到的选项 Using 安卓工作室
  • API网关集成中使用代理集成有什么用?

    我正在尝试在 API Gateway API 和 VPC 背后的资源之间进行集成 创建集成时 有一个选项可供选择 使用代理集成 即使我没有选中此复选框并部署 API 我也可以通过 NLB 使 API 网关连接到 VPC 中的目标资源 所以
  • 在 php 中执行条件时出现问题[已关闭]

    Closed 这个问题是无法重现或由拼写错误引起 help closed questions 目前不接受答案 press GET sell echo press OUTPUT IS SELL if press SELL header Loc
  • Android 共享首选项在删除文件后仍然可见

    我正在尝试使用共享首选项的应用程序 当我从中删除首选项文件时数据 data com your package name shared prefs mySharedPref xml手动使用 Android 监视器 应用程序仍然能够读取首选项值
  • DataGridView 级联/相关组合框列

    因此 我时常在 Winforms 的遗留应用程序中工作 并不总是熟悉绑定对象的最佳实践 基本上我有一个三部分集 其中有两个人 他们可能只有一种产品 但该产品可能会导致拥有不同的 SKU 集 有没有办法从第一个组合框的值触发组合框的事件和填充
  • Java EE 中的拦截器是什么?

    我正在尝试澄清关于 Java EE 中的拦截器的概念 我已经阅读了 Java EE 规范 但我对此有点困惑 请为我提供一些有用的链接或教程 以澄清我的概念 我们如何 何时 为何使用拦截器 拦截器用于实现业务逻辑中的横切关注点 例如日志记录
  • 从 activemq 主题获取消息时,logstash 输入速度非常慢

    我已经在logstash中配置了JMS输入来订阅JMS主题消息并将消息推送到弹性搜索 input jms id gt my first jms yaml file gt D softwares logstash 6 4 0 config j