1回答
: Kafka commitId : fa14705e51bd2ce52018-12-21 12:06:45.015 INFO 12184 --- [r[payments-bus]] o.a.camel.component.kafka.KafkaConsumer: Apache
浏览 9提问于2018-12-21得票数 1
回答已采纳
1回答
消息没有被消耗掉
、、、
我在Spring的application.properties文件中添加了以下配置和Camel实现，但是消息并没有被消耗。我错过任何配置了吗？有没有使用kafka协议和Camel从Azure事件中心实现消费者的指针？NAMESPACENAME.servicebus.windows.net:9093sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLogin
浏览 4提问于2021-10-11得票数 0
回答已采纳
我有一个Kafka集群(版本: 0.10.1.0)，有9个代理和10个分区。 我尝试使用camel kafka 2.14.3从java应用程序中消费消息。这是我的骆驼路线 <route id="ReadFromTopic"> <log message="
浏览 35提问于2020-06-15得票数 1
1回答
我有一个将Kafka流数据分发给MQTT主题的系统。阿帕奇骆驼路线看起来是这样的： <to uri="micrometer:timer:camel.proxy.kafka.mqtt.stream?groupInterval=100&level=INFO" />
浏览 4提问于2022-05-11得票数 0
回答已采纳
1回答
我在Spring应用程序中使用Camel。我需要的是在camel发送所有数据后正确关闭我的应用程序。基本上，camel必须读取一个文件，将其拆分成行，并将每行作为kafka消息发送。如何在camel完成发送所有消息后关闭我的应用程序？这是我的路线：public void configure() throws Exception{
// Kaf
浏览 0提问于2021-03-23得票数 1
我用了阿帕奇骆驼卡夫卡和弹簧靴我在apache camel Kafka组件上使用了默认配置。<dependency> <artifactId>camel-kafka-starte
浏览 3提问于2022-04-25得票数 0
我有一个Camel端点，它基本上是一个Kafka消费者，从主题中读取并将信息发送到数据库。它工作得很好，但是，我正在努力对它进行单元测试，因为我还不能模拟Kafka端点。有没有人可以帮我嘲笑骆驼路线上的卡夫卡消费者？ @Override from(kafka:eph?
浏览 31提问于2020-04-03得票数 1
回答已采纳
在我的骆驼Router.java，我有下一个路线 } .to("jms:topic:test.sink.topic");在骆驼pom.xml是春天启动，骆驼-卡夫卡-启动和骆驼-jms-启动依赖。(AsyncProcessorS
浏览 1提问于2020-09-18得票数 1
回答已采纳
正如问题How to manually control the offset commit with camel-kafka?中所问的，我希望使用camel-kafka手动提交偏移量。我的路线： .from(kafka:topic1).to(kafka:topic2)
.process(new问题是聚合器和kafka生产者是在独立的线程中工作的，kafka
浏览 23提问于2019-06-22得票数 0
我正在使用在camel DSL中配置的kafka消费者来监听Kafka主题。还有另一个安装了kafka的应用程序(服务器)，它正在生成有关此主题的数据。<camel:endpoint id='docInfo' uri='kafka:${camel.kafka_broker}?topic=${camel.kafka_topic}&zookeeperConnect=${
浏览 4提问于2016-05-10得票数 0
我的罐子里有一条骆驼路线 from("file:/app/billing/billingip/HOBSRating/data/mediation/voiceinclude=USAGE_VOICE.*.txt") .log("#########The Camel Headerbefore loading into <em
浏览 0提问于2017-10-20得票数 0
1回答
完整的路线定义： "&groupId=my_group" +
"&autoOffsetReset=earliest" +"&consumersCount={{
浏览 1提问于2016-10-04得票数 2
回答已采纳
我的目标是在rabbitmq交换队列和kafka主题之间建立一个连接器。我按照这个指南来设置连接器：https://camel.apache.org/camel-kafka-connector/latest/try-it-out-locally.html。我从源代码https://github.com/apache/camel-kafka-connector下载并安装了连接器，为camel<
浏览 11提问于2020-09-25得票数 1
回答已采纳
我没有看到如何使用camel-avro组件来产生和使用kafka avro消息的示例？目前我的骆驼路线是这样的。为了使用camel-kafka-avro consumer & producer来使用模式注册表和其他类似的道具，应该对其进行哪些更改。pc.setLocation("classpath:application.properties");
log.info("About to start route: KafkaServe
浏览 1提问于2019-03-16得票数 3
我正在尝试为我的Spring Boot with camel routes应用程序编写单元测试。我的路由生产者是一个Kafka端点，URI是在application.properties文件中定义的。我试图模拟这个Kafka生产者端点，但它没有解析URI值。@RunWith(SpringRunner.class)@MockEndpointsAndSkip("kafka:${kafka.servers}?模拟测试的问题(对不起，我是个新手)
下面是我想要使用Moc
浏览 10提问于2017-07-21得票数 0
回答已采纳
我正在创造一条这样的路线： <route id="ESP_01.Handle_Movement;version=3.1&maxReadRate=0&qualityOfService=AtLeastOnce" />
<to uri="micrometer:timer:
浏览 7提问于2021-01-07得票数 0
回答已采纳
4回答
这是我的路线构建器。在这里，我试图将数据从我的文件插入到topic.Later中，我正在传递我的main方法，并使用camel上下文运行它。我尝试了几个代码，但没有一个对我有帮助。我正在为阿帕奇kafka - Camel的POC工作。";
<groupId>org.apache
浏览 5提问于2017-12-18得票数 1
2回答
我用的是Camel 2.18.2和Kafka 0.10.1.1org.apache.kafka.common.errors.SerializationException:无法将类[B ]的值转换为value.serializer中指定的类org.apache.kafka.common.serialization.StringSerializerfromwimsConfiguration.getDirectUri(), wimsConfiguratio
浏览 4提问于2017-02-07得票数 1
回答已采纳
我有一个简单的骆驼路线，它消耗了卡夫卡的话题。做一些处理，然后写回另一个卡夫卡主题。 .routeId("FromKafka")
.log("@@@@@
浏览 12提问于2017-05-19得票数 0
1回答
我正在查看ActiveMQ (特别是)，并试图找出除了支持的协议(JMS、AMQP、MQTT、OpenWire)之外还有哪些集成/连接器可用。我特别感兴趣的是读和写来自
浏览 0提问于2018-10-31得票数 0
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
