我有一个Scs微服务，它使用来自一系列Kafka主题的消息，这些主题都共享相同的抽象类。
我注册了一个自定义的MessageConverter来反序列化使用这个抽象类的JSON消息。我想通过websocket将从Kafka收到的这些消息推送到我们的前端UI。一旦我为websocket broker添加了配置，Scs的MessageConv
浏览 20提问于2020-03-01得票数 0
我想用Confluent Schema Registry和Avro Schema演进测试Spring Cloud Stream，以便将其与我的应用程序集成。我发现Spring Cloud Stream不支持到Confluent Schema Registry的安全连接，而且实现仍然非常基础。因此，我决定将Confluent Schema Registry Client与Spring Kafka结合使用，用于模式注册部
浏览 29提问于2019-04-25得票数 1
1回答
试图使用以下public MessageConverter userMessageConverter() throws IOException { compile('org.springframework.cloud:spring-cloud-starter-stream-kafka')
浏览 1提问于2016-11-25得票数 1
回答已采纳
我使用的是spring 2.7.4和spring云依赖关系2021.0.4。我还没有在spring文档中找到任何在trustedTypes中添加BatchMessagingMessageConverter的解决方案。我用卡夫卡在批处理模式下读取消息。如果在使用者读取标题时插入自定义标头(我自己的类)，则返回一个DefaultKafkaHeaderMapper$NonTrustedHeaderType
浏览 6提问于2022-11-02得票数 0
回答已采纳
我正在使用Spring cloud stream (kafka)在生产者和消费者微服务之间交换消息。它与本地java序列化交换数据。根据Spring cloud文档，它支持JSON、AVRO序列化。spring cloud stream中有没有尝试过的protobuf序列化(消息转换器)？我写了这个MessageConverter
public class Pro
浏览 60提问于2017-12-27得票数 1
我们刚刚升级到Spring-Cloud-Stream的3.0.0版本，遇到了以下问题： 当像这样使用函数式样式时： public class EventProcessor {
consumer:
spring.cloud.stream.kafka.bindings.validate-in，使用者只
浏览 29提问于2019-12-17得票数 1
1回答
我有一个可供使用的自定义，但现在我们要转到，它使用另一个MessageConverter (org.springframework.messaging.converter.MessageConverter那么，是否有一种方法可以将Spring (org.springframework.amqp.support.converter.MessageConverter)转换为Stream (org.springframework.messa
浏览 2提问于2018-05-30得票数 1
回答已采纳
我有一个使用自定义QueueMessageHandlerFactory的SqsListener，它有一个消息转换器，可以在JSON和POJO之间来回切换。我知道JMS侦听器允许您将自定义ErrorHandler添加为工厂定义的一部分。有没有类似的方法来定义一个自定义的ErrorHandler来使用Spring的SqsListener来捕获这个异常并记录它？ 谢谢!(SimpleMessageList
浏览 16提问于2020-12-08得票数 1
回答已采纳
1回答
我正在为数据源-处理器-接收器的数据流模型寻找azure替代方案。我希望这三个实体是独立的微服务。我想使用消息传递作为这三者之间的纽带。基本上，源应用程序从另一个服务获取数据，并将其发送到处理器，而处理器应用程序对其进行操作，并向宿发送相关的通知/警报。我知道我可以使用rabbitmq进行消息传递，但我需要知道在azure - service bus主题和eventhub主题中哪个更好？我该如何使用它们？
浏览 2提问于2018-01-05得票数 0
我可以使用WebSocket接收器在中作为WebSocket源代码。这样，当我启动源时，客户端就可以向源发送消息，因为有一个websocket服务器在监听特定的端口。
浏览 5提问于2017-10-31得票数 0
自定义反/序列化程序，键是一个简单的字符串@StreamListener }
这在反序列化错误中失败，在调试之后，我看到原因是消息的内容类型标头被设置为application/json，因此它试图将消息反序列化为JSON。内容类型标头是如何设置的，我如何覆盖它？我不是以JSON的形式发送消息，而是像常规
浏览 0提问于2019-07-15得票数 1
回答已采纳
我有一个春季云流卡夫卡消费者服务，在那里确认是手动完成的。提供一个固定的消费群体。spring.cloud.stream.bindings.input.group=sampleconsumergroup
重置集和spring.cloud.stream.kafka.bindings.input.consumer.resetOffsets=true spring.cloud.stream</em
浏览 2提问于2019-03-06得票数 1
回答已采纳
2回答
但是在zipkin服务器中，只有Service3中的spans可用。Service4没有span显示。Marshal跨越Spring云流绑定器compile('org.springframework.cloud:spring-cloud-sleuth-stream') compile('org.springframework.cloud:spring-cloud-<em
浏览 9提问于2017-02-22得票数 0
系统信息
Spring Cloud Data Flow Cloud Foundry: v1.1.0.Relase Pivotal Cloud Foundry: v1.7.12 CF Client (Windows来自Spring Cloud Data Flow Server的日志在上显示了以下堆栈跟踪。description": "Feature Disabled: task_creation", "error_code&qu
浏览 0提问于2017-01-27得票数 1
1回答
如何使用使用主题中的最新记录？
、、、、
我有一个Kafka流处理器，它消耗三个主题，并试图在键上合并(加入操作)它们。成功加入后，它进行一些聚合，然后将结果推送到目标主题。应用程序第一次运行后，它将尝试使用来自这些主题的所有数据。其中两个主题使用类似查找表，这意味着我需要从一开始就使用所有数据。但其中一个主题是我的主题。所以我需要用最新的。但我的应用程序从一开始就消耗了卡夫卡的所有主题。因此，我想从一开始就学习两个主题和一个最新的主题。我
浏览 10提问于2022-02-05得票数 0
回答已采纳
当我部署"function“模块并创建一个简单的流http | customUpper | log时 我看到示例运行良好，并且能够像预期的那样看到日志输出。当我修改函数流app时，使用Spring Boot、2.2.4和Hoxton.SR1作为云流依赖项。我在日志中看不到任何输出。>
浏览 25提问于2020-03-26得票数 0
下面是Stream的定义以及我如何部署它 --spring.cloud.stream.bindings.input.consumer.headerMode=raw | log --spring.cloud.stream.bindings.input.consumer.headerMo
浏览 0提问于2016-09-16得票数 0
我有一个有两个分区的“主题”。topic-1input0具有相同的目的地“主题”和相同的组。我的理解是，由于它是一个相同的组，每个主题将自动分配一个分区。
是否可以将特定的分区分配给特定的消息通道？
浏览 6提问于2017-07-27得票数 3
回答已采纳
是一个简单的自定义转换器，如下所示： @SpringBootApplication@EnableConfigurationPropertiesSee https://stackoverflow.com/questions/59155689/could-not-decode-json-type-for-key-file-name-in-a-spring-cloud-data-flow-stream</e
浏览 13提问于2020-04-28得票数 0
回答已采纳
1回答
我需要将使用的无效消息发送到DLT中，但在单独的引导服务器中。我目前有这样的配置： spring.cloud.stream.binders.some-kafka-binder.type=kafka
spring.cloud.stream.binders.some-kafka-binder.environment.spring.cloud.stream</e
浏览 22提问于2021-10-18得票数 1
云服务器
ICP备案
对象存储
腾讯会议
云直播
腾讯云开发者
