腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(166)
视频
沙龙
1
回答
Spring
Cloud
Stream
-
查询
主题
而
不显
式
消费
KTable
/
KStream
?
apache-kafka-streams
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我在一个Java应用程序中使用了
Spring
Cloud
Stream
库。我想为状态存储使用Kafka Streams绑定器。应用程序将向
主题
发布消息,我希望使用Kafka Streams InteractiveQueryService来检索同一
主题
中的数据。是否可以按原样执行这样的
查询
,或者我是否需要首先将
主题
作为
KTable
/
KStream
使用并物化它,然后才能执行
查询
?我不需要对topic进行
浏览 36
提问于2020-01-28
得票数 0
1
回答
Spring
Cloud
kafka
Stream
-如何对同一频道使用两个不同的kafka集群?
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
、
spring-kafka
我们有一个场景,我们希望在cluster#1上
消费
来自kafka
主题
的数据,但在cluster#2上创建
KTable
主题
(重新分区和changelog)。通道绑定-
spring
.
cloud
.
stream
.bindings.member.consumer.useNativeDecoding: true <e
浏览 4
提问于2019-01-12
得票数 0
1
回答
KTable
作为
主题
的输入,带有空键
spring-boot
、
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
其思想是存储来自 description 的数据(想必是在
KTable
中,为每个id保留最新的描述),以及当新消息出现在live中时--将来自description的数据连接到相应的id上,并进一步发送
KStream
<String, String> process( @Input("live")
KStream
<String, String> live,@Input("descriptions")
KTable
<String, S
浏览 0
提问于2020-05-19
得票数 2
回答已采纳
1
回答
Spring
Kafka
Stream
未编写
spring
、
spring-boot
、
apache-kafka
、
spring-cloud-stream
我正在写一个
Spring
Boot (2.1.4)应用程序,试图使用
Spring
Cloud
Streams for Kafka。 我要做的是维护一个
主题
的传感器列表(“传感器”)。为此,我从传感器
主题
创建了一个
KTable
<String, Sensor>,将温度
主题
映射到纯传感器的数据(在本例中是它的名称),并与一个ValueJoiner进行外部连接,如果传感器存在,则保留传感器$StringSerde
spring
.
cloud
浏览 29
提问于2019-05-03
得票数 1
1
回答
有关如何在
Spring
启动应用程序中使用
KTable
的
Spring
Cloud
3.1文档
spring-cloud
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我正在努力寻找任何关于我可以在哪里使用
Spring
Cloud
Streams的文档,这些文档将Kafka
主题
放入
KTable
中。在使用注解在
Spring
boot中执行此操作的过程中,我已经查找了文档,例如这里的https://
cloud
.
spring
.io/
spring
-
cloud
-static/
spring
-
cloud
-
stream
-b
浏览 19
提问于2021-04-22
得票数 0
1
回答
如何在单个分区的kafka
主题
上运行超过1个
ktable
-
ktable
joins kafka streams应用程序实例?
apache-kafka-streams
、
spring-cloud-stream
、
spring-kafka
KTable
<Key1, GenericRecord> primaryTable = createKTable(key1,
kstream
, statestore-name);
KTable
<Key3, GenericRecord这三个传入的流具有不同的密钥,但在创建
KTable
时,我
浏览 12
提问于2019-01-27
得票数 0
回答已采纳
1
回答
如何使用使用
主题
中的最新记录?
spring-boot
、
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
、
kafka-streams-binder
: myappId
spring
.
cloud
.
stream
.bindings.processName-in
spring
.
cloud
.
stream
.bindings.processName-in-1.destination: secondTopic
spring
.
cloud<
浏览 10
提问于2022-02-05
得票数 0
回答已采纳
2
回答
KTable
不对具有相同密钥的传入记录执行重复数据消除
apache-kafka
、
spring-kafka
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我正在尝试使用输入
主题
作为
KTable
对记录进行重复数据删除,并将它们下沉到输出
主题
。但
KTable
仍在将重复记录下沉到输出
主题
。不确定我哪里错了。这是我的application.yml
spring
:
stream
: bindings: materializedAs: incoming-
浏览 38
提问于2021-05-07
得票数 1
回答已采纳
1
回答
多
主题
流监听器通信错误kafka |未从.properties文件中提取应用ID
apache-kafka
、
kafka-consumer-api
、
apache-kafka-streams
、
spring-kafka
、
spring-cloud-stream
但是当从第二个
主题
发送到第三个
主题
时,它错误地说无法创建
消费
者绑定,30秒后重试,注册表
消费
者属性处出现空指针异常调试时我意识到,第三个
主题
的applicationID被作为空传递,尽管我已经明确指定了它我的application.properties文件 ## Topic 1-
spring
.
cloud</e
浏览 11
提问于2021-01-28
得票数 0
回答已采纳
1
回答
春云流卡夫卡流加入后未写入目的地
主题
apache-kafka
、
spring-cloud
、
apache-kafka-streams
、
spring-cloud-stream
这是我的应用程序,它简单地从客户
主题
(输入绑定)获取对
KStream
的引用,从order
主题
获取另一个引用(订单绑定)。然后,它从客户
主题
创建一个
KTable
,并与order
KStream
执行连接:class ShippingKStreamConfiguration {
浏览 1
提问于2019-04-17
得票数 0
回答已采纳
1
回答
从
消费
者创建materializeView (功能编程模型)
spring-cloud-stream
因为我在kafka
主题
中的数据可以在没有任何转换的情况下实现。public Consumer<
KTable
<String, Pojo>> process() {} 我在文档中看到,可以直接执行
spring
.
cloud
.
stream
.kafka.streams.bindings.process-in-0.consume
浏览 1
提问于2021-07-26
得票数 0
回答已采纳
3
回答
当
主题
有多个分区时,
KTable
-
KTable
外键联接不会生成所有消息。
java
、
spring-boot
、
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
Service.javapublic BiFunction<
KTable
<MyKey, MyValue>,
KTable
<MyOtherKey, MyOtherValue>,
KStream
implementation 'org.springframework.
cloud
:
spring
-
cloud
-
stream
-binder-kafka-streams' implementation 'io.co
浏览 0
提问于2020-07-13
得票数 8
回答已采纳
2
回答
Spring
事件源-使用Kafka + KafkaStreams API
查询
某些实体状态的示例
apache-kafka
、
event-sourcing
、
spring-cloud-stream
、
apache-kafka-streams
、
spring-kafka
您能用
Spring
显示这个
查询
的大致实现吗? application:
cloud
: kafka:
spring
: name: product-service
浏览 12
提问于2017-07-11
得票数 6
回答已采纳
2
回答
:下游消息的数量与发送到
主题
的消息之和不匹配
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
它定义了一个包含以下部分的拓扑:绿色中的数字显示了通过通过流绑定绑定的各个处理器定义的拓扑传递的消息数量,以下是各自的属性:
spring
.
cloud
.
stream
.kafka.streams: schema.registry.url: mock:设置这两种情况:
spring
.
cloud
.
str
浏览 1
提问于2020-05-30
得票数 2
回答已采纳
1
回答
Apache Kafka Streams交互
式
查询
-如何创建值是实体
而
不是聚合的存储
apache-kafka
、
event-sourcing
、
apache-kafka-streams
我有一个
主题
,它接收带有以下信息的事件:value -> {"orderId" : aaa, "productId" : xxx, "userId" : yyy, "state" : "zzz"} (包含订单完整信息的JSON)
KStream</e
浏览 8
提问于2017-07-17
得票数 1
回答已采纳
1
回答
如何让
Spring
cloud
stream
Kafka streams绑定器在处理过程中重试处理消息?
java
、
apache-kafka-streams
、
spring-cloud-stream
、
event-driven-design
、
spring-cloud-stream-binder-kafka
我正在使用
Spring
Cloud
Stream
处理Kafka Streams。在消息处理应用程序中,可能会产生错误。因此,不应提交并重试该消息。我的申请方法-public Function<
KStream
<Object, String>,
KStream
<String, Long>> process() { return (input=kt.map((k, v) -> new KeyValue<>(v, v)).groupByKey(G
浏览 16
提问于2020-06-04
得票数 1
回答已采纳
1
回答
如何在
spring
-
cloud
-
stream
中使用kafka过程拓扑中的交互
式
查询
?
java
、
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
是否可以在
Spring
Cloud
Stream
中使用带有@EnableBinding注释的类或带有@StreamListener的方法中的交互
式
查询
(InteractiveQueryService)我的@StreamListener方法正在监听一堆KTables和KStreams,在处理拓扑的过程中,例如过滤,我必须检查来自
KStream
的键是否已经存在于特定的
KTable
中。我试图弄清楚如何扫描传入的
KTable
以检查密钥是否已经存在,但没有成功。
浏览 16
提问于2019-05-01
得票数 1
回答已采纳
1
回答
spring
kafka流使用不起作用的函数样式
消费
来自多个
主题
的消息
apache-kafka
、
spring-kafka
、
spring-cloud-stream
我正在尝试使用单个绑定来
消费
来自多个
主题
的消息,并且只是简单地打印。但由于某些原因,我只能从第一个
主题
中获得消息。我是否必须以不同的方式指定属性。我在这个博客https://
spring
.io/blog/2019/12/03/
stream
-processing-with-
spring
-
cloud
-
stream
-and-apache-kafka-streams-part/
浏览 25
提问于2021-09-10
得票数 1
回答已采纳
2
回答
如何将
KTable
输出发布到特定的Kafka
主题
?
apache-kafka-streams
我正在尝试编写我的第一个练习应用程序,使用Kafka Streams来计算
主题
中的字数。但是,我想我指的是旧的API,因为在lambda函数的末尾,我想将
KTable
的输出放到一个
主题
中,但我没有看到任何这样的方法。 我引用的代码使用了to()方法,但我认为现在没有这样的方法。我看到了toStream(),但不知道如何使用它将消息放到特定的输出
主题
中。 有没有人可以看一下,因为这应该是非常基础的。from Kafka
KStream
<String, String> wordCo
浏览 19
提问于2019-12-26
得票数 2
1
回答
Spring
Cloud
Stream
Kafka
消费
者应用不允许添加供应商
avro
、
apache-kafka-streams
、
spring-cloud-stream
、
kafka-producer-api
、
confluent-schema-registry
我正在开发一个
Spring
Cloud
Stream
Kafka应用程序。我只添加了
消费
者来使用来自
主题
的消息,并使用FIX协议将它们传递给第三方。下面是我的application.yml文件:
spring
.
cloud
.
浏览 7
提问于2020-07-30
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka Streams与Quarkus:实时处理事件
Spring Cloud Stream简介
译:基于Spring Cloud Stream构建和测试 message-driven 微服务
精通springcloud:消息驱动的微服务,了解Spring Cloud Stream
Spring Cloud 简介
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券