<dependency> <artifactId>spring-cloud-stream-schema</artifactId> </dependency>
当我查看spring-cloud
浏览 4提问于2017-04-03得票数 0
回答已采纳
1回答
我正在使用和注册Avro模式。这是我的财产。spring.cloud.stream.schemaRegistryClient.endpoint= spring.cloud.stream.bindings.output.contentType=application/*+avro spring.cloud</
浏览 4提问于2017-08-22得票数 2
我想用Confluent Schema Registry和Avro Schema演进测试Spring Cloud Stream，以便将其与我的应用程序集成。我发现Spring Cloud Stream不支持到Confluent Schema Registry的安全连接，而且实现仍然非常基础。因此，我决定将Confluent Schema Registry Client与Spring Kafka结合使用，用于模式注册部分，并使用Spring</e
浏览 29提问于2019-04-25得票数 1
我正在使用spring云流并试图发布avro消息，但是得到了上述异常，spring.cloud.stream.bindings.feed-output-channel.producer.useNativeEncoding=truespring.cloud.
浏览 14提问于2022-01-21得票数 0
回答已采纳
1回答
: stream: output: input:Length is negative: -62
at org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessorStreamListenerMessageHandler.handleRequestMessage(St
浏览 20提问于2017-02-19得票数 0
这个问题发生在我设置了Avro消息转换器之后。如果我删除Avro消息转换器并使用StreamListener来处理消息转换，它将很好地工作。源application.propertiesspring.cloud.stream.bindings.toGreeting.contentType=application/*+<e
浏览 13提问于2017-06-28得票数 0
回答已采纳
=true
spring.cloud.stream.kafka.streams.bindings.input.consumer.keySerde=io.confluent.kafka.streams.serdes.avro.SpecificAvroSerdespring.cloud.stream.kafka.streams.bindings.input.consumer.valueSerde=io.confluent.kafka.streams.serdes.a
浏览 1提问于2019-06-07得票数 0
回答已采纳
static com.kstream.spring.cloud.test1.MyBinding.TOPIC1_IN;
spring.cloud.stream.bindings.topic1In.consumer.header-mode=raw
spring.cloud.stream.kafka.streams.bindings
浏览 0提问于2019-03-13得票数 4
回答已采纳
1回答
我很难弄清楚如何测试使用Avro作为消息格式和(合流)模式注册表的应用程序。配置可以如下所示： application: cloud: schema-registry-clientorg.apache.kafka.common.serialization.Serdes$IntegerSerde registry:
浏览 0提问于2019-07-31得票数 1
回答已采纳
我无法使用功能供应商发送Avro消息。SCSt尝试将消息作为JSON发送，但失败了。有人能指出是否需要任何额外的配置吗？setAcceleration(random.nextFloat()) .build(); cloud: endpoint: http://localhost:8990 <
浏览 16提问于2020-11-18得票数 0
回答已采纳
2回答
spring.cloud.stream.function.definition=streamBridgespring.cloud
浏览 0提问于2020-06-29得票数 2
回答已采纳
我试图用avro消息生产者、kafka和avro消费者构建一个使用spring引导、spring云流模式注册表和kafka绑定器的工作示例。o.s.c.s.b.k.KafkaMessageChannelBinder :无法使用contentType java.lang.NullPointerException反序列化io.igx.android.Sensor
我有消费者端的spring.cloud.stream.bindings.output.contentType=a
浏览 6提问于2017-03-09得票数 1
UserRecordSerde extends SpecificAvroSerdespring.cloud.stream.bindings.input.destination: userTopicspring.cloud.stream.kafka.streams.b
浏览 2提问于2018-04-16得票数 4
回答已采纳
我注意到如果我有在我的gradle文件中，spring boot如果我删除而不是从Netty开始。这是不是某种设计
浏览 8提问于2017-12-25得票数 1
回答已采纳
1回答
io.confluent:kafka-avro-serializer:7.1.1")
// https://mvnrepository.com/artifact/org.springframework.cloud&#
浏览 7提问于2022-09-06得票数 0
回答已采纳
我正在编写一个使用Avro消息的spring云流接收器应用程序。我试图让应用程序使用这些消息，但是我得到了以下错误。{ return "hello";}spring.cloud.stream.bindings.input.destination=user_topic
spring.cloud
浏览 1提问于2018-09-19得票数 1
我正在Spring Cloud Dataflow上实现一个流应用程序。我想使用基于Avro的模式注册表客户端进行序列化和模式控制。</groupId> <version>1.1.1.RELEASE</version>
</dependency
浏览 2提问于2017-02-13得票数 2
回答已采纳
我有一个数据流作业，它将avro消息写入PubSub：然后，我想处理Spring应用程序中的消息一般来说，我使用的是org.springframework.cloud.spring-cloud-gcp-starter-pubsub和org.springframework.cloud.spring-cloud-stream-sche
浏览 0提问于2018-05-11得票数 0
2回答
我对Spring kafka Stream是个新手。我最近设置了一个项目，并尝试使用kafka stream API来发布AVRO。解析Json并为每个子json发送AVRO消息。它也可以是一个或多个。 我知道如何使用kafka客户端API来做到这一点。这很简单，可以用循环来完成，但是用Stream API，我是个新手。当前stream类的代码如下： @Service@EnableBinding(StreamBindings.class)
public
浏览 38提问于2021-08-12得票数 0
我使用的是带有卡夫卡绑定的小枝云流。我有多个不同内容类型的消费者。是否有一种方法可以配置反序列化器的基础上？
浏览 0提问于2021-03-16得票数 0
回答已采纳
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号