腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
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
Reactive
kafka
接收器总是覆盖引导服务器到本地主机
spring-boot
、
apache-kafka
、
spring-data
、
project-reactor
、
spring-kafka
我
正在尝试使用@
EnableKafka
和@KafkaListener
注释
为反应式
Kafka
消费者编写
Spring
引导
应用程序
。
我
已经配置了
我
的
kafka
代理
在
不同的机器上。
我
已经
在
和non-reactive
spring
kafka
中
验证了没有弹簧配置,对于这两种情况,它都工作得很好。只有带有
EnableKafka</e
浏览 70
提问于2018-06-08
得票数 3
回答已采纳
1
回答
spring
-
kafka
- SSL
中
的测试
spring
、
spring-kafka
您好,
我
正在尝试使用
spring
-
kafka
-test来测试
我
的测试
中
的嵌入式
kafka
。致以问候。
浏览 0
提问于2019-09-27
得票数 0
2
回答
Spring
Boot无法消费
Kafka
消息
spring-boot
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我们有一个使用org.apache.
kafka
.clients.consumer.KafkaConsumer使用
Kafka
消息的Java
应用程序
我们已经创建了一个具有
Spring
-
Kafka
依赖项的
Spring
Boot
应用程序
,但无法读取新项目中的消息。
我
已经检查了明显的参数,包括引导服务器的主机名和端口(日志显示它们是可识别的)、组、主题以及
Spring
Boot,就像最初的使用者一样,使用StringDeserializer。下
浏览 2
提问于2018-02-07
得票数 0
1
回答
在
Spring
Kafka
中
,如果
我
只是使用producer,
我
需
要在
我
的
应用程序
中
添加
@
EnableKafka
注释
吗?
spring-kafka
根据我对以下文档的理解,消费者/侦听器可能需要@
EnableKafka
注释
。https://docs.
spring
.io/
spring
-
kafka
/api/org/springframework/
kafka
/annotation/
EnableKafka
.html 这
是否
意味着,此
注释
适用于消费者的上下文,而不是生产者的上下文?
浏览 22
提问于2021-11-09
得票数 0
1
回答
禁用@KafkaListener的最佳方法
spring-boot
、
apache-kafka
、
spring-kafka
我
的
应用程序
包含几个@KafkaListeners。当我
在
本地运行
应用程序
或运行一些@SpringBootTests (没有卡夫卡)时,
我
的日志被污染了。org.apache.
kafka
.clients.NetworkClient -消费客户端= Consumer app -1,groupId=app引导代理本地主机:9092 (id:-1齿条: null) @Kafka
浏览 5
提问于2022-08-03
得票数 0
回答已采纳
2
回答
SpringBoot
Kafka
:未加载“KafkaAutoConfiguration”
中
的Bean方法“kafkaTemplate”
spring
、
spring-boot
、
spring-mvc
、
apache-kafka
、
spring-kafka
我
正在使用springboot并尝试编写一个KafkaProducer来推送
Kafka
队列
中
的消息。
我
在
@Configuration类
中
创建了这些方法。另外,如果
我
试图
在
我
的
Spring
项目中排除KafkaAutoConfiguration,我会得到类似"Bean不能被加载,因为KafkaAutoConfiguration被禁用了“这样的错误。编辑:-
我
在
我</e
浏览 3
提问于2020-09-09
得票数 0
1
回答
有人尝试称这种方法为
spring
kafka
。
spring-boot
、
apache-kafka
、
spring-kafka
我
在
把弹簧卡夫卡和弹簧靴整合在一起有点麻烦。
我
使用SpringBootv2.1和
Spring
-Kafkav2.2(根据矩阵应该兼容)。
我
见过许多类似的问题,但没有一个能解决
我
的问题。/2.2.0.RELEASE/
spring
-
kafka
-2.2.0.RELEASE.jar!pom
中
的依赖: <groupId>org.springframework.
k
浏览 2
提问于2022-06-28
得票数 0
1
回答
如何在application.properties -
Spring
流
中
设置默认键/值-serde
java
、
spring-boot
、
apache-kafka
、
apache-kafka-streams
、
spring-kafka
我
正在制作一个
应用程序
(不是
Spring
)
spring
.
kafka
.streams.application-id=streams-app
spring
.
kafka
.streams.bootstrap-servers=localhost但在application.properties
中
,
我
不知道如何设置这些属性。此外,自动完成也不存在。简单地说,
是否</em
浏览 6
提问于2022-07-21
得票数 1
回答已采纳
1
回答
如何使用
Kafka
DSL对
Spring
Cloud Stream进行单元测试
spring-cloud-stream
我
正在尝试(单元)测试使用
Kafka
DSL的
Spring
Cloud Stream
Kafka
处理器,但收到以下错误"Connection to node -1 could not be established
我
同时尝试了EmbeddedKafka和TestBinder,但我仍然有相同的行为。
我
尝试从开始(它可以工作),并且
我
调整了
应用程序
以使用
Kafka
DSL,并且几乎保留了测试类的原样。Cloud Stream通用语
浏览 68
提问于2018-06-01
得票数 4
回答已采纳
2
回答
在
spring
-
kafka
中
禁用连接和消费者创建
java
、
spring
、
apache-kafka
、
spring-kafka
我
已经编写了一个简单的
kafka
配置和消费者类,如下所示:@Service * This consumerStringDeserializer.class); }现在需要注意的是,
我
需
要在
dev环境
中
禁用它。
我
尝试禁用KafkaConfigur
浏览 42
提问于2019-08-12
得票数 1
2
回答
与
Kafka
自动配置问题的
Spring
集成
spring
、
spring-boot
、
apache-kafka
、
spring-integration
我
正在尝试配置一个
Spring
应用程序
来使用
Kafka
消息。
在
添加
:<dependency></depe
浏览 9
提问于2017-03-09
得票数 1
回答已采纳
8
回答
如何使用@Value
Spring
注解注入Map?
java
、
spring
、
dependency-injection
、
annotations
、
spring-annotations
如何使用
Spring
中
的@Value
注释
将值从属性文件中注入到Map
中
?
我
的
Spring
类是,
我
尝试使用$,但是得到了以下错误消息: @Configuratio
浏览 5
提问于2015-06-07
得票数 95
回答已采纳
1
回答
生成对
Kafka
测试容器的请求后验证存储库状态
java
、
spring-boot
、
apache-kafka
、
testcontainers
我
正在使用
Kafka
和Postgres测试容器创建一个集成测试,例如:@SpringBootTest@
EnableKafka
我
已经确认一切都是正确处理的,即该请求由
Kafka
接收,并由
应用程序
异步处理并插入数据
浏览 2
提问于2022-09-28
得票数 0
1
回答
KafkaMessageListenerContainer vs ConcurrentMessageListenerContainer
java
、
spring
、
apache-kafka
、
messaging
注意,
我
没有显式地定义任何bean,
我
将所需的bean创建留给了
spring
boot。
我
想知道
我
的理解
是否
正确。
我
希望并行地使用来自有多个分区的主题的消息,比如3。那么,如果
我
在
application.yml文件
中
配置它,如下所示就可以了。
我
已经尝试了下面的配置,并看到创建了3个消费者。
spring
: consumer:
浏览 39
提问于2019-10-08
得票数 2
回答已采纳
2
回答
Spring
Boot
Kafka
Consumer未消费,
Kafka
Listener未触发
java
、
spring-boot
、
apache-kafka
、
spring-kafka
我
正在尝试构建一个简单的
spring
boot
Kafka
Consumer来消费来自
kafka
主题的消息,但是没有消息被消费,因为KafkaListener方法没有被触发。:
spring
-
kafka
:${SpringKafkaVersion}"import org.springframewo
浏览 517
提问于2020-01-07
得票数 1
1
回答
用DeadLetterPublishingRecoverer处理
Spring
错误
spring
、
spring-boot
、
error-handling
、
apache-kafka
、
spring-kafka
我
试图
在
Spring
kafa
中
实现错误处理。
在
我
的
Kafka
侦听器
中
,
我
抛出一个运行时异常,如下所示:
spri
浏览 1
提问于2020-04-05
得票数 1
回答已采纳
1
回答
使用事务时不调用
Kafka
ConsumerInterceptor onCommit
spring-boot
、
kotlin
、
apache-kafka
、
spring-kafka
我
在
Spring
应用程序
中使用
Spring
。
我
试图使用卡夫卡ConsumerInterceptor拦截时,偏移是提交的。下面的最小示例一切都如预期的那样工作:@
EnableKafka
@KafkaListener(topics:
kafka
: enable-auto-commit:
浏览 6
提问于2022-10-13
得票数 2
回答已采纳
2
回答
Spring
引导:不包括一些自动配置的bean
spring-boot
、
spring-kafka
我
想让这个项目成为一个可重用的库,跨越一组
Spring
引导
应用程序
。但是,当我从一个
spring
引导
应用程序
向这个库
添加
依赖项时,
在
应用程序
启动时会出现一个错误:
我
所需要的只是重用org.springfra
浏览 8
提问于2017-04-26
得票数 2
回答已采纳
1
回答
Spring
Boot上
Spring
集成的
Kafka
配置
spring-boot
、
spring-integration
、
spring-kafka
我
有一个可以工作的
Spring
Boot
应用程序
原型,它监听
Kafka
队列。除了application.yml
中
的配置之外,所需要的只是一个用@KafkaListener
注释
的MessageListener实现。
我
现在介绍
Spring
Integration,并为此配置了以下bean:public KafkaMessageDrivenChannelAdapter<String, String> adapter
在</em
浏览 5
提问于2018-02-20
得票数 4
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
译:基于Spring Cloud Stream构建和测试 message-driven 微服务
Spring Cloud Stream简单入门
使用 Angular 5.0和Spring Boot 2.0 构建一个基本的 CRUD 应用
Spring和SpringBoot比较,解惑区别
SpringBoot 2.0 系列(三):流程详解(下)
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券