腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
如何抑制
Spring
流
中窗口聚集
的
结果?
spring-boot
、
apache-kafka
、
spring-cloud
、
apache-kafka-streams
、
spring-cloud-stream
我在我
的
Spring
项目中
使用
Kafka
-streams-binder。
Kafka
流
应用程序
使用
6分钟
的
滑动窗口对结果进行汇总和分析。但问题是聚合操作正在产生重复
的
结果。我想要抑制中间结果,并且只在
应用程序
的
窗口结束后才发布。可以通过
Kafka
2.1.1中
的
Kafka
.supress()操作来实现。但是
Spring<
浏览 2
提问于2019-11-29
得票数 2
2
回答
在
Spring
Kafka
中,我是否需要在
应用程序
中添加@EnableKafka注释?
java
、
spring-boot
、
apache-kafka
、
spring-kafka
我看到一些人将@EnableKafka添加到他们
的
spring
boot
应用程序
中,我想知道为什么。我有一个可以正常工作
的
spring
boot
kafka
生产者和消费者,我没有
使用
@EnableKafka。那么,为什么人们需要明确地添加它呢? 谢谢。
浏览 181
提问于2020-04-17
得票数 16
回答已采纳
3
回答
Spring
执行器+
Kafka
流
-将
kafka
流
状态添加到健康检查端点
spring
、
spring-boot
、
apache-kafka
我有一个春季引导
应用程序
,在那里我
使用
apache streams。我不
使用
春云
流
。我添加了执行器健康检查端点。health.db.enabled: false base-path:当一个运行时异常被抛出并且我
的
流
被停止时我
的
pom.xml: <dependency>
浏览 13
提问于2019-09-19
得票数 7
回答已采纳
1
回答
使用
kafka
流
的
Spring
boot
应用程序
spring-boot
、
apache-kafka-streams
有谁有
使用
kafka
stream和
spring
boot
将消息作为
流
读取
的
hello world示例。 我
的
kafka
集群是受SASL_安全保护
的
。那么我如何将我
的
spring
boot
kafka
流
应用程序
与。在application.properties文件中写什么。 我不想用春天
的
云溪。
spri
浏览 21
提问于2020-07-10
得票数 0
1
回答
当自动提交为真时,弹簧云
流
卡夫卡绑定健康指示器失败
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我们正在
使用
Kafka
绑定构建带有
Spring
云
流
的
定制DB Sink。我们
使用
以下版本
的
Spring
和
Spring
<
spring
.
boot
.version>2.3.4.RELEASE</
浏览 2
提问于2021-04-30
得票数 0
1
回答
在SCDF处理器模块中
使用
的
Spring
Boot
父版本
spring-cloud-dataflow
我们正在开发SCDF上
的
项目,
kafka
版本2.4.1用于数据
流
,2.3.1用于skipper。我有一个云
流
应用程序
,它在我
的
IDE中进行单元测试时工作得很好。但当我注册为处理器时,我在我
的
Stream中看不到此特定
应用程序
的
日志中
的
任何活动。 当前
使用
Boot
2.2.5和Hoxton.SR3。但当我
使用
spring
boot
版
浏览 13
提问于2020-03-25
得票数 0
1
回答
使用
Spring
Integration启动
Spring
Boot
应用程序
Kafka
用户暂停
java
、
spring
、
spring-boot
、
apache-kafka
、
spring-integration
我正在开发一个
Spring
Boot
应用程序
,它
使用
以
Kafka
主题为源
的
Spring
集成
流
。我们
的
集成
流
开始
使用
一个包含带有springframework.cloud.stream.annotation.Input和输出注释
的
SubscribableChannels
的
接口。这些配置为通过云配置和
spring
.cloud.stream.
k
浏览 0
提问于2018-04-24
得票数 1
2
回答
如何
使用
camel创建
kafka
主题分区
apache-kafka
、
apache-camel
我正在
使用
camel-
spring
-
boot
-starter中
的
camel-
kafka
,在
spring
引导项目中将一条消息从一个卡夫卡主题路由到另一个。在某些主题上,我当前
的
应用程序
,它只
使用
、camel-
kafka
、和(没有弹簧云
流
)。 在骆驼中,我们
使用</em
浏览 2
提问于2018-06-20
得票数 0
1
回答
kafka
流
升级到
spring
后停止工作-
kafka
:2.5.3
java
、
spring-boot
、
apache-kafka
、
apache-kafka-streams
、
spring-kafka
我正在尝试将我
的
Spring
应用程序
升级到2.5.0版本plugins {}implementation 'org.springframework.
kafka
:
spring</
浏览 5
提问于2021-11-29
得票数 0
回答已采纳
2
回答
如何
使用
Spring
Kafka
测试
Kafka
Streams应用?
spring-boot
、
apache-kafka
、
apache-kafka-streams
、
spring-kafka
、
spring-kafka-test
我正在写一个
使用
Kafka
Streams,
Spring
-
Kafka
和
Spring
Boot
的
流
应用程序
。在
使用
Spring
-
Kafka
时,我找不到任何信息来正确测试
Kafka
Streams DSL所做
的
流
处理。文档提到了EmbeddedKafkaBroker,但似乎没有关于如何处理测试
的
信息,例如状态存储。
浏览 25
提问于2019-08-31
得票数 3
1
回答
为什么我
的
春季云流配置会创建多个
kafka
消费者?
spring-boot
、
spring-kafka
、
spring-cloud-stream
这不是一个大问题,但我很好奇,一些额外
的
流
消费者来自哪里,如果这是一个设置,我可以改变。 我有一个非常简单
的
spring
云
流
消费者设置,针对当地
的
Kafka
代理。但是,当我检查本地代理中
的
消费者组成员时,它总是一个消费者,并且总是创建
的
第二个消费者(即
使用
客户机id test-group-2)。为了清晰起见,我
使用
了
Spring
版本
的
2.3.4.RELEASE和云
浏览 7
提问于2021-04-14
得票数 0
回答已采纳
1
回答
我们可以在
Kafka
Streams中
使用
任何其他数据库,如MariaDB或MongoDB来代替Rocks DB来存储状态吗?有什么方法可以配置它吗?
mongodb
、
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
我有一个
Spring
boot
Kafka
Stream
应用程序
,它处理所有传入
的
事件,并将其存储在
Kafka
Streams内部提供
的
State store中,并
使用
交互式查询服务进行查询。在所有这些
使用
" RocksDB“
的
Kafka
流
中,我想用任何其他可以配置
的
数据库替换这个RocksDB,比如MariaDB或MongoDB。有办法做到这一点吗?如
浏览 21
提问于2020-08-27
得票数 4
1
回答
春云数据
流
Grafana Prometheus没有显示
流
数据
spring-cloud
、
grafana
、
prometheus
、
spring-cloud-stream
、
spring-cloud-dataflow
我在这个网站上发布了基于
的
Spring
云数据
流
。 export STREAM_APPS_URI=https://dataflow.
spring
.io/Einstein-BUILD-SNAPSHOT-stream-applications-
kafka
-maven我继续注册这3个
应用程序
,然后用它们创建一个
流
,然后运行它。问题1:
流
的<
浏览 2
提问于2019-09-11
得票数 4
3
回答
春天云
流
卡夫卡
流
绑定KafkaException:无法启动
流
:“侦听器”不能为空
spring
、
spring-boot
、
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
我刚接触过
Kafka
流
和,但在将与集成相关
的
代码移到属性文件方面,我读过一些关于它
的
好东西,这样devs可以主要关注事物
的
业务逻辑方面。} imports {}当我运行
应用程序
时,我得
浏览 14
提问于2021-03-31
得票数 3
回答已采纳
1
回答
Spring
Cloud Stream中
的
生产者异常处理
spring-boot
、
apache-kafka-streams
、
spring-kafka
、
spring-cloud-stream
我在
使用
Spring
Cloud Stream编写
的
Kafka
Stream作业中遇到了一个场景,producer因异常而失败。在
kafka
流
中检查,有一个配置来处理相同
的
问题:default.production.exception.handler 在
spring
云
流
中找不到后续处理程序。请帮帮忙。提前谢谢。
Spring
boot
版本:2.2.4.RELEASE
浏览 2
提问于2020-03-11
得票数 0
2
回答
连接多个集群
spring
kafka
java
、
spring-kafka
我想从一个
kafka
集群消费消息并发布到另一个
kafka
集群。想知道如何
使用
spring
-
kafka
进行配置吗?
浏览 72
提问于2021-01-08
得票数 2
回答已采纳
2
回答
Spring
Cloud数据
流
:自定义应用
流
和预建应用
流
之间
的
通信
spring
、
spring-cloud-stream
、
spring-cloud-dataflow
大家好,
Kafka
版本: 0.10.2.1 ( 2.11 scala版本)
Spring
boot
版本: 2.0.2我已经完成了来自
的
教程 然后,我注册了一个名为transformer (
浏览 2
提问于2018-05-25
得票数 0
1
回答
Spring
云
流
绑定器
kafka
不能在Netty上运行
spring-cloud-stream
、
spring-webflux
我想
使用
Kafka
Steams和
Spring
Webflux在Netty之上构建一个
流
引擎,以通过HTTP提供持续
的
状态更改。我注意到如果我有在我
的
gradle文件中,
spring
boot
这是不是某种设计决定不为
spring
-cloud
浏览 8
提问于2017-12-25
得票数 1
回答已采纳
1
回答
Kafka
与
Spring
框架
的
连接
spring
、
spring-boot
、
spring-integration
、
spring-xd
、
apache-kafka-connect
有没有人知道
Spring
Boot
与
Kafka
Connect
的
集成?有一个
spring
-
kafka
项目,我认为它与
Kafka
客户端进行了很好
的
集成,但没有连接和
流
API。
浏览 2
提问于2017-08-09
得票数 7
1
回答
如何在
kafka
中
使用
kafka
流进行请求-响应?
spring-boot
、
apache-kafka
、
apache-kafka-streams
我想用
kafka
流
实现请求-响应模式,我
使用
了
spring
boot
kafka
,它添加了一些数据作为头部,命名为关联id,但是当请求消息被
kafka
流
API处理时,头部数据会丢失,不能发送到响应主题!我如何解决它,或
使用
其他方法??
浏览 0
提问于2020-04-19
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
使用idea快速的搭建spring boot项目
使用Gradle构建基于Kotlin的Spring Boot项目
《06.Spring Boot的数据访问:PagingAndSortingRepository使用》
Spring Boot简化了Web应用程序的开发,你是怎么看待的?
使用 Spring Boot 2.1 介绍 Servlet 4.0 的服务器推送
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券