1回答
我需要访问spring云流kafka事务性重试中的重试尝试号，这样对于特定的异常，基于重试尝试号，我可以将结果发布到不同的主题。
浏览 3提问于2022-09-27得票数 1
回答已采纳
1回答
我正在编写一个使用Spring云流Kafka流绑定器的kafka流应用程序。 return kt;}
在这里，如果发
浏览 1提问于2020-06-07得票数 0
我已经编写了一个Spring云流消息生成器，它成功地将有效负载发布到我本地引导服务器上的主题。我想将有效负载发布到我在Confluent Cloud上创建的主题上。我需要进行哪些配置更改？下面是运行中的localhost的配置。spring: stream: output:
浏览 20提问于2020-12-23得票数 0
看看使用绑定(functional )的项目，我遇到了两种风格-- KStreams和反应性管道Flux<Message<T>>。它们作为一个想法有些重叠，但只是部分地重叠。卡夫卡世界中Flux的特征是什么？这是另一种"KStream"，一种“耐久的反应流”吗？它的使用是否保证不滞后，或至少最小，因为背压？
浏览 4提问于2022-09-14得票数 0
回答已采纳
目前，我有一个spring clound函数，它使用一个主题并发布到另一个主题。但是对于特定的情况，我需要将消息发布到另一个主题。主要需要从spring cloud function发布消息到多个主题。Exception e) {
// need to send message to anothe
浏览 15提问于2021-10-04得票数 0
回答已采纳
当将事件发布到kafka主题时，我会遇到以下异常我正在使用下面的spring云版本，没有在我的pom中为spring-cloud-stream-kafka-binder提供任何版本。<spring-cloud-stream.ver
浏览 0提问于2017-03-22得票数 0
回答已采纳
我有这样的情景。
有4个主题：处理主题、异常主题、重试主题和拒绝主题。我有一个使用Kstream的处理器的spring云流应用程序。此处理器从异常主题读取消息，并基于每个消息中可用的标志创建两个kstream分支，用于重试主题和拒绝主题。现在需要做的是，在r
浏览 2提问于2021-06-21得票数 0
我们让多个应用程序使用者收听相同的kafka主题，并且生产者在向主题发送消息时设置消息头，以便特定实例能够评估标头并处理消息。received message is {}",message.getName());在SpringCloudStream3.0.0中，@StreamListener被废弃了，我无法在函数中找到与条件属性等价的内容
浏览 11提问于2021-09-16得票数 5
2回答
我正在开发一个spring引导应用程序，这个依赖库仅用于消费数据并将数据推送到数据库。
卡夫卡( spring-cloud-stream-binder-kafka )或卡夫卡(spring)
浏览 9提问于2022-04-27得票数 -2
我正在使用camel-spring-boot-starter中的camel- kafka ，在spring引导项目中将一条消息从一个卡夫卡主题路由到另一个。在某些主题上，我当前的应用程序，它只使用、camel-kafka、和(没有弹簧云流)。
在骆驼中，我们使用urls提供..
浏览 2提问于2018-06-20得票数 0
1回答
我正在开发一个基于Kafka的spring云流的路由器(事件代理)应用程序，该应用程序位于功能范例中。应用程序从常量输入主题中消耗，映射和过滤消息，然后根据某些输入字段将其发送到某个主题(一次只有一条消息，而不是多个结果)。通过为输出消息设置spring.cloud.stream.sendto.destination头是最好的方法吗？如果是的话，
浏览 4提问于2021-12-30得票数 0
我正在尝试构建一个Spring应用程序，它使用来自一个Kafka主题的事件，对其进行一些处理(可能涉及对反应性db查找的操作)，并将它们发送到另一个kafka主题。目前，该应用程序为kafka使用了webflux和spring云数据流。
请有人建议使用好吗，还是应该使用其他方法来实现端到端的反应行为。尝试用Spring引导WebFlux，春季<e
浏览 7提问于2022-12-02得票数 0
1回答
我正在尝试使用spring应用程序中的kafka主题。我使用的是Spring云流和下面提到的版本下面是代码和配置spring(){ System.out.println(l
浏览 4提问于2021-11-29得票数 2
我正在寻找一个示例来创建一个使用spring云流kafka绑定器(没有Kafka流)的功能风格处理器，它可以从一个主题消耗一批n条消息，并将m条消息发布到另一个主题(m < n)。.build() } });但是，这会产生一个包
浏览 6提问于2021-05-25得票数 1
回答已采纳
我在spring-云流-schema- 1.2.0.RC1中缺少了AvroSchemaMessageConverter类。我想通过这个链接。时，我预期中的类是可用的但如下所示，它并不存在：可以指向我所缺少的依赖项，是我对春季云流的maven依赖项，将其发布到Kafka主题。dependency>
浏览 4提问于2017-04-03得票数 0
回答已采纳
在以下卡夫卡消费者代码中是否有一种使用@Header的方法？我使用的是 Stream (卡夫卡流绑定器实现)，在实现之后使用功能模型。String, Pojo>> process() {}@KafkaListener(topics = "${mytopicname}", clien
浏览 1提问于2021-06-25得票数 1
回答已采纳
在我们的项目中，我们使用spring-cloud-starter-stream-kafka来消费来自卡夫卡的消息，在添加了@ComponentScan for "org.springframework.cloud.stream.binder.kafkaorg.springframework.cloud.stream.test.binder.TestSupportBinder (org.springframework.cloud.stream.binder.kafka</
浏览 27提问于2022-05-18得票数 1
回答已采纳
=publishspring.cloud.stream.bindings.publish-out-0.destination=${category}-${spring.application.name}-${runtime-env}
当我通过streamBridge调用它时，我调用发布in-0绑定。streamBridge.send("publish-in-0", "kafka", ProducerPayload.builder().event(event).content(e
浏览 11提问于2022-09-15得票数 0
回答已采纳
在春季引导应用程序中，我正在使用spring云启动器-流- kafka和spring-云流罐子。
jar的版本是1.1.1.RELEASE，我们正在创建名为Test的生产者。对于同样的情况，下面是application.yml文件。，它是将“输出”创建为一个主题。对于卡夫卡，我使用的是wurstmeister/ kafka (标签0.9.0.1-1)图像
浏览 3提问于2017-11-14得票数 1
回答已采纳
我希望每5分钟消费一次来自kafka主题的消息，然后处理它，并使用spring云流将其发送到另一个主题。你知道该怎么做吗？
浏览 143提问于2020-07-02得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
