-
kubernetes上的Spring Cloud Dataflow部署时出错
我正在开发Spring Cloud Dataflow Stream App。我能够使用Cloud Foundry中运行的船长来运行Spring云数据流服务器。 -
Spring Cloud Stream RabbitMQ随机失败并出现队列NOT_FOUND错误
我已经配置了RabbitMQ集群,并在RabbitMQ上通过这样的配置使用Spring Cloud Stream: <pre><code>if (this.assignment -
Spring Cloud Streams-Apache Kafka活页夹-Avro反序列化异常-使用者
将<code>@StreamListener</code>注释与Apache Kafka Binder + Spring Cloud Streams一起使用时,推荐的处理反序列化异常的 -
Spring Cloud Stream / Function:不使用Java Function / BiFunction的Kotlin lambdas
我有一个使用Spring Boot,<code>spring-cloud-function</code>和<code>spring-cloud-stream-binder-kafka-streams</code>编写的Kafka -
无法实例化[org.springframework.cloud.stream.binding.BindingService]:工厂方法“ bindingService”抛出异常
我正在尝试使用Spring Cloud Stream和Apache Kafka作为流绑定器的事件驱动架构。 Spring Boot版本:2.1.9发 -
从现有GCP pubsub订阅中消费
我正在尝试使用此仓库中托管的示例代码。 <a href="https://github.com/spring-cloud/spring-cloud-gcp/tree/master/spring-cl -
Spring Cloud Stream Kafka聚合使用自动装配bean的新实例
有没有办法在Kafka Streams聚合中使用Autowired bean的新实例? <pre><code>@EnableBinding(Processor.class) public class -
如何更改Spring Cloud Stream Kafka活页夹的目标?
我将Spring Cloud Stream 2.1.4与Spring Boot 2.1.10结合使用,试图将Kafka的本地实例作为目标。 这是到目前为止我 -
Sping Cloud Stream Kafka-以批处理模式使用消息,并作为单个已处理消息发送出去
我尝试为下一个Spring Cloud Stream版本准备我们的应用程序。 (当前使用3.0.0.RC1)。 使用Kafka活页夹。 -
spring-cloud-stream-binder-kafka-streams-在功能实现中阅读Avro消息
我正尝试使用来自已在Avro中序列化的主题的消息。该文档对此工作原理非常困惑。 <a href="https://cloud.spri -
春云流
Iv最近一直在与春季云流Rabbitmq生产商和消费者合作。是否有约定在何处创建队列? <code>Should the -
Spring Cloud Stream错误处理...错误
这并不是真正的问题,因为我找到了一种解决方法,但是它与文档冲突,所以我想共享和记录有关的信 -
Spring Cloud Stream Kafka KTable作为输入不起作用
Spring Cloud Stream Kafka,KTable作为输入不起作用 <strong> Sink.java </strong> <pre><code>public interface Event -
KafkaConsumer不轮询所有消息
我有一个类似于以下代码的代码: <pre><code>KafkaConsumer<Long, String> kafkaConsumer = new KafkaConsumer<> -
弹簧执行器中CustomEndpoint上的异常行为
我创建了一个自定义端点来获取绑定信息。但是网址与我预期的完全不同。 这是我的代码: <p -
springframework.cloud.stream.messaging软件包中的Sink是什么?
我正在运行的应用程序将在kafka流中充当消费者。我有通过春季的流配置的kafka消息传递。 如何从 -
Kafkalistener无服务器或功能正常
我们有一个Kafka侦听器,使用来自主题的消息。我们希望使该bean具有功能性,以便在繁重的工作中使用 -
在应用程序启动时何时安全通过Spring Cloud Stream发送消息?
我有一个Spring Boot应用程序,该应用程序的bean在启动时需要发送一条消息(使用Spring Cloud Stream)。 < -
用于多租户服务的Spring Cloud Stream
我正在配置Spring Cloud流以进行服务编排。为Tibco EMS创建了活页夹,但是由于资源限制,我们为不同的客 -
卡夫卡和具有多种消息类型的主题(Avro):消费者(由于在类路径上缺少类,{spring cloud spring失败了
<strong>主题包含两种类型的消息:PaymentStarted和PaymentCompleted。 与消费者有两种分离的微服务。 所以:Mic -
使用Spring Cloud streamng无法在Kafka Ktable中看到任何消息
我已经使用Spring Cloud流API编写了一个Kafka流应用程序,但无法在KTable中看到任何消息。我无法追踪问题。 -
发布到kafka时出现Spring Cloud Dataflow错误
我正在使用kafka粘合剂在春季Clodata流程上进行POC。在将有效负载推送到kafka时遇到错误。这在Rabbit MQ中可 -
SerializationFailedException:具有kpl-kcl-enabled的Spring Cloud Stream Kinesis绑定程序:true
我目前正在评估在一个新项目中使用春季云流运动学粘合剂的可能性,但是我遇到了一些问题。 -
在SCDF上下文中,Kafka消费者属性设置在哪里?
我试图通过修补<code>CommitFailedException</code>,<code>max.poll.interval.ms</code>和<code>session.timeout.ms</code>来解决<co -
发送时出现春季云数据流kafka活页夹错误-Magic v1不支持记录头
尝试在Kubernetes中获取Spring Cloud数据流流,并在Source尝试向Kafka发送消息时遇到以下错误。当我使用Rabbit M -
kafka流跳窗口聚合导致时间戳为零的多个窗口
Kafka Streams DSL窗口聚合导致多个窗口。 <pre><code>@StreamListener("input") public void process(KStream<S -
执行器检查活页夹失败
当我运行<a href="https://github.com/spring-cloud/spring-cloud-stream-samples/tree/master/kafka-streams-samples/kafka-streams-word-cou -
根据部分数据属性更新KTable
我正在尝试使用对象的部分数据更新KTable。 例如。用户对象是 <code>{"id":1, "name":"Joe", & -
目前是否可以在春季云流中将脉冲星交换为Kafka
我一直在尝试进行一些搜索(Google,Slack,Stack),但尚未找到答案。我们有一些使用<a href="https://spring.i -
Spring Cloud Data Flow将时间戳添加到文件名
我正在尝试将开箱即用的Source和Sink流应用程序与Spring Cloud数据流一起使用。我正在尝试将文件从一个文