当前位置: 首页 > 知识库问答 >
问题:

春靴骆驼Kafka

司徒修能
2023-03-14

我有一个Spring Boot2.25.1应用程序,它使用Camel 2.25.1与camel-kafka,一切都正常工作…在我的Kafka消费者中,我需要添加该功能以按需暂停消费,因此我升级到camel 3.18.1,以便我可以使用可暂停功能。升级到3.18.1后,我收到错误FileNotes与类文件TimeoutAwareAggregationStategy.class.

当我打开camel-core 3.18.1 jar时,在come 2 . 25 . 1版本中可用的这个类并不存在。

请指教。

我期待从骆驼2.25.1升级到骆驼3.18.1更流畅。

共有1个答案

苏涛
2023-03-14

根据Camel 2.x到3的Camel升级指南,< code>camel-core是模块化的,被分解成多个jar文件。在升级指南中,他们提到了聚合策略许多变化。虽然我找不到名为< code > TimeoutAwareAggregationStategy 的< code>AggregationStrategy接口的直接实现,但我可以看到该类存在于2.25.4版的< code>camel-core中,而< code>AggregationStrategy接口在3.0版中被移到了< code>camel-api中。

我期待从骆驼2.25.1升级到骆驼3.18.1更流畅

通常,当将主要版本升级到较新的主要版本时,会有一些您必须考虑的重大更改。这些更改几乎总是包含在更改列表或升级指南中。

 类似资料:
  • 没有“org.apache.camel.CamelContext”类型的合格bean可用:应至少有一个合格的自带候选bean。 依赖项注释:{@org.SpringFramework.Beans.Factory.Annotation.AutoWired(required=true)}

  • 我一直在尝试为Spring引导Kafka骆驼Avro消费者寻找示例代码,但没有运气。我在以下URL找到了Spring Camel Kafka消费者和生产者示例: https://thysmichels.com/2015/09/04/apache-camel-kafka-spring-integration/ 我的具体问题是,一旦我的bean从Avro模式创建,并且我有了POJO类,我如何将上面的c

  • Java-Spring-骆驼 我想用服务列表发起骆驼路线。 想做下面的事情,但是< code>from方法似乎不是一个生产者。如何定义动态生产者?

  • 我有哪些选项可以将Kafka与Spring靴骆驼连接? 我正在运行ActiveMQ Artemis和Camel,以建立进出客户端的JMS/MQTT和REST路由。我想把Kafka添加到这个二重唱中,以流式传输/交换数据(视频音频、文件/文本)。 到目前为止,我下载了Kafka汇合平台(免费试用),我正在测试他们提供什么。在融合平台中,我看到有可能将连接器作为“插件”添加。我假设我可以添加Camel

  • 尝试将春豆添加到骆驼体属性中。类似于: 甚至先输入标题: 其中uiLimit为: 并且在标头和属性中仍然为空。 任何想法为什么注册表中的 bean 查找对 OSGI 不起作用?(单个捆绑包中的所有豆子/路由) PS:这在Route中运行良好:

  • 我想在我的Junit5单元测试中将值注入到带有@Value注释的私有字段。 我引用了这个,并使用了ReflectionTestUtils。setField通过注入值解决了我的问题,但在验证方法被调用的次数时失败。 MyClass(我的类别): 测试类: 运行上述测试时出错 我想kafkaTemplate.sendMessage();被调用一次,但被调用两次后添加反射TestUtils。 需要关于如