腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(3707)
视频
沙龙
2
回答
如何
使用
spring
webflux
持续
消费
来自
Kafka
的
主题
?
java
、
spring-webflux
、
spring-kafka
、
project-reactor
我有一个名为WordListenerHandler
的
spring
-
webflux
处理程序,我可以从浏览器请求一个HTTP GET。此请求是一个
使用
Flux:.body(Flux.interval(Duration.ofSeconds(1)).log(), Long.class)
的
Long流,因此它不会刷新页面而不断更新Flux。我希望显示
kafka
topi
的
消息,而不是长值
的
流。因此,我有一个
消费
者方法onMessage(Consu
浏览 70
提问于2021-03-31
得票数 1
回答已采纳
2
回答
如何
在发送reactor消耗
的
前100条消息后有条件地发布附加SSE web流量事件
kafka
主题
java
、
project-reactor
、
server-sent-events
、
webflux
、
reactor-kafka
我正在
使用
reactor-
kafka
库和
spring
webflux
SSE流
消费
来自
kafka
主题
的
数据。当
来自
主题
的
所有消息都被
消费
完时,我需要返回一个特殊
的
ServerSentEvent,即最大
主题
偏移量get等于订阅时从0偏移量开始消耗的当前偏移量。以便客户端知道在
kafka
topic中没有更多<em
浏览 7
提问于2021-06-28
得票数 1
1
回答
如何
从
主题
末尾开始阅读,而不考虑组
的
承诺偏移量
spring-boot
、
spring-webflux
、
server-sent-events
、
spring-kafka
我正在
使用
以下包来
消费
kafka
消息 compile 'org.springframework.boot:
spring
-boot-starter-
webflux
'// tag::actuator[] compile("org.springframework.boot:
spring
-
浏览 7
提问于2019-05-15
得票数 0
回答已采纳
1
回答
带有弹簧引导网络流
的
反应性
kafka
流示例
apache-kafka
、
microservices
、
spring-cloud-stream
我正在尝试构建一个
Spring
应用程序,它
使用
来自
一个
Kafka
主题
的
事件,对其进行一些处理(可能涉及对反应性db查找
的
操作),并将它们发送到另一个
kafka
主题
。目前,该应用程序为
kafka
使用
了
webflux
和
spring
云数据流。 请有人建议
使用
好吗,还是应该
使用
其他方法来实现端到端
的
反应行为。尝试用<e
浏览 7
提问于2022-12-02
得票数 0
1
回答
Spring
Kafka
消费
已被
消费
者
消费
的
旧消息
spring-boot
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我有一个
Spring
启动应用程序,
使用
的
是
Spring
Kafka
。我们已经创建了一个
消费
者,它
使用
来自
4个
主题
的
消息。这些
主题
没有任何分区。我在这里面临
的
问题是rendom行为,在三个
主题
中,在任何一个
主题
中,offset stop和我
的
消费
者一次又一次地
消费
来自
该
浏览 17
提问于2020-04-27
得票数 1
1
回答
Spring
Kafka
JDBC连接器兼容性
spring-boot
、
spring-kafka
、
apache-kafka-connect
、
confluent-platform
Kafka
JDBC connect兼容
Spring
-
Kafka
库吗? 我确实关注了,但仍然有一些困惑。
浏览 4
提问于2020-07-04
得票数 0
2
回答
如何
在
spring
boot测试中禁用
kafka
连接?
spring-boot
、
spring-test
、
spring-kafka
我
使用
spring
kafka
消费
来自
kafka
主题
的
消息,所以我有一个
kafka
消费
者配置类: @Configuration //
kafka
consumer configurations } 我有一些JUnit测试,会用mockMvc加载
spring
上下文来测试我
的
API,我不想测试与
浏览 115
提问于2019-08-29
得票数 1
2
回答
春云流-卡夫卡不尊重一个群体
的
单一
消费
者
apache-kafka
、
spring-cloud-stream
我用
的
是春云流卡夫卡。我正在启动两个具有相同组名
的
消费
者应用程序实例( testGroup ),
使用
来自
具有单个分区
的
Kafka
主题
testTopic
的
消息,我期望其中一个
消费
者实例
使用
来自
Kafka
主题
的
消息,而另一个实例不
使用
任何东西我正在
使用
0.8.xx版本
的
K
浏览 6
提问于2016-11-15
得票数 0
2
回答
为一个
kafka
主题
创建多个
消费
者
java
、
apache-kafka
我有一个
spring
boot应用程序。我希望实现一个从
Kafka
主题
消费
的
函数,对于每个
消费
的
消息,它调用另一个方法对消息进行一些处理,然后将其存储在数据库中。源
kafka
主题
有12个分区。我想在同一个
消费
群体下创建6到12个
kafka
消费
者。所有的
消费
者都将
消费
来自
Kafka
的
消息并调用该
浏览 1
提问于2020-02-19
得票数 1
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
spring
.clou
浏览 4
提问于2019-01-12
得票数 0
1
回答
Kafka
未连接到下面的问题
java
、
spring
、
spring-boot
、
apache-kafka
、
kafka-consumer-api
=localhost:9092
spring
.
kafka
.consumer.auto-offset-reset=earliest
spring
.
kafka
.consumer.key-deserializer=org.apache.
kafka
.common.serialization.StringDeserializer
spring
.
kafka
.consume
浏览 7
提问于2021-09-09
得票数 1
3
回答
在
spring
-cloud-stream
kafka
绑定器中接受二进制json消息
的
属性是什么
spring-boot
、
apache-kafka
、
spring-cloud-stream
我正在
使用
spring
-cloud-stream
kafka
绑定器来
消费
来自
kafka
主题
的
消息。源系统正在以ascii发送json消息。当我
的
消费
者听到它抛出
的
主题
时 o.s.c.s.b.k.KafkaMessageChannelBinder : Could not convert message: 7B22736..或者有没有我可以研究
的
例子?
浏览 0
提问于2017-03-08
得票数 1
1
回答
使用
spring
-
kafka
在一天中
的
特定时间
消费
主题
spring-boot
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我们需要在一天中
的
特定时间
消费
来自
特定
主题
的
数据,我们希望我们
的
kafka
侦听器仅在一天中
的
该时间为特定
主题
工作。正在阅读
Kafka
Scheduler https://jaceklaskowski.gitbooks.io/apache-
kafka
/
kafka
-KafkaScheduler.html
的
文章 欢迎
使用<
浏览 72
提问于2019-10-18
得票数 0
回答已采纳
1
回答
Spring
Kafka
@KafkaListener -重试发送失败消息并手动提交偏移量
spring-boot
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我
使用
@KafkaListener来
消费
来自
kafka
主题
,我有一个应用程序逻辑来处理不同
消费
者组中
的
多个
消费
者
的
每个记录。 现在我
的
问题陈述是,-I必须将
使用
的
消息发送到第三方rest端点。我
使用
的
是
spring
kafka
2.2.0。以下是我
的
手动确认配置
spring
浏览 83
提问于2019-02-12
得票数 2
回答已采纳
2
回答
Kafka
Kstream和
Spring
@KafkaListener有什么不同?
apache-kafka
、
spring-kafka
我对
Kafka
和阅读文档有点陌生。卡夫卡办公网站有一个。其中应用程序被绑定到一个
主题
,并且消息一到达就被处理。结果会回发到
主题
或数据库。
Spring
Kafka
注解@KafkaListener具有相同
的
功能。例如,我尝试过。在这里,我们也会监听一个
主题
,并在发布内容时对其进行处理。 所以我很好奇地想知道1.这2个有什么不同?
浏览 5
提问于2018-01-18
得票数 1
1
回答
Spring
Kafka
消费
者线程池
spring
、
spring-boot
、
spring-kafka
我
使用
的
是
Spring
Kafka
Consumer。我已经将并发设置为10,并创建了5个
消费
者(针对5个
主题
)。所以有50个
Spring
Kafka
消费
者线程。我可以为
Kafka
消费
者提供
的
最大线程数是多少?
如何
增加这个线程池
的
大小?我已经看过了
spring
文档,但没有发现任何相关内容。
浏览 84
提问于2021-08-17
得票数 1
回答已采纳
1
回答
带有
Kafka
使用
者
的
Spring
Boot作业调度程序
spring
、
apache-kafka
、
spring-kafka
我正在开发一个POC,在这里我想
使用
来自
Kafka
主题
“用户”
的
消息。要实现这一目标,用户应该先从
Kafka
主题
读取消息,然后在预定
的
时间或cron时间触发
spring
启动调度器,然后开始逐个
使用
卡夫卡
主题
中
的
现有消息,并对这些消息进行处理,当所有消息被消耗时,
kafka
消费
者就应该停止。我尝试了下面的方法来实现这一点,尽管我很难从调度器方法sc
浏览 0
提问于2021-01-07
得票数 2
1
回答
Kafka
多
消费
者监听多个
主题
java
、
spring
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我们正在开发一个应用程序,在该应用程序中,我们希望在
Kafka
中收听多个
主题
。所有
主题
都有一个单独
的
分区。所有的
主题
名称都有一个共同
的
前缀,比如“topicPattern -x”,"test-y“,所以我们可以
使用
spring
。我们想要编写一个
使用
regexp模式监听所有
主题
的
java
spring
使用
者。我们
的
想法是,我们可以运行同一
浏览 2
提问于2018-03-22
得票数 0
1
回答
弹簧云卡夫卡绑定查询
java
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我们有一个需求,当我们
使用
来自
一个
主题
的
消息时,会有一些充实发生,然后我们将消息发布到另一个
主题
。下面是一些事件我正在
使用
活页夹,一切都很好。突然,我们观察到生产者正在向
主题
发送重复
的
信息,然后我们使生产者是幂等
浏览 3
提问于2021-09-28
得票数 0
1
回答
如何
通过
消费
kafka
主题
消息而不是Rest API来创建命令
axon
我
使用
的
是Axon版本(3.3),它在SpringBoot主类中
使用
在我们
的
用例中,命令端微服务需要从
kafka
主题
中挑选消息,而不是将其公开为Rest api。它会将事件存储在事件存储中,然后将其移动到另一个
kafka
主题
,供查询端微服务
消费
。 由于KafkaAutoCOnfiguration被禁用,我不能
浏览 18
提问于2019-07-12
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
译:基于Spring Cloud Stream构建和测试 message-driven 微服务
SpringBoot整合Kafka
Spring WebFlux和Spring Cloud进行响应式微服务开发
4.kafka生产者&消费者
Spring Boot WebFlux框架响应式编程数据实时更新
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券