我一直在尝试为KafkaStreamsProcessor编写单元测试。logic });} aplication.yml spring: stream: streams: brokers:- ${
浏览 6提问于2020-10-09得票数 0
回答已采纳
在尝试了许多不同的设置和阅读了许多不同的指南之后，我仍然不知道如何为使用kafka-streams绑定器的Spring Cloud Stream处理器编写简单的单元测试。assertThat(output.receive().getPayload()).isEqualTo("HELLO".getBytes());
} 但是，尝试将函数签名更改为充分利用kafka-streamsjav
浏览 11提问于2020-09-28得票数 0
回答已采纳
例如，这会将Avro反序列化程序添加到我的应用程序中的所有使用者。我只想把它放在一个消费者身上 spring.cloud.stream.kafka.binder.consumerProperties.value.deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer如果我这样做，它就会起作用 spring.cloud.stream.bindings.sched
浏览 13提问于2020-10-28得票数 0
回答已采纳
假设我的通道是pcin，我理解我应该使用折叠属性spring.cloud.stream.kafka.streams.bindings.pcin.producer.valueSerde和spring.cloud.stream.kafka.streams.bindings.pcin.producer.keySerde=pcs
spring.cloud.stre
浏览 1提问于2018-04-18得票数 0
回答已采纳
我使用的是带有卡夫卡绑定的小枝云流。我有多个不同内容类型的消费者。是否有一种方法可以配置反序列化器的基础上？
浏览 0提问于2021-03-16得票数 0
回答已采纳
1回答
我很难弄清楚如何测试使用Avro作为消息格式和(合流)模式注册表的应用程序。配置可以如下所示： application: cloud: schema-registry-client: kafka:
浏览 0提问于2019-07-31得票数 1
回答已采纳
我试过这样做：和和
spring.cloud.stream.kafka.streams.bindings.<channe
浏览 1提问于2019-04-24得票数 1
1回答
我想使用Spring Cloud Stream来消费和处理Apache Kafka队列，并将它们写入MongoDB。我看到有一个选项可以使用这个库，这样函数将是反应性的，或者是命令性的。在大多数Spring项目中，命令式方式是默认的，但据我所知，在spring cloud stream中，反应式范例是默认的。 我想知道什么被认为是最“稳定”的api，例如，对于企业推荐使用什么？
浏览 21提问于2021-11-15得票数 0
回答已采纳
在使用连接到Kafka的Spring应用程序中，我尝试设置两个单独的流侦听器方法：
Exception in thread "test-d44cb424-7575:805)
at org.apache.
浏览 4提问于2018-10-15得票数 1
回答已采纳
=myGroupspring.cloud.stream.kafka.streams
浏览 1提问于2019-06-07得票数 0
回答已采纳
implement SpecificRecordUserRecordSerde extends SpecificAvroSerdespring.cloud.stream.bindings.input.destination: userTopicspring.
浏览 2提问于2018-04-16得票数 4
回答已采纳
$getQueryableStore$0(InteractiveQueryService.java:115) ~[spring-cloud-stream-binder-kafka-streams-3.2.5(InteractiveQueryService.java:88) ~[spring-cloud-stream-binder-kafka-streams-3.2.5.jar:3.2.5]
at(Intera
浏览 18提问于2022-10-13得票数 0
回答已采纳
这是关于升级生产中的现有代码库，这些代码库使用来自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不兼容。streams code}
现在，将kafka</e
浏览 20提问于2021-05-15得票数 2
我是新手阿帕奇Kafka，我已经创建了一个简单的Spring启动生产者和消费者项目，可以生产和消费正确的消息，但现在我想与Kafka流工作，但面临着困难找到一个简单的POC的Kafka流与Spring
浏览 60提问于2020-08-15得票数 0
回答已采纳
通道绑定-spring.cloud.stream.bindings.member.consumer.useNativeDecoding: truespring.cloud</
浏览 4提问于2019-01-12得票数 0
我正在使用spring cloud stream和使用confluent's schema registry的Aiven的模式注册表。Aiven的模式注册表使用密码保护。vanilla java的kafka驱动时，一切都很好，但是如果我使用Spring cloud stream，我不知道如何注入这两个参数。目前，我将"basic.auth.user.info&q
浏览 21提问于2019-04-16得票数 2
回答已采纳
我正在使用spring cloud kafka绑定器将数据读取到KStream。在阅读其中一个主题的数据时，我需要从头开始阅读。添加我使用过的application.yaml：
spring.cloud.stream.bindings.inputorg.apache.ka
浏览 11提问于2018-05-04得票数 1
我正在尝试使用Spring Cloud Stream创建一个简单的功能bean，它处理来自KStream和GlobalKTable的消息，连接它们，聚合它们，并将结果输出到一个新的流中，但我在正确配置它所需的spring.cloud.stream.bindings.joinAndAggregate-out-0.destination: aggregate-outputspring.cloud.stream<
浏览 82提问于2020-05-20得票数 1
回答已采纳
无法在Spring Cloud Stream Binder Kafka 3.x (functional style)中将自定义商店连接到我的Transformer，如here中的示例所示。: state store my-store added to topology 我已经在我的应用程序中使用了Spring Cloud Stream Binder Kafka的几乎所有功能，从我的单元测试来看我现在使用</e
浏览 31提问于2021-04-06得票数 0
回答已采纳
我尝试让Spring Cloud Stream使用Kafka Streams已经有一段时间了，我的项目使用嵌入式kafka来测试Kafka DSL，我使用作为测试实现的基础(它本身就是的测试用例)。当使用使用"Processor.class“& MessageChannel作为实现的"DemoApplicationTest.ExampleAppWorki
浏览 14提问于2019-11-03得票数 1
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
