腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
为一个
kafka
主题
创建
多个
消费者
java
、
apache-kafka
我有一个
spring
boot应用程序。我希望实现一个从
Kafka
主题
消费的函数,对于每个消费的消息,它调用另一个方法对消息进行一些处理,然后将其存储在数据库中。源
kafka
主题
有12个分区。我想在同一个消费群体下
创建
6到12个
kafka
消费者。所有的消费者都将消费来自
Kafka
的消息并调用该函数。我不能得到一个好的设计。有人能帮帮我吗?
浏览 1
提问于2020-02-19
得票数 1
1
回答
如何在
Spring
中提供特定的
主题
属性?
spring
、
spring-boot
、
apache-kafka
、
spring-kafka
在我的应用程序中,我
使用
的是
Spring
Kafka
,并且有
多个
consumers在
使用
一个单独的topic。下面是我想添加的一些属性:
spring
.
kafka
.consumer.auto-offset-reset=latest
spring
.
kafka
.consumer.key-deserializer=<Deseri
浏览 2
提问于2022-09-29
得票数 0
回答已采纳
2
回答
使用
spring
创建
多个
kafka
主题
java
、
spring-boot
、
apache-kafka
我正在
创建
一个
spring
-boot应用程序,它将
创建
多个
主题
。我从一个.csv文件中获取了
主题
名称和配置的列表。我正在尝试这段代码,但它只能
创建
一个
主题
,但
使用
它
创建
多个
主题
是不可取的。有没有办法用
spring
创建
多个
主题
?
浏览 47
提问于2019-06-26
得票数 1
1
回答
Kafka
版本:3.0.1-
Kafka
管理客户端反复
创建
-内存泄漏
spring-boot
、
apache-kafka
、
out-of-memory
、
spring-kafka
、
spring-cloud-stream
我们有一个跳转应用程序,它从一个
主题
消耗,并生成记录到
多个
主题
。 org.apache.
kafka
:
kafka
-clients:3.0.1 org.springf
浏览 17
提问于2022-08-18
得票数 0
1
回答
Kafka
多消费者监听
多个
主题
java
、
spring
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我们正在开发一个应用程序,在该应用程序中,我们希望在
Kafka
中收听
多个
主题
。所有
主题
都有一个单独的分区。所有的
主题
名称都有一个共同的前缀,比如“topicPattern -x”,"test-y“,所以我们可以
使用
spring
。我们想要编写一个
使用
regexp模式监听所有
主题
的java
spring
使用
者。我们的想法是,我们可以运行同一消费者(属于同一组)的
多个
实例,<e
浏览 2
提问于2018-03-22
得票数 0
2
回答
是否有为特定
主题
而不是所有
主题
配置num stream线程的选项?
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
在我们的应用程序中,我们有
多个
主题
,其中一些
主题
将
使用
16个分区
创建
,而一些
主题
将
使用
1个分区
创建
。有没有什么
spring
.cloud.stream.
kafka
.bindings属性/选项可以实现这一点?
浏览 0
提问于2020-02-27
得票数 1
3
回答
spring
boot
kafka
中基于消费者记录密钥的多消费者
java
、
apache-kafka
、
spring-kafka
我想根据消费者记录密钥列出
kafka
主题
。//do some processing //do some processing有没有可能有
多个
消费者根据密钥收听同一个话题
浏览 4
提问于2020-01-09
得票数 0
2
回答
春云流和消费
多个
卡夫卡
主题
spring
、
spring-boot
、
apache-kafka
、
spring-integration
在尝试
使用
一个@StreamListener中的
多个
主题
时,我遇到了一个
spring
引导流的问题。根据春云流文档:确认到文档: 绑定中间件上通道的目标目的地(例如,RabbitMQ exchange或
Kafka
主题
)。如果信道绑定为
使用
者,则可以将其绑定到
多个
目的地,并且可以将目标名称指定为逗号分隔的字符串值。如果未设置,则
使用
通道名称。不能重写此>属性的默认值。但是,在我
使用
了next config之
浏览 4
提问于2017-06-18
得票数 5
回答已采纳
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-
Kafka
集成中动态订阅
kafka
主题
浏览 0
提问于2017-01-08
得票数 11
2
回答
kafka
分区是否可以分布在
多个
kafka
集群节点上?
java
、
spring-boot
、
apache-kafka
、
confluent-platform
、
kafka-cluster
我的应用程序在
Spring
.
kafka
.boot-server属性中指定了
kafka
集群节点列表,并侦听所有这些节点上的
主题
。如果我要在其中一个节点上
创建
一个
主题
,假设有5个分区,这些分区是分散在这些
多个
节点上,还是在单个节点上
创建
?此外,如何才能发现
主题
分区实际存在于哪个节点上?
浏览 4
提问于2020-06-18
得票数 2
回答已采纳
1
回答
Spring
Kafka
管理客户端
多个
引导服务器带安全性的
Kafka
(jass_config)
java
、
spring-boot
、
apache-kafka
、
spring-kafka
、
spring-cloud-stream
如何从具有安全性的微服务( Admin MS)连接到
多个
引导服务器(DEV、STAGE和PROD)?我想连接到所有的
kafka
服务器并
创建
/管理
主题
,
创建
all等。我正在
使用
spring
kafka
adminclient,并
使用
spring
boot从application.yml配置属性来连接到开发人员。但现在我想要连接到所有环境。有没有一种更简单更好的方法,那就是
创建
一个属性hash
浏览 0
提问于2019-10-20
得票数 0
1
回答
仅
使用
spring
cloud stream
kafka
streams绑定器自动
创建
生产者
主题
apache-kafka-streams
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
是否可以在application.yml中仅为应用程序生成的
主题
启用
spring
.cloud.stream.
kafka
.streams.binder.auto-create-topics,而不是自动
创建
应用程序
使用
的
主题
我希望我的制作人只负责
创建
主题
。我正在
使用
spring
-cloud-stream和
kafka
-streams绑定器。 在更一般的意义上,这是
创建
kafka<
浏览 30
提问于2020-11-24
得票数 0
回答已采纳
1
回答
使用
spring
云流向错误通道发送错误消息
spring-integration
、
spring-cloud-stream
、
spring-kafka
我正在
使用
spring
-cloud-stream:1.3.0开发
spring
启动应用程序。messages,
spring
-cloud-stream-binder-
kafka
:1.3.0.RELEASE.我
使用
spring
集成dsl来拆分文件中的行,并
使用
beanio将行转换为json,要求将成功的json消息写入
kafka
主题
,并将错误消息写入不同的
kafka
主题
。当出现&quo
浏览 2
提问于2017-10-19
得票数 1
1
回答
Spring
-
Kafka
将ConcurrentKafkaListenerContainerFactory用于
多个
@Kafkalistener
java
、
spring-boot
、
apache-kafka
、
spring-kafka
我正在
使用
Spring
-
Kafka
框架实现来自
Kafka
主题
的消息消费。我正在尝试理解我为我的卡夫卡监听器
创建
的ConcurrentKafkaListenerContainerFactory的一些用法。@KafkaListener运行良好,但不出所料,在我的场景中,我有
多个
独立的侦听器,分别侦听
多个
主题
。我想知道我是否可以在我所有的监听器中重用ConcurrentKafkaListenerContainerFactory,或者我必须为
浏览 187
提问于2020-04-26
得票数 1
回答已采纳
1
回答
Spring
Cloud
kafka
Stream -如何对同一频道
使用
两个不同的
kafka
集群?
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
、
spring-kafka
我们有一个场景,我们希望在cluster#1上消费来自
kafka
主题
的数据,但在cluster#2上
创建
KTable
主题
(重新分区和changelog)。: true
spring
.cloud.stream.
kafka
.streams.bindings.member.consumer.keySerde: org.apache.
kafka</e
浏览 4
提问于2019-01-12
得票数 0
1
回答
KafkaListener听几个
主题
的行为
apache-kafka
、
kafka-consumer-api
、
spring-kafka
,包含来自两个
主题
的记录还是只包含一个
主题
?默认的
主题
分配策略是什么?如果它是范围,并且我将并发设置为4,并且
主题
的分区数目不一样,那么是否可能有些线程空闲或未被充分
使用
?
浏览 2
提问于2022-10-12
得票数 0
1
回答
用
spring
管理
Kafka
主题
java
、
spring-boot
、
apache-kafka
、
rabbitmq
、
spring-kafka
我们计划在我们的应用程序中
使用
Kafka
进行排队。我在RabbitMQ和
Spring
方面有一些经验。或者,我们是否应该编写一个单独的脚本来帮助
创建
主题
?维护一个单独的脚本来<e
浏览 3
提问于2018-06-18
得票数 10
回答已采纳
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
主题
?
java
、
spring-boot
、
ssl
、
apache-kafka
我有
多个
生产者将消息推送到我的
kafka
代理中。我想保护我的
主题
,这样生产者需要密码才能在
主题
中推送消息或任何形式的保护。#
spring
.cloud.stream.
kafka
.binder.configuration.[ssl.truststore
浏览 0
提问于2020-08-22
得票数 2
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
使用Spring Boot和Kotlin创建RESTfull API
Spring Boot与Kotlin使用Spring Data Rest创建HAL风格Restful接口
Spring for Apache Kafka 3.0和Spring for RabbitMQ 3.0发布
SpringBoot整合Kafka
SpringBoot Kafka 整合使用
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券