腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Spring
Kafka
:
按
顺序
阅读
两个
不同
的
主题
java
、
apache-kafka
、
spring-kafka
Spring
Kafka
是否有可能在保证
顺序
的
情况下从
不同
的
消费者中读取
两个
不同
的
主题
?例如,
主题
A存储与确定如何处理存储在
主题
B中
的
数据相关
的
信息。
主题
A被读取到内存中并被引用,但在从
主题
B读取数据之前需要完全填充
主题
A。下面是我当前设置
的
示例...code here th
浏览 2
提问于2020-01-22
得票数 0
回答已采纳
2
回答
2个
kafka
用户从2个具有
不同
SSL配置
的
不同
主题
进行
阅读
java
、
apache-kafka
、
spring-cloud-stream
、
spring-kafka
我正在写一个
Spring
启动应用程序,它将从2个
不同
的
主题
消费,并处理消息。这
两个
主题
托管在
不同
的
集群上,具有
不同
的
SSL配置。我想创建2个
不同
的
消费者来
阅读
主题
。我使用
的
是
Spring
-cloud-stream和
kafka
-stream。有什么关于如何为这个场景设置application.p
浏览 27
提问于2019-04-01
得票数 0
回答已采纳
1
回答
如何保证debezium生成
的
topic事件
顺序
,存储在
kafka
中并发送给spark?
apache-spark
、
apache-kafka
、
debezium
、
change-data-capture
我使用debezium捕获所有更改并将其发送给
kafka
。后来,我读取了Spark
的
所有信息,并使用jdbc将其发送到Apache Phoenix。我正在使用debezium和一个重路由选项,它只将所有表
的
更改发送到一个
kafka
主题
。有了这个配置,我确信我可以
按
顺序
阅读
spark中独特
的
kafka
主题
。但我
的
问题是:如果我使用debezium而没有重新路由选项,并且我在
不
浏览 96
提问于2019-05-03
得票数 0
1
回答
Spring
KafkaTestUtils:等到
主题
中
的
消息被消耗时
java
、
spring-boot
、
integration-testing
、
spring-boot-test
、
spring-kafka-test
所以,我遇到了有趣
的
情况:我找到了一些小麻烦,如何避免它--线程睡眠等等。但我相信这是个糟糕
的
解决方案。作为Kaf
浏览 3
提问于2021-11-23
得票数 0
回答已采纳
1
回答
Spring
Kafka
和多分区轮询策略
apache-kafka
、
spring-kafka
假设我有一个有4个分区
的
主题
。我使用了一个使用@KafkaListener注解
的
spring
kafka
微服务来消费记录。这个微服务是dockerized化
的
,我有它
的
两个
实例。然后将每个实例插入
两个
分区。 我观察到,当我需要赶上延迟时,实例停留在它所在
的
分区上,并让第二个分区累积延迟。然后,当我们停止生成消息,并且第一个分区上
的
延迟完全耗尽时,它才会切换到第二个分区。我
的
应用程序
浏览 31
提问于2020-01-14
得票数 2
回答已采纳
1
回答
Spring
cloud
Kafka
Stream -
不同
集群中
的
死信
主题
kafka-consumer-api
、
spring-kafka
、
spring-cloud-stream
我有一个
Kafka
消费者。如果消费者无法
阅读
任何消息,我需要将其发送到Dead Letter
主题
。我使用
的
是
Spring
cloud
Kafka
流,我在如下配置中启用了DLQ。
spring
: stream: definition: myConsumer binderenvironment:
spring</
浏览 12
提问于2021-02-03
得票数 0
1
回答
我们可以对
不同
的
主题
使用相同
的
容器吗?
apache-kafka
、
spring-kafka
我对
Kafka
有
两个
不同
的
主题
。
两个
主题
中
的
数据类型和数据结构(Json)是相同
的
。我可以为
两个
主题
使用相同
的
侦听器容器吗?我尝试使用,并且我能够从这
两个
主题
中获得使用
的
输出。 下面是我
的
配置。@KafkaListener(id = "#{'${
spring
.
kaf
浏览 23
提问于2021-07-09
得票数 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
spring
.cloud.stream.bindings.
浏览 4
提问于2019-01-12
得票数 0
1
回答
如何按需
阅读
Kafka
主题
消息
spring-boot
、
spring-kafka
如何
阅读
来自
Kafka
topic on demand
的
消息。我有
主题
名称,offsetId,PartitionID,使用这三个参数,我如何从
Kafka
主题
中检索特定
的
消息。可以使用
Spring
Kafka
吗?我使用
的
是
spring
boot 2.2.4.RELEASE
浏览 0
提问于2020-11-10
得票数 0
3
回答
春天-卡夫卡:如何在卡夫卡制片人中插入application.yml
主题
spring
、
apache-kafka
、
spring-kafka
我有一个
spring
-
kafka
微服务,我最近添加了一封死信,以便能够发送各种错误信息。@KafkaListener(topics = "${
spring
.
kafka
.topic.nam
浏览 3
提问于2021-03-03
得票数 1
回答已采纳
1
回答
如何从与
不同
经纪人相关
的
多个
Kafka
主题
中消费?
java
、
spring
、
spring-boot
、
apache-kafka
、
spring-kafka
如何从与
不同
经纪人相关
的
多个
Kafka
主题
中消费? 我有一个
Spring
应用程序,需要使用
两个
主题
,但是
主题
与
不同
的
Brokers相关联。我在@Listener注释中使用
Spring
,我看到了从
两个
主题
中使用
的
方法,这些
主题
与同一个代理相关,而不是
不同
的
代理。不幸
的
是,我在<
浏览 4
提问于2021-02-19
得票数 1
回答已采纳
1
回答
Kafka
:
不同
主题
的
不同
反序列化器
java
、
spring-boot
、
apache-kafka
、
spring-kafka
目前,我正在使用
Spring
和@KafkaListener注释从
不同
的
Kafka
主题
中获取信息。是否可以在这个新
主题
中使用JsonDeserializer,对遗留
主题
使用KafkaAvroD
浏览 5
提问于2022-10-18
得票数 1
回答已采纳
1
回答
是否可以在启动或编译时在中设置groupId?
java
、
spring
、
spring-boot
、
apache-kafka
我刚开始和
Kafka
一起使用。 我创造了一个制片人和一个消费者。我需要
的
是有
两个
相同
的
消费者(实际上是
两个
微服务),但是使用
不同
的
groupId,所以他们都会
阅读
主题
并得到相同
的
消息。现在,我在
spring
应用程序项目中
的
groupId在properties.yml文件中
的
资源下面,是否可以在编译时将该值设置为参数,或者在启动时设置为更好
的
参数?
浏览 2
提问于2018-07-06
得票数 2
回答已采纳
4
回答
只读
kafka
主题
中
的
特定消息
apache-kafka
、
kafka-consumer-api
、
kafka-python
场景: 我正在将数据JSON对象数据写入
kafka
主题
,而读取时我只想读取基于消息中存在
的
值
的
特定消息集。我使用
的
是
kafka
-python库。completed", value: 1, active: yes} {flow_status:"failure",value 2, active:yes} 在这里,我只想读取flow_Status为已完成
的
消息
浏览 78
提问于2019-02-18
得票数 2
回答已采纳
1
回答
单一的卡夫卡消费者-从多个
主题
中
阅读
-信息消费
的
顺序
是什么?
java
、
apache-kafka
、
kafka-consumer-api
我正在用java编写一个简单
的
Kafka
使用者,它被配置为从多个
主题
中读取。目前,让我们假设
两个
主题
( topic1和
主题
2)和
两个
主题
的
单个分区。卡夫卡消费者从topic1和topic2中
阅读
的
顺序
是什么?如果这
两个
主题
都有,那么假设已经发布了100条消息。假设topic1具有以下按时间
顺序
排列
的
消息( A1
浏览 0
提问于2018-02-06
得票数 1
回答已采纳
1
回答
使用2个
主题
,但只处理一个已启用
的
主题
java
、
apache-kafka
、
spring-kafka
对于我们
的
应用程序,我们将smae消息写入
两个
不同
主题
的
Kafka
Broker,现在在使用者部分,我必须同时使用这
两个
主题
,并且只处理一个在
spring
属性文件中启用
的
主题
。我如何使用
spring
引导和KafkaListner来完成它??
浏览 9
提问于2022-06-16
得票数 0
1
回答
Spring
Kafka
JDBC连接器兼容性
spring-boot
、
spring-kafka
、
apache-kafka-connect
、
confluent-platform
Kafka
JDBC connect兼容
Spring
-
Kafka
库吗? 我确实关注了,但仍然有一些困惑。
浏览 4
提问于2020-07-04
得票数 0
1
回答
Spark Streaming并行处理
不同
DStreams,线性处理一个DStream内
的
作业
apache-spark
、
apache-kafka
我有一个应用程序,需要从
Kafka
队列消费,维护每个
主题
的
批处理
顺序
。我为每个
主题
创建了
不同
的
DStreams。但当我运行它时,每个
主题
都是
按
顺序
使用
的
。如果我设置了"spark.streaming.concurrentJob=4“(n>1),那么
主题
是并行使用
的
,但在同一
主题
批中也是并行处理
的
。(我需要避免)有
浏览 0
提问于2018-10-27
得票数 0
1
回答
如何在
spring
cloud
kafka
活页夹中将偏移量重置为开始
apache-kafka
、
spring-cloud
、
spring-cloud-stream
我正在使用
spring
cloud
kafka
绑定器将数据读取到KStream。在
阅读
其中一个
主题
的
数据时,我需要从头开始
阅读
。添加我使用过
的
application.yaml:
spring
.cloud.stream.bindings.inpu
浏览 11
提问于2018-05-04
得票数 1
2
回答
Kafka
Kstream和
Spring
@KafkaListener有什么
不同
?
apache-kafka
、
spring-kafka
我对
Kafka
和
阅读
文档有点陌生。卡夫卡办公网站有一个。其中应用程序被绑定到一个
主题
,并且消息一到达就被处理。结果会回发到
主题
或数据库。
Spring
Kafka
注解@KafkaListener具有相同
的
功能。例如,我尝试过。在这里,我们也会监听一个
主题
,并在发布内容时对其进行处理。 所以我很好奇地想知道1.这2个有什么
不同
?
浏览 5
提问于2018-01-18
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
SpringBoot整合Kafka
Spring for Apache Kafka 3.0和Spring for RabbitMQ 3.0发布
Spring Cloud Stream简单入门
Kafka与RabbitMQ千万不要乱用…
加米谷大数据:2入门介绍kafka0.10.x
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券