我有一个Camel端点，它基本上是一个Kafka消费者，从主题中读取并将信息发送到数据库。它工作得很好，但是，我正在努力对它进行单元测试，因为我还不能模拟Kafka端点。有没有人可以帮我嘲笑骆驼路线上的卡夫卡消费者？ @Override from(kafka:eph?
浏览 31提问于2020-04-03得票数 1
回答已采纳
我正在使用在camel DSL中配置的kafka消费者来监听Kafka主题。还有另一个安装了kafka的应用程序(服务器)，它正在生成有关此主题的数据。<camel:endpoint id='docInfo' uri='kafka:${camel.kafka_broker}?=${camel.kafka_host}&consumerStreams=${<e
浏览 4提问于2016-05-10得票数 0
1回答
我开始一个骆驼-卡夫卡的消费者，在那里，它把所有的数据从主题和移动到一个hashmap。camel-Kafka的Jar版本为2.18.1。" /> </route>由: org.apache.camel.ResolveEndpointFailedException:引起的无法解析端点: kafka://
浏览 2提问于2017-05-17得票数 0
回答已采纳
我正在使用apache camel集成我的kafka消息。此外，我还使用JAVA DSL来使用来自kafka端点的消息。使用apache kafka API，它知道如何提交具有给定属性切换的消费者偏移量。kafk
浏览 9提问于2015-09-21得票数 5
Apache Camel Kafka Consumer提供名为"consumerStreams“和"consumersCount”的URI选项。需要了解差异和使用场景，以及如何适应多分区Kafka主题消息消费
浏览 11提问于2016-03-10得票数 8
我正在使用camel-spring-boot-starter运行一个kafka消费者应用程序。SpringBoot应用程序实现CommandLineRunner。以下属性是在我的应用程序中配置的。camel.springboot.main-run-controller=true 我试图在端口8080上公开springboot执行器指标，但在将端点公开为非web应用程序时，我面临着挑战。我如何为我的用例公开HTTP端点上的致动器“/metric
浏览 15提问于2021-06-22得票数 0
noop=true&idempotent=false</constant> <to uri="kafka:customer-interactions-issues-relationshipsbrokers=localhost:9092"/>该路由必须由以下用户使用：
<route id="1"><
浏览 0提问于2018-06-29得票数 0
4回答
我正在为阿帕奇kafka - Camel的POC工作。";
<groupId>org.apache.camel</groupId>
<artifactId>camel-kafkajava.lang.Null
浏览 5提问于2017-12-18得票数 1
:造成，端点上没有可用的消费者:direct://camel。我用的是JDK 1.8和Camel 2.25.2<route xmlns="http://camel.apache.org/schema/spring" customId="true
浏览 8提问于2021-07-15得票数 0
5回答
ESB应该如何打包/部署？
、、、、
我试图理解Apache Camel，它似乎是一个轻量级的ESB。如果我对Camel /ESB的理解是正确的，那么您可以将Camel Route视为节点和边的图形。每个节点都是路由上的一个端点(可以消费/产生消息)。每条边是两个不同端点(一个生产者和一个消费者)之间的路由。假设这是正确的，我有一个实际的问题:关于部署应用程序的ESB/Camel Route，最佳实践规定了什么？我想我是在问
浏览 2提问于2012-06-19得票数 9
回答已采纳
Service2有了activemq端点，我们需要调用该特定服务的方法。我得到了异常，如没有消费者可用于端点。我假设一旦Service1启动，它就不会获得需要使用@Produce注解activemq端点进行初始化的service2实例。异常：由: org.apache.camel.CamelExchangeException: Endpointdirect://ServiceB上没有可用的使用者引起。-- These routes are outbo
浏览 54提问于2010-12-14得票数 0
因此，需要获得由一个路由创建的所有端点： RouteBuilder route1 =.to("file:data/outbox") } context.addRoutes(route2);
浏览 2提问于2018-08-24得票数 2
回答已采纳
Me"
} 但是现在如何在或者，有没有一种方法可以从第一个路由开始测试并满足JMSReplyTo的要求，而实际上不需要运行EMS服务器？
浏览 57提问于2019-04-29得票数 0
回答已采纳
我正在测试使用Apache在Kafka (0.8.2.1)上发送消息的简单生产者。我在camel中使用java创建了端点。上发送消息。但是当运行程序时，我得到了以下错误--注意:动物园管理员和Kafka已经启动，可以使用kafka控制台生成/消费消息。(KafkaProducer.java:54)
at org.apache.camel.component.kafka.KafkaProducer.doStart(Ka
浏览 1提问于2015-07-07得票数 4
回答已采纳
我注意到越来越多的人在微服务架构中使用Apache Camel。例如在Openshift Container平台上。有人能在这方面给我点启发吗？我不能理解这件事。
浏览 2提问于2019-03-19得票数 2
我一直在尝试在java中创建端点，并在我的xml路由中引用这些端点，但没有成功。我可以用xml做到这一点：并在路由中引用端点： <from这是我的camelContext：
<camelContext xmlns="http://
浏览 4提问于2015-12-16得票数 1
1回答
我是Apache Kafka的新手，我希望创建一个小的微服务/程序(可能是用Java编写的)来使用来自Kafka的消息并解析它们来构建XML文件。我已经有消息出现在我的单个Kafka主题中(发布者是第三方应用程序)，但我需要实时解析它们(所以我认为某种bash脚本可能是不可能的)。
我也有很少的Java知识，但目前正在努力学习基础知识。我的工作和现有的知识只是围绕着将消息发送到Kafka中的应用程序-一个营销自动化解决方案-所以我不熟悉如何在事后处理Kafka消息。此外，如果需
浏览 0提问于2021-09-27得票数 0
场景：
{server1-file1} - camel route(Generic) - {server2-file1}{server1-file1} - <e
浏览 1提问于2016-05-05得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
