我有一个使用protobuf格式的消息的应用程序，当我运行它时，我得到了这个错误： Exception in thread "NotificationProcessorService-process-applicationIdJson消息，而我需要更改一些配置，比如“嘿，我正在等待protobuf消息”。这是我的application.yaml文件： spring: stream:
浏览 28提问于2021-04-03得票数 0
我的理解是，创建是为了与Kafka客户端API交互，后来创建项目是为了“构建与共享消息传递系统相连接的高度可伸缩的事件驱动的微服务”，该项目包括两个绑定程序，其中一个是允许与Kafka交互的绑定器。spring-cloud-stream-binder-kafka-streams
因此，我很清楚，如果我想与Kafka交互，我将<e
浏览 3提问于2021-11-10得票数 0
回答已采纳
我正在构建一个spring云微服务，它使用来自kafka主题的数据。在消费者中，我将主题绑定到一个KStream。传入消息不包含时间戳，因为kafka版本低于0.10。否则，当我按键对它们进行分组时，它不会使用"default.timestamp.extractor“(已设置为org.apache.kafka.streams</
浏览 1提问于2019-06-08得票数 0
我们有一个场景，我们希望在cluster#1上消费来自kafka主题的数据，但在cluster#2上创建KTable主题(重新分区和changelog)。通道绑定-spring.cloud.stream.bindings.member.consumer.useNativeDecoding: true
spring<
浏览 4提问于2019-01-12得票数 0
2回答
我正在开发一个spring引导应用程序，这个依赖库仅用于消费数据并将数据推送到数据库。
卡夫卡( spring-cloud-stream-binder-kafka )或卡夫卡(spring)
浏览 9提问于2022-04-27得票数 -2
我们让多个应用程序使用者收听相同的kafka主题，并且生产者在向主题发送消息时设置消息头，以便特定实例能够评估标头并处理消息。received message is {}",message.getName());在SpringCloudStream3.0.0中，@StreamListener被废弃了，我无法在函数中找到与条件属性等价的内容
浏览 11提问于2021-09-16得票数 5
在Spring网站()中，列出了要使用的绑定选项。我们有阿帕奇卡夫卡和卡夫卡流选项。
，他们之间有什么区别？，为了什么目的，我们应该在这两者之间做出选择？
浏览 3提问于2021-06-18得票数 0
回答已采纳
场景: Apache Flink、Kafka、Protocol buffers data consumer。数据来源为协议缓冲区格式的Kafka主题(多个主题: topic#1、topic#3、topic#3)。使用者是Apache Flink使用者。每个主题都有一个独特的协议定义。，将Kafka中的数据摄取到数据库中。如何为A
浏览 13提问于2021-04-03得票数 0
TL/DR:我在Kafka中有一个Protobuf格式的主题中的数据，我想创建一个流，将protobuf转换为Avro格式的新主题，一旦它转换为avro格式，我将有一个连接器来使用它并将其转储到s3存储桶中='AVRO') AS SELECT * FROM SearchRequest_proto; 之后，如果我进入我的kafka<em
浏览 22提问于2020-09-19得票数 0
我正在做一个POC来演示一些Spring Cloud Kafka功能。我使用的是带有SpringBoot 2.4.1的Java11。我的build.gradle具有以下库 implementation 'org.springframework.cloudCloud Stream>
我<em
浏览 0提问于2021-01-30得票数 0
我用的是春云流卡夫卡。我正在启动两个具有相同组名的消费者应用程序实例( testGroup )，使用来自具有单个分区的Kafka主题testTopic的消息，我期望其中一个消费者实例使用来自Kafka主题的消息，而另一个实例不使用任何东西我
浏览 6提问于2016-11-15得票数 0
看看使用绑定(functional )的项目，我遇到了两种风格-- KStreams和反应性管道Flux<Message<T>>。它们作为一个想法有些重叠，但只是部分地重叠。卡夫卡世界中Flux的特征是什么？这是另一种"KStream"，一种“耐久的反应流”吗？它的使用是否保证不滞后，或至少最小，因为背压？
浏览 4提问于2022-09-14得票数 0
回答已采纳
我们通过集成使用Kafka流。我将复制因子配置为在所有内部Kafka流主题中使用，方法是设置它适用于大多数由Kafka流在内部使用的重新分区/变更主题。但是，
浏览 5提问于2020-10-14得票数 1
回答已采纳
我正在创建一个简单的卡夫卡流应用程序。我的制作人正在制作protobuf序列化消息到一个主题，我在Kafka流应用程序中使用这个主题来处理消费者消息。我试图在我的valueSerde: io.confluent.kafka.streams.serdes.protobuf.KafkaProtobufSerde文件中使用</
浏览 1提问于2021-07-28得票数 0
我希望每5分钟消费一次来自kafka主题的消息，然后处理它，并使用spring云流将其发送到另一个主题。你知道该怎么做吗？
浏览 143提问于2020-07-02得票数 0
这是这个question的续集。我可以将“普通”Apache Kafka绑定器和功能模型一起使用吗？到目前为止，使用基于注释的配置，我在一个应用程序中混合了这两者，spring-cloud-stream-binder-kafka用于简单的消费/生产，spring-cloud-stream-binder-kafka-streams用于高级
浏览 21提问于2019-10-16得票数 0
回答已采纳
我正在使用spring cloud kafka绑定器将数据读取到KStream。在阅读其中一个主题的数据时，我需要从头开始阅读。添加我使用过的application.yaml：
sp
浏览 11提问于2018-05-04得票数 1
我有以下设置：
几个Spring服务，其中最显著的是spring-cloud-starter-zipkin和spring-cloud-stream-binder-kafka依赖项。乍一看，一切似乎都还好，特别是在我的服务之间的rest调用中，但是我刚刚看到，它并不适用于我自己用于服务之间异步通信的消息(我使用spring云流来实现这一点)。我可以看到来
浏览 0提问于2018-06-11得票数 0
回答已采纳
这不是一个大问题，但我很好奇，一些额外的流消费者来自哪里，如果这是一个设置，我可以改变。
我有一个非常简单的spring云流消费者设置，针对当地的Kafka代理。但是，当我检查本地代理中的消费者组成员时，它总是一个消费者，并且总是创建的第二个消费者(即使用客户机id test-group-2)
浏览 7提问于2021-04-14得票数 0
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
