带有Avro的Spring Cloud Stream无法正确转换字符串消息

问题描述我遇到一个问题,源发送了一个GenericMessage[有效负载=xxxxx,...]而接收器接收的消息为10,120,120,120,120,120。此问题发生在我设置Avro消息转换器之后。如果我删除Avro消息转换器并使用StreamListener处理消息转换,

发布:2023-01-03 标签:spring-cloud-stream


如何知道所有消息是否在卡夫卡-春泉云流中被消费

问题描述我们正在有条件地触发Kafka消费者。如何知道该主题的所有消息是否都已被消费。推荐答案您可以使用ListenerContainerCustomizer@Bean在监听器容器上配置idleEventInterval,并使用@EventListener方法消费容器空闲事件。参

发布:2023-01-03 标签:spring-cloud-stream


基于APACHE-KAFKA-BINDER的春云流功能模型

问题描述这是question的续集。我可以把"普通"的阿帕奇卡夫卡活页夹和功能模型一起使用吗?到目前为止,使用基于注释的配置,我在一个应用程序中混合了spring-cloud-stream-binder-kafka和spring-cloud-stream-binder-kafka

发布:2023-01-03 标签:apache-kafkaspring-cloud-streamspring-cloud-stream-binder-kafka


Spring Cloud Stream:如何在新的Consumer<>函数编程模型中使用@Transaction

问题描述我有StreamListener,我想使用新的功能模型和Consumer<>替换它。遗憾的是,我不知道如何将@Transaction转换到新模式:@Transactional@StreamListener(PaymentChannels.PENDING_PAY

发布:2023-01-03 标签:spring-bootspring-cloud-streamspring-cloud-function


PolledProcessor在Spring云数据流上的问题

问题描述我正在使用PolledProcessor实现一个Spring云数据流处理器。我遵循了这里的示例https://spring.io/blog/2018/02/27/spring-cloud-stream-2-0-polled-consumers。以下是我的代码。我将一个带有

发布:2023-01-03 标签:spring-cloud-streamspring-cloud-dataflow


如何在Spring Cloud Stream中添加或调整文件供应商的配置

问题描述SpringCloudStream的文件-供应商依赖包括FileSupplierConfiguration,它配置一个文件消息源(来自Spring集成)。我需要定制这个@配置提供的FileReadingMessageSource,但我不确定最好的方法。它仅提供了控制其@B

发布:2023-01-03 标签:spring-cloud-stream


利用Spring Cloud数据流搭建异质系统场景下的数据交换

问题描述我有一个涉及用不同语言(Java、Python、C#等)编写的多个应用程序的用例,我想在这些应用程序之间创建几个流。下面给出了一个说明性的例子。我正在尝试通过一个编排层找到完成此任务的最佳方法,该编排层完成所有幕后工作,包括记账、部署、消息队列创建和绑定等。为此,我正在研

发布:2023-01-03 标签:spring-cloud-streamspring-cloud-dataflow


如何使用Spring Cloud Kafka Stream 3.1创建制片人

问题描述我知道如何使用命令式编程方法定义生产者,但我找不到如何使用函数式编程方法定义生产者。我读了关于这个的SpringCloudStreamBinder文档,但只找到了如何定义消费者,或者消费者和生产者(例如,从主题中获取信息,转换数据并发送到另一个主题)。所以,我不知道是否可

发布:2023-01-03 标签:javaspringapache-kafkaspring-cloud-stream


春云Kafka StreamsUncaughtExceptionHandler

问题描述我正在尝试将StreamsUncaughtExceptionHandler添加到我的Kafka流处理器中。该处理器是用Kafka函数编写的。我查看了suggestionprovidedbyArtemBilan以将StreamsUncaughtExceptionHandle

发布:2022-10-16 标签:javaapache-kafkaspring-kafkaapache-kafka-streamsspring-cloud-stream


当产生的消息是消费者没有引用的模型类型时,如何反序列化消费者中的消息?

问题描述我正在尝试反序列化从Conumers作用域之外的服务生成的消息。如果序列化/反序列化模型包不同,则Kafka模型不在受信任的包中。会出现错误所以我想我有两个选择。或者以json/字符串的形式生成消息,或者让消费者包含生产者库并使用相同的模型来反序列化消息。我想在消费者中反

发布:2022-10-16 标签:spring-kafkaspring-cloud-stream