腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
使
Kafka
主题
从
spring
boot
自动
创建
spring-boot
、
apache-kafka
我的
Spring
boot
项目有4个模块,我需要使用
Kafka
在模块之间建立通信。我在我的电脑上安装了
Kafka
,并使用cmd
创建
了
主题
。问题是,在我提交我的项目后,除非我的老师在他的计算机上
创建
了相同的
主题
(根据我所理解的),否则
主题
将不起作用。 有没有办法确保我的项目
自动
创建
主题
?
浏览 244
提问于2021-10-14
得票数 0
回答已采纳
1
回答
Spring
Cloud Stream
Kafka
复制因子和运行时保留问题
apache-kafka
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
、
retention
、
replication-factor
我有一个使用
Kafka
的
spring
boot
项目。我配置了
Spring
Cloud Stream
Kafka
自动
配置。我想
创建
我的
主题
自动
与3个副本和1天的保留。为此,我在application.yml中添加了复制因子和retention.ms,如下所示: cloud:
kafka
:
浏览 10
提问于2021-03-11
得票数 0
回答已采纳
1
回答
为什么卡夫卡最初
从
KafkaAdminClient中获取引导服务器?
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我在consumerFactory和producerFactory bean中使用
Spring
。我知道我可以使用
spring
自动
配置。但我采用了这种方法。在这种方法中,我使用死信
主题
作为错误处理程序。当我使用autoCreateTopics = "true"和启动应用程序时,它首先尝试
从
KafkaAdminClient捕获配置。由于我在MSK中使用的是引导服务器,当
kafka
试图连接到本地主机时,它会产生断开连接的错误,只在几秒钟后,它将记录ConsumerConfi
浏览 6
提问于2022-08-25
得票数 0
回答已采纳
2
回答
向
Kafka
发送关于动态
创建
的
主题
的消息时出现错误LEADER_NOT_AVAILABLE
java
、
spring
、
spring-boot
、
spring-kafka
我正在尝试使用以下代码在动态
创建
的
主题
上发送消息:public class KafkaMessageSender { private static final Logger当我使用topic = 'somethingnew‘调用这个send方法时,我得到了下面的error,(有趣的是它可以发送一些消息,但对于很多人来说,它会给出错误,一段时间后,它也会开始发送关于这些
主题
的消息
kafka
中有没有潜在的bug?我使用的是
spring
boot
版本: 1
浏览 12
提问于2018-02-13
得票数 3
回答已采纳
2
回答
在
Spring
Kafka
中,我是否需要在应用程序中添加@EnableKafka注释?
java
、
spring-boot
、
apache-kafka
、
spring-kafka
我看到一些人将@EnableKafka添加到他们的
spring
boot
应用程序中,我想知道为什么。我有一个可以正常工作的
spring
boot
kafka
生产者和消费者,我没有使用@EnableKafka。那么,为什么人们需要明确地添加它呢? 谢谢。
浏览 181
提问于2020-04-17
得票数 16
回答已采纳
1
回答
如何在
spring
boot
中定期读取Mongodb采集数据并发布到
kafka
topic
mongodb
、
spring-boot
、
spring-batch
、
spring-kafka
我需要定期读取mongo DB表数据,并使用
spring
boot
将其发布到
Kafka
主题
中。我在Mongo DB中
创建
了一个集合,并在Mongo DB中插入了一些记录。此外,我希望定期
从
Mongo DB读取数据,并需要使用
spring
boot
在
Kafka
的
主题
中发布这些表数据。我是
spring
batch scheduler的新手。
浏览 22
提问于2020-10-02
得票数 0
1
回答
如何将
Spring
Cloud Stream Functional Bean接入
Kafka
Binder?
java
、
spring
、
spring-boot
、
spring-boot-cloud-streams
我正在使用
Spring
Cloud Streams Documentation来尝试解决如何通过Gradle中已经下载的绑定器将我的微服务连接到
Kafka
。我已经尝试在我的
Spring
Boot
Application类中
创建
一个简单的@Bean Function<String, String>()方法,并且已经验证了它能够通过使用命令行与uppercase-in-0和uppercase-out-0
主题
交互来与
Kafka
对话,正如确认应用程序能够与
K
浏览 43
提问于2020-03-25
得票数 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
1
回答
我们如何手动重置通过
spring
boot
java应用程序使用的
kafka
主题
的偏移量?
java
、
spring-boot
、
apache-kafka
、
kafka-consumer-api
我的要求是,当应用程序无法处理
从
通过
spring
boot
java应用程序使用的
kafka
主题
的当前偏移量读取的消息时,重置
kafka
主题
的偏移量。在手动重置偏移量或发送否定确认之后,需要通过
spring
boot
java应用程序的
kafka
消费者再次从不合适的偏移量值轮询消息。它能实现吗?
浏览 3
提问于2019-01-09
得票数 1
2
回答
Spring
Boot
测试如何关闭`@EnableKafka`?
java
、
spring
、
spring-boot
、
spring-kafka
、
spring-boot-test
我想运行我的集成测试,但我不知道如何禁用@EnableKafka。 我的应用程序是这样的: @SpringBootApplicationpublic class MyApplication {
浏览 199
提问于2019-10-18
得票数 1
回答已采纳
1
回答
@ConditionalOnBean(KafkaTemplate.class)
使
整个应用程序崩溃
java
、
spring
、
spring-boot
、
apache-kafka
、
spring-annotations
我有一个
Spring
boot
应用程序,它使用来自
Kafka
主题
的数据并用
从
Kafka
接收的数据发送电子邮件通知,public EmailService emailService() {我找不到任何解释,这是如何可能的,因为KafkaTemplate bean是由
Spring
在KafkaAutoConfiguration类中
自动
创建
的。 你能给我解释一下吗?
浏览 4
提问于2021-08-11
得票数 1
1
回答
初始化SpringBoot应用程序时出错。我有一个SpringBoot应用。2.1.5.RELEASE使用Kakfa
spring
、
spring-boot
、
spring-mvc
、
apache-kafka
2.1.5.RELEASE使用
Spring
for Apache
Kafka
(基于
Kafka
的消息传递解决方案),使用IntelliJ IDEA我
创建
了这个服务: at org.springframework.
boot
.SpringApplication.refresh</groupId>
浏览 38
提问于2019-11-06
得票数 0
回答已采纳
1
回答
卡夫卡DLT处理毒丸的春云流
spring-kafka
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
spring
-
boot
2.5.2
spring
-cloud Hoxton.SR12
spring
-
kafka
2.6.7 (因发行而降级:) )我将上面提到的菜谱中提到的group: a-custom-group destination: some-destination.2
kafka
spring
.deserializer.value.delegat
浏览 5
提问于2021-07-11
得票数 0
回答已采纳
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</em
浏览 7
提问于2019-05-15
得票数 0
回答已采纳
2
回答
Spring
的“配置”和“
自动
配置”有什么区别?
spring
、
spring-boot
用@Configuration而不是@AutoConfiguration注解的类不那么
自动
或什么的?
浏览 19
提问于2022-10-18
得票数 1
回答已采纳
2
回答
Spring
Cloud Streams -以下方法不存在
spring-boot
、
gradle
、
apache-kafka
、
spring-cloud-stream
我们目前正在尝试
创建
一个SCS应用程序,该应用程序可以生成特定的
主题
消息,但是在运行该应用程序时,我们遇到了错误: The following method did not exist: org.springframework.
kafka
.core.DefaultKafkaProducerFactory.setBeanName我们认为
spring
-
boot
和SCS之间存在兼容性问题。我们使用的是
spring
-
boot
版本: 2.2.2-RELEASE他已经将我
浏览 109
提问于2020-07-22
得票数 1
回答已采纳
2
回答
springboot如何集成Ckafka,必须使用
kafka
-client吗?
kafka
浏览 222
提问于2023-02-27
1
回答
用属性文件处理
Spring
Kafka
中的错误?
java
、
spring
、
apache-kafka
、
spring-kafka
spring
.
kafka
.consumer.properties.
spring
.deserializer.value.delegate.class=io.confluent.
kafka
.serializers.KafkaAvroDeserializer
spring
.
kafka
.consumer.properties.
spring
.deserializer.key.delegate.class=org.apache.
kafka
.common.serial
浏览 21
提问于2021-01-07
得票数 0
回答已采纳
1
回答
spring
-
kafka
:在
Spring
Boot
中使用交互式查询
spring-boot
、
apache-kafka-streams
、
spring-kafka
在
Kafka
Streams +
Spring
Boot
应用程序中配置(提供主机和端口信息)和访问交互式查询的惯用方式是什么? 访问KafkaStreams实例以访问状态存储的正确方法是什么?我知道
spring
-cloud-stream中有InteractiveQueriesService,但我并不是只在
Spring
Boot
中使用
spring
-
kafka
库。 谢谢
浏览 11
提问于2020-10-17
得票数 1
回答已采纳
1
回答
使用
Spring
Boot
的多线程事务性
Kafka
生产者和消费者
multithreading
、
spring-boot
、
apache-kafka
、
spring-kafka
、
spring-transactions
我有一个项目,其中使用
Spring
Boot
相关项目。我想在项目中使用
Kafka
的消费者和生产者的事务功能。我需要尽可能高效地在
Kafka
中产生大量的消息。如何使用
Spring
boot
开发多线程消费者和生产者?
浏览 81
提问于2020-10-14
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
日记:Mac上kafka单机搭建和监控工具kafka eagle
Spring文档翻译系列(一)
Spring Boot 正式支持Java 17,Kafka3.0弃用Java8
为什么越来越多的开发者选择使用Spring Boot
深入浅出,了解 Spring 框架和 Spring Boot 的历史
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券