我使用的是带有卡夫卡绑定的小枝云流。我有多个不同内容类型的消费者。是否有一种方法可以配置反序列化器的基础上？
浏览 0提问于2021-03-16得票数 0
回答已采纳
可以从流函数记录入站消息吗？有没有什么拦截器可以让我这么做？
浏览 12提问于2021-01-12得票数 0
我正在构建一个spring云微服务，它使用来自kafka主题的数据。在消费者中，我将主题绑定到一个KStream。传入消息不包含时间戳，因为kafka版本低于0.10。下面是我的配置：
org.apache.kafka.common.serialization.Serdes$StringSerde : cloud: stream: org.apache.kafka.common.serialization.Serde
浏览 1提问于2019-06-08得票数 0
1回答
我对Kafka Stream API非常陌生。我有一个这样的KStream： KStream<Long,String> joinStream = builder.stream(("output")); 带有记录数的KStream值如下所示：流将每1秒更新一次。我需要构建一个Rest API，它将根据值、利润和spotPrice进行计算。但我一直在努力获取最后一张唱片的价值。
浏览 20提问于2021-03-29得票数 1
我正在做一个POC来演示一些Spring Cloud Kafka功能。我使用的是带有SpringBoot 2.4.1的Java11。我的build.gradle具有以下库 implementation 'org.springframework.cloud:spring-cloud-str
浏览 0提问于2021-01-30得票数 0
我正在尝试使用Spring Cloud Stream创建一个简单的功能bean，它处理来自KStream和GlobalKTable的消息，连接它们，聚合它们，并将结果输出到一个新的流中，但我在正确配置它所需的spring.cloud.stream.bindings.joinAndAggregate-out-0.destination: aggregate-outputspring.clou
浏览 82提问于2020-05-20得票数 1
回答已采纳
我想在我的春季云流卡夫卡应用程序中为我的生产者设置acks=all属性。我试过这样做：和和
spring.cloud.stream</e
浏览 1提问于2019-04-24得票数 1
你好，我是测试弹簧云和卡夫卡流，并得到错误。:183) ~[spring-cloud-stream-3.0.3.RELEASE.jar:3.0.3.RELEASE]
at org.springframework.cloud.stream.binder.DefaultBinderFactory.getBinder(DefaultBinderFactory.java:134) ~[spring-cloud-stream-3.0.3
浏览 5提问于2020-03-25得票数 0
我是Spring Cloud和kafka stream的新手。我正在尝试使用kafka活页夹设置spring cloud应用程序。我尝试在本地测试kafka流处理器，但无法打印任何日志。我的kafka消息将包含JSONObject。= autonomousProcessor
spring.cloud.stream.bindings.autonom
浏览 37提问于2021-07-27得票数 0
回答已采纳
=myGroupspring.cloud.stream.kafka.streams
浏览 1提问于2019-06-07得票数 0
回答已采纳
我正在启动一个新的SB应用程序，它将充当Kafka的消费者，我开始使用Kafka流，但在启动该应用程序时，我得到了以下例外
$Proxy101不能转换为org.springframework.messaging.MessageChannel$Proxy101和org.springframework.messaging.MessageChannel处于加载程序‘app’的未命名模块中)，在org.springframework.cloud.stream.binder.AbstractMes
浏览 5提问于2021-04-06得票数 0
卡夫卡世界中Flux的特征是什么？这是另一种"KStream"，一种“耐久的反应流”吗？它的使用是否保证不滞后，或至少最小，因为背压？
浏览 4提问于2022-09-14得票数 0
回答已采纳
我使用Kafka Streams Binder的Spring Cloud Stream应用程序有以下属性： windowStream-inanotherTimestampExtractor destination: hints destination: hints
spring<
浏览 13提问于2020-05-27得票数 0
回答已采纳
我正在为spring kafka streams应用程序的定制而苦苦挣扎。我一直在尝试在我的KStreams中配置处理未捕获(运行时异常)。参考文档https://docs.spring.io/spring-cloud-stream-binder-kafka/docs/3.1.0/reference/html/spring-clo
浏览 65提问于2021-01-14得票数 0
如何在Spring cloud上添加状态存储 我总是收到这样的错误：“嵌套异常是无效的，无法启动流：；嵌套异常是无效的拓扑: StateStore myStore is org.apache.kafka.streams.errors.TopologyException: org.springframework.kafka.KafkaException”。group:"org.springframework.cloud", name:
浏览 13提问于2020-03-18得票数 0
回答已采纳
1回答
我们使用了带有函数的Kafka流。我们有一个典型的示例应用程序，它将用户单击的kstream与用户区域ktable连接起来。
浏览 11提问于2022-01-24得票数 0
回答已采纳
到目前为止，使用基于注释的配置，我在一个应用程序中混合了这两者，spring-cloud-stream-binder-kafka用于简单的消费/生产，spring-cloud-stream-binder-kafka-streams用于高级流处理。函数式模型似乎只被streams绑定器支持，如果我尝试混合这两种方法-基于简单使用的注解和用于流的函数式，<e
浏览 21提问于2019-10-16得票数 0
回答已采纳
}", key, value); */其中@ the (“requesti”)配置如下所示；spring.cloud.stream.kaf
浏览 2提问于2019-02-25得票数 0
回答已采纳
1回答
我遇到了使用KStream组件的Spring云流应用程序的问题。它是侦听一个输入，并在处理完消息后将消息定向到一个输出。
java.lang.RuntimeExcept
浏览 0提问于2018-02-13得票数 1
回答已采纳
我们让多个应用程序使用者收听相同的kafka主题，并且生产者在向主题发送消息时设置消息头，以便特定实例能够评估标头并处理消息。log.info("sydney order request received message is {}",message.getName());在SpringCloudStream3.0.0中，
浏览 11提问于2021-09-16得票数 5
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
