spring-cloud-stream 相关问题

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

Spring Cloud函数和Kafka

我正在努力了解如何测试使用Kafka Binder同时还使用Spring Cloud功能的应用程序。让我们使用这个非常简单的示例:@ ...

回答 1 投票 0

尝试部署SCDF流时,找不到容器错误

我首先按如下方式注册接收器:应用程序注册--name mysink-类型接收器--uri文件:///Users/swatikaushik/Downloads/kafkaStreamDemo/target/kafkaStreamDemo-0.0.1-SNAPSHOT.jar然后创建了一个...

回答 2 投票 0

全局状态存储目录重复

我有一个使用spring-cloud-stream-stream库的kafka流处理应用程序。该应用程序利用3个application.id值来收听3个主题。对于其中两个输入主题,在...

回答 1 投票 0

Spring Cloud Stream Kafka将无法连接

我正在使用此docker compose:版本:'2'服务:zookeeper:图片:confluentinc / cp-zookeeper:4.1.1主机名:zookeeper端口:-“ 32181:32181”环境:...

回答 1 投票 0

Spring Cloud Stream访问原始流

这是我的用例,用户使用websocket(带有订阅的GraphQl)订阅我的流,我需要返回org.reactivestreams.Publisher的实例(应该是我的kafka主题订阅)...

回答 1 投票 0

Spring Cloud Data Flow Grafana Prometheus未显示流数据

我在此网站上使用docker-compose启动Spring云数据流。 https://dataflow.spring.io/docs/installation/local/docker/我创建了3个应用程序,即Source,Processor和Sink。我跑了出口...

回答 1 投票 4

如何关闭/停止Spring Cloud流绑定的RabbitMQ队列

我想阻止用户使用springm流绑定创建队列,同时点击终结点/ prepare-for-shutdown。请在下面的配置中找到,在...

回答 1 投票 0

Spring云流-RabbitMQ配置

我正在使用Spring Cloud Stream Java学习RabbitMq。对mq配置有疑问。根据文档-spring.cloud.stream.bindings。> channelName> .destination = dest1我在下面使用...

回答 1 投票 0

无法解析我的Json对象,该对象在Spring Cloud流中通过绑定器接收

我对Json转换器有问题,当我尝试收听该对象并将其转换为Java对象时,我在Rabbitmq中使用弹簧云流发送了一个Json对象。这是我收到的地方...

回答 1 投票 0

当实施死信队列(DLQ)时,会引发通道错误

频道错误;协议方法:#method(reply-code = 406,reply-text = PRECONDITION_FAILED-虚拟主机'ecp-audit'中队列'ecpauditchannel.ecpqueue'的不等价arg'x-dead-letter-exchange':已接收...

回答 1 投票 0

spring-cloud-stream应用程序正在寻找不存在的org.springframework.integration.endpoint.Pausable

我基于一个官方示例尝试的一个简单的spring-boot应用程序由于一个奇怪的错误而失败了。 spring-cloud-stream中的某个类正在寻找org.springframework ....

回答 1 投票 0

如何通过YAML中的Spring Cloud Stream提供Kafka Streams属性?

我想将spring.kafka.streams。*移动到spring.cloud.stream下-这可能吗?我想到的流属性类似于消费者属性或生产者属性,但是不起作用。 ...

回答 1 投票 0

在Pivotal Cloud Foundry上运行的Spring Cloud Dataflow可以将文件写入内部服务器吗?

在过去的几个月中,我一直在尝试Spring Dataflow。我一直在使用Docker容器在自己的计算机上运行数据流。我有一些用例,要么抓住一个...

回答 1 投票 0

在kafka或使用者重启期间是否有任何配置可用于清除未提交的消息?

我有一个业务场景,当使用者或kafka重新启动时,使用者不应该使用主题中已提交/未提交的消息。我尝试应用auto.offset.reset:最新。但是它的...

回答 1 投票 0

时发生错误,从AMQP属性映射到MessageHeaders

虽然与RabbitMQ的消息通信被成功地消耗,但是,显示在日志以下警告。 **发生错误而映射从AMQP性质MessageHeaders ** ...

回答 1 投票 1

Spring cloud kafka流应用程序异常终止

我有简单的spring cloud kafka流应用程序。每当出现异常时,应用程序都会终止,而我无法覆盖此行为。期望的结果是增量补偿...

回答 1 投票 0

具有RabbitMQ集群配置属性的Spring Cloud Stream

我阅读了文档:https://docs.spring.io/spring-boot/docs/current/reference/html/appendix-application-properties.html#common-application-properties,但我不清楚如何这两个...

回答 1 投票 0

如果不满足条件,如何避免有条件@StreamListener的WARN日志?

使用StreamListener注释的条件,如果不满足此条件,DispatchingStreamListenerMessageHandler将记录带有文本的WARN消息:找不到与...相匹配的@StreamListener。]

回答 1 投票 0

单个微服务中可能有多个流吗?

单个微服务中可能有多个流吗?这是我的yaml。绑定:输入:目的地:topic1内容类型:application / * + avro输出:...

回答 1 投票 0

Spring cloud stream kafka活页夹连接到docker-compose kafka

我想使用春季云流kafka活页夹。我使用以下docker-compose文件启动了2个kafka代理和1个zookeeper。版本:'3'服务:kafka-0:图片:confluentinc / cp-kafka:5 ....

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.