spring-cloud-stream 相关问题

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

Spring Cloud Data Flow YARN：java.lang.NoSuchMethodError失败：javax.el.E xpressionFactory.newInstance（）Ljavax / el / ExpressionFactory;

我正在使用SPARK2-2.1.0.cloudera1-1.cdh5.7.0.p0.120904-el6.parcel和hadoop在docker cloudera容器中运行spring-cloud-dataflow-server-yarn-dist-1.2.0.RELEASE服务器-2.6.0-cdh5.11.1。我有 ...

spring-cloud-stream spring-cloud-dataflow

回答 1 投票 0

Spring Cloud Task - 从docker容器中的maven存储库启动任务

我学习Spring Cloud Task，编写简单的应用程序，分为3个服务。首先是一个TaskApplication，只有main（）并实现CommandLineRunner，第二个是...

spring docker spring-cloud-stream spring-cloud-task

回答 1 投票 0

Spring Cloud Stream Kafka Binder：“从状态IN_TRANSACTION到状态IN_TRANSACTION尝试无效转换”

我正在尝试使用Spring Cloud Streams + Kafka Binding在Apache Kafka上使用“一个交付”概念进行一些PoC。我安装了Apache Kafka“kafka_2.11-1.0.0”并定义了“transactionIdPrefix”......

apache-kafka spring-cloud-stream spring-kafka

回答 1 投票 0

消息生产者的春天云合同

我正在使用spring cloud contract for messages，如https://cloud.spring.io/spring-cloud-static/spring-cloud-contract/1.2.1.RELEASE/single/spring-cloud-contract.html#中所述。 ..

spring-cloud spring-cloud-stream spring-cloud-contract

回答 1 投票 0

如何配置Spring云流（kafka）以使用protobuf作为序列化

我使用Spring云流（kafka）在生产者和消费者微服务之间交换消息。它与本机java序列化交换数据。根据Spring云文档，它......

protocol-buffers spring-cloud-stream

回答 1 投票 1

@MessagingGateway，Spring Cloud Stream以及两者之间的错误处理

关于如何使用Spring Cloud Stream MessageChannels配置@MessagingGateway的答案？在@MessagingGateway处理错误的正确方法是什么？

spring-integration spring-cloud-stream

回答 1 投票 1

Spring云流粘合剂kafka不在Netty上运行

我想在Netty上使用Kafka Streams和Spring Webflux构建一个流引擎，以便通过HTTP提供持续的状态更改。如果我有编译我会注意到的（'org ....

spring-cloud-stream spring-webflux

回答 1 投票 1

如何使用弹簧云流和kafka活页夹确定一些消息的优先级

TLDR：我希望能够在同一主题中的其他人之前处理一些紧急消息。更多解释：我正在开发一个相当大的应用程序，使用许多弹簧微服务依赖...

spring-cloud-stream spring-kafka

回答 1 投票 0

需要关于aws S3的Spring Integration示例的示例代码作为inBound和apache kafka作为出站[关闭]

在Spring Integration上需要示例，将aws s3作为入站，将apache kafka作为出站。我想从aws s3读取数据并需要解析它们并将其生成为apache kafka主题

amazon-s3 apache-kafka spring-integration spring-cloud-stream

回答 1 投票 0

Spring Schema Registry Server和MySQL

我正在尝试运行Spring Cloud Schema Registry Server，如此处所述。我希望模式在重启之间保持不变，所以我想使用MySQL。但是我在申请期间遇到了以下错误......

java mysql spring-cloud spring-cloud-stream

回答 1 投票 0

我可以编写既不是源也不是接收器的应用程序？

我正在尝试使用Spring Cloud Data Flow服务器来管理我的所有应用程序。而且，我对春天的一切都是新手。我想编写一个从SFTP读取文件并将其写入S3的应用程序。 ......

spring-cloud spring-cloud-stream spring-cloud-dataflow

回答 1 投票 0

云代工厂中的应用程序级服务绑定，用于Spring启动应用程序

我需要使用不同微服务的mysql服务实例绑定我的spring启动应用程序（在PCF上运行）。我相信应用程序级服务绑定可以帮助我，但我......

mysql spring-boot spring-cloud-stream pcf

回答 1 投票 0

更改RabbitMQ Spring Cloud Stream Starter App的内容类型

RabbitMQ Source应用程序的Spring Cloud Stream Starter应用程序的文档列出了几种可能的内容类型，每种类型的输出有效负载的结果类型都不同。但是，它......

spring spring-cloud-stream spring-cloud-dataflow

回答 1 投票 1

在API调用上停止和启动订阅者

我一直试图停止并启动SubscribableChannel的订阅者，但似乎无法获取用于调用unsubscribe函数的MessageHandler。使用默认的自动装配...

spring-cloud-stream spring-kafka

回答 2 投票 0

Spring集成Kinesis - 找不到合适的实现

我正在运行这个示例 - Spring Cloud Stream Kinesis Sample by Spring云。我在Windows 7中的用户文件夹下的.aws文件夹中的凭据。启动应用程序时，我得到以下内容...

java spring spring-cloud amazon-kinesis spring-cloud-stream

回答 1 投票 0

Spring cloud - 输入与输出

从这个例子：@SpringBootApplication @EnableBinding（MyProcessor.class）public class MultipleOutputsServiceApplication {public static void main（String [] args）{SpringApplication.run（...

java spring spring-cloud spring-cloud-stream

回答 1 投票 0

通过在每次重启应用程序时创建新的使用者组来重置主题偏移

我有一个Kafka主题和一个在Spring Cloud应用程序中分配（必须）的消费者组的消费者。作为一项要求，在每次应用程序重启时我都需要开始阅读所有收到的消息......

apache-kafka spring-cloud-stream

回答 2 投票 0

spring cloud stream app starter文件源到Spring Batch Cloud Task

我有一个弹簧批量启动应用程序，它采用平面文件作为输入。我将应用程序转换为云任务并部署在spring本地数据流服务器中。接下来，我创建了一个以File Source开头的流...

spring-batch spring-cloud-stream spring-cloud-dataflow spring-cloud-task

回答 1 投票 1

Spring cloud config - 共享文件或他的位置

我有两个应用程序：一个spriig启动配置服务器，另一个是spring启动配置客户端客户端必须使用名为certificate.json的文件。我想将此文件存储在...中