腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(8260)
视频
沙龙
1
回答
在运
行时
设置
spring
云
流
kafka
的
主题
apache-kafka
、
spring-cloud-stream
我使用
的
是
spring
cloud stream。我现在介绍了如何使用application.yaml和
Kafka
创建静态绑定。我想在java代码中创建一个新
的
绑定,或者修改application.yaml中定义
的
绑定
的
主题
。例如 cloud: default-binder:
kafka
definition: listenEnrichment bindings:listenEnrichment-
浏览 9
提问于2021-02-04
得票数 0
2
回答
在
spring
引导应用程序中使用哪些
kafka
库?
java
、
spring-boot
、
apache-kafka
、
spring-kafka
、
spring-cloud-stream
我正在开发一个
spring
引导应用程序,这个依赖库仅用于消费数据并将数据推送到数据库。 卡夫卡(
spring
-cloud-stream-binder-
kafka
)或卡夫卡(
spring
)
浏览 9
提问于2022-04-27
得票数 -2
1
回答
带有弹簧引导网络
流
的
反应性
kafka
流
示例
apache-kafka
、
microservices
、
spring-cloud-stream
我正在尝试构建一个
Spring
应用程序,它使用来自一个
Kafka
主题
的
事件,对其进行一些处理(可能涉及对反应性db查找
的
操作),并将它们发送到另一个
kafka
主题
。目前,该应用程序为
kafka
使用了webflux和
spring
云
数据
流
。 请有人建议使用好吗,还是应该使用其他方法来实现端到端
的
反应行为。尝试用
Spring
引导WebFlux,春季
云
数
浏览 7
提问于2022-12-02
得票数 0
2
回答
运
行时
配置更新
java
、
spring
、
apache-kafka
、
spring-kafka
、
spring-cloud-stream
我使用
Spring
云
流
和
Kafka
绑定器来使用SASL连接到
Kafka
集群。SASL配置如下所示:
spring
.cloud.stream.
kafka
.binder.configuration.sasl.jaas.config=SASL_SSL 我想以编程方式/
在运<
浏览 3
提问于2021-03-26
得票数 0
1
回答
如何更新已创建
主题
的
复制因子?
apache-kafka
、
spring-kafka
、
spring-cloud-stream
我们已经创建了
kafka
主题
,默认replication-factor为1,为了更新这一点,我们在application.yaml中添加了
spring
.cloud.stream.
kafka
.binder.replication-factor: 3属性,该属性没有反映在
kafka
中创建
的
主题
。使用
的
spring
云
流
版本为Germantown.SR1
浏览 17
提问于2020-01-27
得票数 2
回答已采纳
1
回答
春
云
启动
流
-
kafka
不创建提供给
spring
.boot.cloud.stream.bindings.output.destination
的
主题
。
java
、
docker
、
spring-boot
、
apache-kafka
、
docker-compose
在春季引导应用程序中,我正在使用
spring
云
启动器-
流
-
kafka
和
spring
-
云
流
罐子。 jar
的
版本是1.1.1.RELEASE,我们正在创建名为Test
的
生产者。对于同样
的
情况,下面是application.yml文件。,它是将“输出”创建为一个
主题
。对于卡夫卡,我使用
的
是wurstmeister/
kafka
(标签0.9.0.1-1)图像
浏览 3
提问于2017-11-14
得票数 1
回答已采纳
1
回答
异常未嵌入到DLQ中
spring-cloud-stream
、
spring-cloud-dataflow
、
spring-kafka
我已经用
kafka
活页夹
设置
了一个春天
的
云
流
。正如前面提到
的
,我还启用了DLQ并
设置
了headerMode来捕获异常消息。然而,当有异常时,我只在我
的
kafka
主题
中看到消息,而没有异常详细信息。我
的
application.yml看起来像这样 application: cloud:
浏览 4
提问于2017-10-13
得票数 1
2
回答
Spring
流
kafka
绑定器-
主题
序列化配置
spring
、
spring-boot
、
apache-kafka
、
spring-kafka
、
spring-cloud-stream
因此,我想我陷入了困惑,因为我知道SpringCloudStreams有两个不同的卡夫卡绑定: 我可以使用以下逻辑调整默认值: main: web-appli
浏览 23
提问于2020-11-12
得票数 1
1
回答
用于大容量数据处理
的
Spring
或
Kafka
流
apache-kafka-streams
、
spring-kafka
、
spring-cloud-stream
、
quickfix
、
fix-protocol
我正致力于为银行创建一个大容量
的
JSON数据处理应用程序,使用
Spring
、
Kafka
和QuickFIX/J。这是我第一次使用
Kafka
和QuickFIX/J这样
的
技术,无法决定是使用普通
的
Kafka
spring
还是
Kafka
流
还是
spring
云
流
。以下是要求: 从多个进程读取数据,并将数据发送给QuickFIX/J启动器,后者进一
浏览 7
提问于2020-06-01
得票数 0
1
回答
如何在springboot中为每个
主题
动态创建单独
的
Kafka
监听器?
spring
、
spring-mvc
、
spring-boot
、
kafka-consumer-api
、
spring-kafka
我是
Spring
和
Kafka
的
新手。我正在做一个使用SpringBoot-
kafka
的
用例,允许用户
在运
行时
创建
kafka
主题
。
spring
应用程序期望
在运
行时
以编程方式订阅这些
主题
。到目前为止,我所知道
的
是,
Kafka
listener是设计时,因此在启动之前需要指定
主题
。有没有办法在SpringBoot-<
浏览 0
提问于2017-01-08
得票数 11
1
回答
春季
云
流
Kafka
在启动时创造了一个奇怪的话题。
apache-kafka
、
spring-kafka
、
spring-cloud-stream
我在application.yml中为我
的
Spring
云
流
Kafka
设置
了以下内容: cloud: definition: userBindingstream: binder: replicationFactorSystem.out.println("Rec
浏览 2
提问于2021-12-08
得票数 0
回答已采纳
1
回答
不应用于状态存储更改
主题
的
Kafka
流
复制因子
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
我们通过集成使用
Kafka
流
。我将复制因子配置为在所有内部
Kafka
流
主题
中使用,方法是
设置
它适用于大多数由
Kafka
流在内部使用
的
重新分区/变更
主题
。但是,该
设置
似乎对通过Materializ
浏览 5
提问于2020-10-14
得票数 1
回答已采纳
1
回答
包含maxRequestSize
的
春季
云
流
卡夫卡绑定版本是什么?
spring-cloud-stream
当将事件发布到
kafka
主题
时,我会遇到以下异常我正在使用下面的
spring
云
版本,没有在我
的
pom中为
spring
-cloud-stream-
kafka
-binder提供任何版本。<
spring
-cloud-stream.version>Brooklyn.S
浏览 0
提问于2017-03-22
得票数 0
回答已采纳
2
回答
如何使用camel创建
kafka
主题
分区
apache-kafka
、
apache-camel
我正在使用camel-
spring
-boot-starter中
的
camel-
kafka
,在
spring
引导项目中将一条消息从一个卡夫卡
主题
路由到另一个。在某些
主题
上,我当前
的
应用程序,它只使用、camel-
kafka
、和(没有弹簧
云
流
)。 在骆驼中,我们使用urls提供..。有点像. uri(
kafk
浏览 2
提问于2018-06-20
得票数 0
1
回答
在春
云
流
中调用Hibernate
spring-boot
、
spring-data-jpa
、
spring-cloud-stream
我对春天
的
云
流
很陌生。在
流
处理过程中调用Hibernate有效吗?
浏览 9
提问于2021-12-15
得票数 1
回答已采纳
1
回答
如何让
kafka
在
spring
运
行时
使用http
流
数据?
spring
、
spring-xd
、
http-streaming
、
apache-kafka
在
spring
运
行时
,可以让
kafka
源模块作为处理器模块工作吗?有代码样本吗?我正试图实现这样
的
目标: http (xd源)、xd源(xd处理器)、xd使用者(xd接收器)stream create kafkaSourceTest --definition "http --outputType=application/json |
kafka
浏览 3
提问于2015-05-12
得票数 0
回答已采纳
1
回答
弹簧
云
流
:按类型连接到粘合剂上
的
功能
apache-kafka
、
spring-kafka
、
spring-cloud-stream
、
spring-cloud-function
我有一个用功能方法实现
的
Spring
云
流
应用程序。该应用程序消耗来自多个
Kafka
主题
的
事件,将输入规范化为输出模式(总是相同
的
模式),并发布到
Kafka
。我不使用
Kafka
流
,因为不需要连接/充实/状态。 我希望通过控制要
在运
行时
使用
的
输入
主题
来允许灵活部署:您可以使用所有
主题
,也可以使用
浏览 0
提问于2021-12-02
得票数 0
1
回答
春天云
流
的
动态目的地-卡夫卡
apache-kafka
、
spring-kafka
、
spring-cloud-stream
、
spring-cloud-function
我正在开发一个基于
Kafka
的
spring
云
流
的
路由器(事件代理)应用程序,该应用程序位于功能范例中。应用程序从常量输入
主题
中消耗,映射和过滤消息,然后根据某些输入字段将其发送到某个
主题
(一次只有一条消息,而不是多个结果)。通过为输出消息
设置
spring
.cloud.stream.sendto.destination头是最好
的
方法吗?如果是的话,我应该如何为生产者
设置
绑定呢?
浏览 4
提问于2021-12-30
得票数 0
1
回答
如何每隔5分钟消费一次来自
kafka
topic
的
kafka
消息,而不是使用
云
流连续消费
apache-kafka
、
spring-cloud-stream
我希望每5分钟消费一次来自
kafka
主题
的
消息,然后处理它,并使用
spring
云
流
将其发送到另一个
主题
。你知道该怎么做吗?
浏览 143
提问于2020-07-02
得票数 0
2
回答
为
Kafka
创建
Spring
数据
流
主题
python
、
spring
、
kubernetes
、
apache-kafka
、
spring-cloud-dataflow
我有自己
的
Spring
数据
流
处理器,里面有Python,我使用这个示例作为指南:。()]) SCD
浏览 8
提问于2019-12-14
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring for Apache Kafka 3.0和Spring for RabbitMQ 3.0发布
Spring文档翻译系列(一)
SpringCloud初识
Spring Cloud Stream简单入门
使用Apache Kafka的Golang实践指南
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券