我使用的是带有卡夫卡绑定的小枝云流。我有多个不同内容类型的消费者。是否有一种方法可以配置反序列化器的基础上？
浏览 0提问于2021-03-16得票数 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
浏览 20提问于2021-05-15得票数 2
例如，这会将Avro反序列化程序添加到我的应用程序中的所有使用者。我只想把它放在一个消费者身上 spring.cloud.stream.kafka.binder.consumerProperties.value.deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializerspring.cloud.stream.kafka.binder.scheduler-in-fr
浏览 13提问于2020-10-28得票数 0
回答已采纳
在遵循之后，我能够直接将主题中的数据消费到我的Java对象中。以下属性完成了所有的魔术 spring.json.value.default.type: com.xxxx.datamapper.domain.FormData
但是，现在我想在一个spring引导应用程序中运行两个流侦听器。为此，我需要为每个使用者绑定进行
浏览 13提问于2020-05-21得票数 0
我想在我的春季云流卡夫卡应用程序中为我的生产者设置acks=all属性。我试过这样做：和和
spring.cloud.stream.kafka.
浏览 1提问于2019-04-24得票数 1
假设我的通道是pcin，我理解我应该使用折叠属性spring.cloud.stream.kafka.streams.bindings.pcin.producer.valueSerde和spring.cloud.stream.kafka.streams.bindings.pcin.producer.keySerde=pcs
spring.cloud.stream.bindings.p
浏览 1提问于2018-04-18得票数 0
回答已采纳
在Spring Boot with Kafka中，我可以如下设置ConsumerFactory的属性： @EnableKafkapublic class KafkaConsumerConfigKafka Streams，我可以按如下方式在代码中设置属性： final Properties streamsConfigurati
浏览 25提问于2019-01-31得票数 1
1回答
我很难弄清楚如何测试使用Avro作为消息格式和(合流)模式注册表的应用程序。配置可以如下所示： application: cloud: schema-registry-client: kafka: binder:$IntegerS
浏览 0提问于2019-07-31得票数 1
回答已采纳
我正在使用spring cloud kafka绑定器将数据读取到KStream。在阅读其中一个主题的数据时，我需要从头开始阅读。添加我使用过的application.yaml：
spring.cloud.stream.bind
浏览 11提问于2018-05-04得票数 1
我正在尝试使用Spring Cloud Stream创建一个简单的功能bean，它处理来自KStream和GlobalKTable的消息，连接它们，聚合它们，并将结果输出到一个新的流中，但我在正确配置它所需的-0.consumer.key-serde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerde
spring.cloud.stream.kafka.<
浏览 82提问于2020-05-20得票数 1
回答已采纳
1回答
我试图为每个绑定设置valueSerde，但是只考虑默认的值。:spring.kafka.bootstrap-servers: 192.168.56.101:19092
spring.cloud.stream.kafka.streams.bindings.process-in-0.consumer.valueSerde: io.github.kprasad99.st
浏览 3提问于2020-12-03得票数 0
回答已采纳
我试图使用在Kafka流上运行交互式查询。我坚持从InteractiveQueryService检索密钥值存储。在我的代码上，甚至在示例代码上，我总是会遇到相同的错误：
代码来自示例类：
<e
浏览 18提问于2022-10-13得票数 0
回答已采纳
这是我的配置文件： brokers: localhost:9093
spring.cloud.stream.kafka.streams.binder.functions.processFoo.applicationId: foo-processors
浏览 4提问于2020-10-24得票数 1
回答已采纳
1回答
在春季云流卡夫卡绑定中，是否有一种方法来设置两个重连接尝试之间的重新连接频率或时间？
如果卡夫卡集群在应用程序运行时出现故障，它将继续尝试重新连接，CPU使用率将上升到100%。我可以在spring-cloud-stream-binder-kafka-core-3.0.6.RELEASE)，中看到一个属性recoveryInterval (recoveryInterval是KafkaConsumerPropertie
浏览 3提问于2022-04-01得票数 0
回答已采纳
我使用Kafka Streams Binder的Spring Cloud Stream应用程序有以下属性： windowStream-inanotherTimestampExtractor destination: hints destination: hints
spring<
浏览 13提问于2020-05-27得票数 0
回答已采纳
:504) at org.apache.kafka.streams.processor.internals.RecordDeserializer.deserialize(RecordDeserializer.javamapper.setRawMappedHeaders(rawMappedHeaders)
浏览 8提问于2021-04-12得票数 1
我正在尝试(单元)测试使用Kafka DSL的Spring Cloud Stream Kafka处理器，但收到以下错误"Connection to node -1 could not be established我尝试从开始(它可以工作)，并且我调整了应用程序以使用Kafka DSL，并且几乎保留了测试类的原样。EmbeddedKafka真的支持Kafka DSL吗？Spring Cloud Stream通
浏览 68提问于2018-06-01得票数 4
回答已采纳
1回答
=output spring.cloud.stream.bindings.output.contentType=application/jsonspring.cloud.stream
浏览 1提问于2018-11-15得票数 0
回答已采纳
这将在Kafka中使用属性key.subject.name.strategy和value.subject.name.strategy -> 来完成。在一位卡夫卡本地人的作品中： val props = Properties到目前为止，我已经在一位制片人中尝试过这个： application:
浏览 0提问于2019-04-24得票数 5
回答已采纳
我正在做一个POC来演示一些Spring Cloud Kafka功能。我使用的是带有SpringBoot 2.4.1的Java11。我的build.gradle具有以下库 implementation 'org.springframework.cloud:spring-cloud</em
浏览 0提问于2021-01-30得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
