spring-cloud-stream 相关问题

Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。

Spring Kafka，Spring Cloud Stream和Avro兼容性未知魔术字节

我在反序列化来自Kafka主题的消息时遇到问题。消息已使用spring-cloud-stream和Apache Avro进行了序列化。我正在使用Spring Kafka读取它们，并尝试反序列化...

java apache-kafka avro spring-cloud-stream confluent-schema-registry

回答 4 投票 3

春季云数据流流java.lang.OutOfMemoryError：Java堆空间

我在写我自己的春天云流处理器，它接受一个I D作为输入参数，下载相应的文件，并将其发送到输出。这些文件可以像800MB大。输出对象...

spring-cloud-stream spring-cloud-dataflow

回答 1 投票 0

获得DataFlowClientException春季云数据流

当我想给下面的命令外壳我收到以下错误。可否请您让我知道为什么我收到这个错误。我想执行下面的链接程序的Maven ...

spring-boot spring-cloud spring-cloud-stream spring-cloud-config spring-cloud-dataflow

回答 1 投票 0

春季云流：如何指定单个消息处理一组绑定？

春季云溪版本1.3.3我很好奇有关如何安装一个消息处理一组绑定？对于每个绑定，我有非常相同的逻辑：... @StreamListener（“TOPIC_1”）...

spring-integration spring-cloud-stream

回答 1 投票 0

春季云流卡夫卡 - 方法必须声明

我已经配置了带弹簧的云流弹簧启动的基于应用程序。我想在KStream工作，但我不断收到错误“java.lang.IllegalArgumentException异常：方法必须声明”。 ...

spring spring-boot spring-cloud-stream spring-kafka

回答 2 投票 2

休息或消息代理或用于整合内部部署和基于云泉启动应用程序的一些其他方法

我有2个春天启动应用程序内部部署柜员应用基于云从所有柜员应用柜员应用程序，如果离线工作（汇总数据多租户应用...

spring-boot spring-integration spring-cloud spring-cloud-stream

回答 1 投票 0

如何创建嵌入春季云流中的卡夫卡单元测试

对不起，这个问题太普通，但有人对如何与卡夫卡嵌入式执行生产者和消费者测试的一些教程或指南。我已经试了，但也有几个版本？

junit apache-kafka spring-cloud-stream spring-kafka

回答 1 投票 4

如何在Spring Cloud DataFlow中注册应用程序？

我从Spring Cloud DataFlow开始，我已经通过Docker Compose运行了一个实例，并通过示例应用成功创建了Streams。我自己编写了一个Source和Sink应用程序，但我不是...

java spring spring-cloud-stream spring-cloud-config spring-cloud-dataflow

回答 2 投票 0

如何从Spring云流中读取Kafka Message Key？

在这里输入代码我正在使用Spring云流来消费来自Kafka的消息。是否可以从代码中读取Kafka消息密钥？我有一个Kafka主题，通常有两种类型......

spring apache-kafka spring-cloud-stream

回答 1 投票 0

spring cloud stream和gcp pub sub，binder问题

我尝试使用GCP的Pub Sum作为活页夹在本地运行SCS应用程序。 K m mmkkkk。 Mmm org.sm.Mpringframework.cloudkki spring-cloud-gcp-starter-pubsub M这是configl @Configu @ ...

spring-cloud spring-cloud-stream

回答 1 投票 1

Kafka主题，Spring-cloud-stream频道和Spring-cloud-stream目的地之间的差异

劳驾!我从队友那里得到了同样的问题。他们问我Kafka话题，Spring云流频道和Spring Cloud流目的地有什么不同点。我们试着......

apache-kafka spring-cloud-stream spring-kafka

回答 1 投票 -1

Spring Cloud Kafka Stream无法创建Producer配置错误

我有两个带有Kafka-stream依赖项的Spring启动项目，它们在gradle和完全相同的配置中具有完全相同的依赖关系，但是启动时项目之一的日志错误如下...

spring-boot gradle kotlin spring-cloud-stream spring-kafka

回答 1 投票 6

Spring Cloud Stream和GCP pub sub作为活页夹卡住了

我尝试在这里运行示例https://github.com/spring-cloud/spring-cloud-gcp/tree/master/spring-cloud-gcp-samples/spring-cloud-gcp-pubsub-binder-sample我期待它在我的...上创建一个主题

spring-cloud-stream

回答 2 投票 1

Spring @StreamListener进程（KStream，？> stream）分区

我有一个在我的流处理器中有多个分区的主题我只想从一个分区流式传输，并且无法弄清楚如何配置这个spring.cloud.stream.kafka.streams ....

apache-kafka-streams spring-cloud-stream

回答 2 投票 0

当消费者瘫痪时，卡夫卡的消息会丢失

您好我正在使用spring cloud stream编写一个kafka消费者 - 生产者。在我的消费者中我将数据保存到数据库，如果数据库关闭，我将手动退出应用程序。之后......

spring-boot apache-kafka kafka-consumer-api spring-cloud-stream

回答 1 投票 0

Spring云流自定义绑定器未注册。如果使用@Configuration，则禁用kafka绑定器

我正在尝试制作一个自定义的Spring云流绑定器，但它不会注册自己：Binder实现：公共类DPSBinder实现Binder