我正在尝试迁移到Spring Cloud Stream的新的函数式编程模型，取代下面这样的条件StreamListener注释 @StreamListener("app-input", conditionspring.cloud.function.definition=functionRouter
spring.cloud.stream.bindings.functionRouter</e
浏览 71提问于2021-05-06得票数 1
回答已采纳
1回答
我目前有这样的配置： spring.cloud.stream.binders.some-kafka-binder.type=kafka
浏览 22提问于2021-10-18得票数 1
我必须路由来自两个不同的kafka主题的事件，我不知道如何将功能路由器0绑定到两个不同的目的地。路由将通过向生产者端的每个消息添加一个spring.cloud.function.definition头来完成。假设我有
具有具有值topic1或consumerB值的spring.cloud.function.definit
浏览 1提问于2021-03-30得票数 0
回答已采纳
我有一个常规的java Function；我试图绑定它：
然而，这种方法
浏览 1提问于2019-11-29得票数 4
回答已采纳
2回答
在尝试使用一个@StreamListener中的多个主题时，我遇到了一个spring引导流的问题。根据春云流文档:确认到文档：
绑定中间件上通道的目标目的地(例如，RabbitMQ exchange或Kafka主题)。(KafkaTopicUtils.java:39) ~[spring-cloud-stream-binder-kafka-core-1.2.1.RELEASE.jar:1.2.1.RELEASE
浏览 4提问于2017-06-18得票数 5
回答已采纳
我从我的teammates.They得到了相同的问题，问我卡夫卡主题，春天云流频道和春天云流目的地之间的不同点是什么。我们试着在网上搜索，但找不到任何线索。
浏览 2提问于2019-02-14得票数 0
我希望有一个绑定，它连接到特定的队列/主题，并根据特定的头条目路由到正确的函数。spring: function: enabled: true function
浏览 0提问于2020-10-18得票数 0
我们有一个场景，我们希望在cluster#1上消费来自kafka主题的数据，但在cluster#2上创建KTable主题(重新分区和changelog)。通道绑定-spring.cloud.stream.bindings.member.consumer.useNativeDecoding: true
<e
浏览 4提问于2019-01-12得票数 0
我知道使用Kafka Connect，您可以创建连接器，将所有kafka消息汇聚到一个PUBSUB主题。我想知道我是否可以将Spring Cloud Stream绑定器与Spring Cloud Function结合使用，并将所有这些部署到Google Functions。根据我的理解，我可以将Spring Cloud Stream和Spring Clou
浏览 1提问于2020-09-08得票数 0
1回答
我正在写一个Spring Boot (2.1.4)应用程序，试图使用Spring Cloud Streams for Kafka。 我要做的是维护一个主题的传感器列表(“传感器”)。但是，我正在尝试使用Spring Stream绑定，即上面的代码被包装在 @Configurationclass StreamConfiguration$StringSer
浏览 29提问于2019-05-03得票数 1
我正在使用spring cloud kafka绑定器将数据读取到KStream。在阅读其中一个主题的数据时，我需要从头开始阅读。添加我使用过的application.yaml：
spring.cloud.stream.bindings.inpu
浏览 11提问于2018-05-04得票数 1
目的：
return value -> MessageBuilder.withPayload(value + "_payload").setHeader("spring.cloud.st
浏览 9提问于2022-02-14得票数 0
我有一个有两个分区的“主题”。topic-1input0具有相同的目的地“主题”和相同的组。我的理解是，由于它是一个相同的组，每个主题将自动分配一个分区。
是否可以将特定的分区分配给特定的消息通道？
浏览 6提问于2017-07-27得票数 3
回答已采纳
我使用Spring流与卡夫卡绑定。要禁用我提到的自动创建主题- 。但是，设置此属性似乎不起作用，而且框架会自动创建主题。以下是application.properties中的配置这是启动日志
2021-06
浏览 1提问于2021-06-25得票数 1
回答已采纳
是否可以在application.yml中仅为应用程序生成的主题启用spring.cloud.stream.kafka.streams.binder.auto-create-topics，而不是自动创建应用程序使用的主题我希望我的制作人只负责创建主题。我正在使用spring-cloud-stream和kafka-streams绑定器。 在更一般的意义上，这是创建kafka<
浏览 30提问于2020-11-24得票数 0
回答已采纳
然后，在一分钟的时间窗口内将事件聚合起来，并将其用于不同的主题。然后，我需要从主题中读取聚合事件，并将其写入不同的主题，同时将主题绑定到另一个kafka集群中的不同主题。environment: cloud: kafkaeg:
type: kafka
浏览 0提问于2019-05-17得票数 1
我正在尝试用Spring Cloud + Kafka Streams + Spring Boot2来创建一个尽可能简单的hello world。 我意识到我错过了基本的概念。基本上，我理解： 1-我需要定义一个出站流来向Kafka主题写入消息，并定义一个入站流来从Kafka主题读取消息 public interface LoansStreams {
StringCloud Stream<e
浏览 368提问于2019-04-27得票数 16
回答已采纳
1回答
我们有一个需求，当我们使用来自一个主题的消息时，会有一些充实发生，然后我们将消息发布到另一个主题。我还设置了以下事务属性
spring.cloud.stream.kafka.binder.transaction.transactionIdPrefix=TX-spring.cloud.stream.kafka.binder.transaction.producer.configuration.ack=allspring
浏览 3提问于2021-09-28得票数 0
我有一个使用Spring Cloud Stream Kafka的应用程序。对于用户定义的主题，我可以通过下面提到的配置从指定的主题中删除记录。但此配置不适用于DLQ主题。例如，在下面的配置中，我在绑定器级别配置了保留时间。因此，在绑定级别下定义的我的生产者主题(学生主题)配置正确，当主题日志超过指定的保留字节(300000000)时，我可以检查记录是否被删除。但是绑定</e
浏览 51提问于2021-03-12得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
