我正在使用Spring cloud stream (kafka)在生产者和消费者微服务之间交换消息。它与本地java序列化交换数据。根据Spring cloud文档，它支持JSON、AVRO序列化。spring cloud stream中有没有尝试过的protobuf序列化(消息转换器)？public ProtobufMessageConvert
浏览 60提问于2017-12-27得票数 1
1回答
应用程序非常简单，有两个部分(作为单独的java进程运行)。
使用者将请求放入RequestTopic并从ResponseTopic获得响应。根据文档，spring.cloud.stream.bindings..destination应该指定发送或接收消息的主题。但是它为YAML文件中“spring.cloud.stream.bindings”指定的属性创建了Kafka主题。有人能在推荐信/密码中指出这个问题吗？
浏览 1提问于2019-12-04得票数 0
回答已采纳
2回答
根据spring云文档，它应该使用autoCommitOffset 来完成。spring.cloud.stream.kafka.binder.brokers=${KAFKA_BROKER_LIST}
spring.cloud.stream.default.content
浏览 7提问于2020-05-14得票数 1
回答已采纳
对于在Kafka绑定器中生成/使用的消息头的管理，有一个KafkaHeaderMapper接口，它作为bean的实现可以配置以下属性：spring.cloud.stream.kafka.binder.headerMapperBeanNameStream中的KafkaStreams绑定器有类似的地方吗？我的意图是能够控制如何在流输入和输出中反序列化/序列化或包括&
浏览 17提问于2022-01-18得票数 0
我试过这样做：和和
spring.cloud.stream.kafka.streams.bindings.请您帮助我如何将这些属性设置为应用程序
浏览 1提问于2019-04-24得票数 1
我正在尝试使用Spring Cloud Stream创建一个简单的功能bean，它处理来自KStream和GlobalKTable的消息，连接它们，聚合它们，并将结果输出到一个新的流中，但我在正确配置它所需的：spring.cloud.stream.kafka.binder.brokers: kafka-svc:9
浏览 82提问于2020-05-20得票数 1
回答已采纳
1回答
我一直在尝试使用polyglot并构建一个简单的python处理器。我遵循了polyglot recipe，但我无法获得要部署的流。我最初部署的处理器与示例中使用的处理器相同，但得到以下错误： 请求的未知命令行参数:请求的spring.cloud.stream.bindings.input.destination未知环境变量: SPRING_CLOUD_STREAM_KAFKA_BINDER_BROKERS当我手动将sprin
浏览 24提问于2020-07-17得票数 1
回答已采纳
1回答
我很难弄清楚如何测试使用Avro作为消息格式和(合流)模式注册表的应用程序。配置可以如下所示： application: cloud: schema-registry-client$IntegerSerde registry:
url: ${<em
浏览 0提问于2019-07-31得票数 1
回答已采纳
这是我的配置文件： brokers: localhost:9093
spring.cloud.stream.kafka.streams.binder.functions.processFoo.applic
浏览 4提问于2020-10-24得票数 1
回答已采纳
我正在使用spring cloud stream和使用confluent's schema registry的Aiven的模式注册表。Aiven的模式注册表使用密码保护。根据these的说明，需要设置这两个配置参数才能成功访问模式注册表服务器。vanilla java的kafka驱动时，一切都很好，但是如果我使用Spring cloud stream，我不知道如何
浏览 21提问于2019-04-16得票数 2
回答已采纳
我想从一个kafka集群消费消息并发布到另一个kafka集群。想知道如何使用spring-kafka进行配置吗？
浏览 72提问于2021-01-08得票数 2
回答已采纳
我正在使用spring云流并试图发布avro消息，但是得到了上述异常，spring.cloud.stream.bindings.feed-output-channel.producer.useNativeEncoding=headers['kafka_messageKey']
spring.cloud.stream.kafka.bindings.feed-output-chan
浏览 14提问于2022-01-21得票数 0
回答已采纳
我使用spring-cloud-stream-kafka-binder-3.0.4批量消费消息，消费后将消息转换为object，但得到上述异常。, messages.size()); catch (Exception e) throw e;} 配置： spring.cloud.stream.bindings.activity-input-channel.destinat
浏览 64提问于2021-09-17得票数 0
回答已采纳
我使用Spring数据流来设置读取CSV文件的流，使用自定义处理器对其进行转换并对其进行日志记录：
stream create --name testsourcecsv --definition "file=application/json | log --spring.cloud.stream.bindings.input.content-type=application/json" --deploy:268) ~[sp
浏览 8提问于2019-12-03得票数 1
回答已采纳
1回答
目前，我们正在为kafka使用Spring Boot 2.1.3.RELEASE和下面的依赖项： <dependencies> <groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud
浏览 3提问于2020-07-08得票数 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 Cloud Stream中使用不同的键序列化器/反序列化器。我已经找到了指定全局serdes的方法，但我不知道如何为每个绑定指定不同的serdes，以便允许不同的键类型(Integer，String等)。例如，以下配置使用属性spring.kafka.consumer.keyDeserializer和spring.<em
浏览 20提问于2019-05-09得票数 1
回答已采纳
我使用SpringBootVersion1.5.2.RELEASE和SpringKafkaVersion1.1.2.RELEASE。通过application.properties文件，我确实可以看到可用的选项(Spring.kafka.suer.*)来配置Kafka使用者。
但是，我无法找到的是配置确认模式的方法。
浏览 3提问于2017-07-20得票数 0
回答已采纳
我正在使用这个docker compose：services:
image: confluentinc/cp-zookeeper:4.1.1: 1spring.cloud.stream.bindings.event.binder=event-binder
spring.cloud.stream.bindings.event.destination=event
浏览 106提问于2020-05-07得票数 0
回答已采纳
3回答
我正在尝试使用Spring Cloud Stream来集成Kafka。正在编写的消息是Java POJO，虽然它的工作方式与预期一样(消息正在写入主题，我可以使用消费者应用程序读取)，但消息的开头添加了一些未知字符，这在尝试集成Kafka Connect以接收主题中的消息时会造成麻烦00bd-47c9-8e49-dc800c1daf50","username":"john","hasSent":nul
浏览 1提问于2017-11-21得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
