我有一个流处理器,它处理从Kafka InputTopic到OutputTopic的消息。此外,我有多个租户将对他们进行这一处理。函数定义类似于:public class StreamProcessorConfig {
public Function<KStream<String现在为租户A配置流应用程序:
spring.cloud.function.definition: myfunctiondefiniti
在尝试了许多不同的设置和阅读了许多不同的指南之后,我仍然不知道如何为使用kafka-streams绑定器的SpringCloud Stream处理器编写简单的单元测试。从一个全新的存储库开始,按照概述的here设置,我能够编写基本的大写演示函数(在我的代码名为‘uppercaseSimple’中),如下所示: @Bean
public Function<S
这是关于升级生产中的现有代码库,这些代码库使用来自kafka-clients,kafka-streams,spring-kafka 2.4.0到2.6.x的窗口,并将spring-boot-starter-parent2.2.2.RELEASE升级到2.3.x,因为2.2与kafka-streams 2.6不兼容。streamsBuilder.build(); public Ka
我对Spring kafka Stream是个新手。我最近设置了一个项目,并尝试使用kafka stream API来发布AVRO。需求:需要解析一个复杂的Jsonobject,它可能有多个子jsons。解析Json并为每个子json发送AVRO消息。它也可以是一个或多个。 我知道如何使用kafka客户端API来做到这一点。当前stream类的代码如下: @Service@EnableBinding(StreamBindings.class)
public class StreamLis