腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
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
2
回答
在
Spring
Kafka
中
,
我
是否需
要在
应用程序
中
添加
@
EnableKafka
注释
?
java
、
spring-boot
、
apache-kafka
、
spring-kafka
我
看到一些人将@
EnableKafka
添加
到他们
的
spring
boot
应用程序
中
,
我
想知道为什么。
我
有一个可以正常工作
的
spring
boot
kafka
生产者和消费者,
我
没有
使用
@
EnableKafka
。那么,为什么人们需要明确地
添加
它呢? 谢谢。
浏览 181
提问于2020-04-17
得票数 16
回答已采纳
1
回答
在
发送avro消息时获取异常,异常是注册Avro模式
的
org.apache.
kafka
.common.errors.SerializationException:错误:
java
、
spring-boot
、
avro
、
spring-cloud-stream
、
confluent-schema-registry
我
正在
使用
spring
云流并试图发布avro消息,但是得到了上述异常,
spring
.cloud.stream.bindings.feed-output-channel.
producer
.useNativeEncoding=headers['
kafka
_messageKey']
spring
.cloud.stream.
kafka
.bindings.feed-output-channel.
p
浏览 14
提问于2022-01-21
得票数 0
回答已采纳
1
回答
Spring
Reactive
kafka
接收器总是覆盖引导服务器到本地主机
spring-boot
、
apache-kafka
、
spring-data
、
project-reactor
、
spring-kafka
我
正在尝试
使用
@
EnableKafka
和@KafkaListener
注释
为反应式
Kafka
消费者编写
Spring
引导
应用程序
。
我
已经配置了
我
的
kafka
代理
在
不同
的
机器上。
我
已经
在
和non-reactive
spring
kafka
中
验证了没有弹簧配置,对于这两种情况,它都工
浏览 70
提问于2018-06-08
得票数 3
回答已采纳
1
回答
用DeadLetterPublishingRecoverer处理
Spring
错误
spring
、
spring-boot
、
error-handling
、
apache-kafka
、
spring-kafka
我
试图
在
Spring
kafa
中
实现错误处理。
在
我
的
Kafka
侦听器
中
,
我
抛出一个运行时异常,如下所示:application.properties
浏览 1
提问于2020-04-05
得票数 1
回答已采纳
11
回答
Spring
Kafka
这个类不在受信任
的
包
中
java
、
spring-boot
、
apache-kafka
、
spring-kafka
在库更新之前
的
Spring
/
Kafka
应用程序
中
,
我
使用
以下类org.telegram.telegrambots.api.objects.Update将消息发送到
Kafka
主题。现在
我
使用
以下org.telegram.telegrambots.meta.api.objects.Update。如你所见-他们有不同
的
包裹。
应用程序
重新启动后,
我
遇到以下问
浏览 2
提问于2018-08-04
得票数 36
回答已采纳
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
应用程序
,但无法读取新项目中
的
消息。
我
已经检查了明显
的
参数,包括引导服务器
的
主机名和端口(日志显示它们是可识别
浏览 2
提问于2018-02-07
得票数 0
4
回答
将
kafka
-console-
producer
.sh运行到另一台服务器
apache-kafka
、
kafka-producer-api
我
已经
在
我
的
centos服务器上安装了Apache。
我
只是
想把一条消息写到另一台服务器上
的
一个主题上。因此,安装之后,
我
没有启动动物园管理员或
Kafka
服务器,而
只是
输入以下命令:
我</
浏览 1
提问于2019-04-23
得票数 0
回答已采纳
1
回答
如何为
Kafka
+
Spring
配置`
spring
.json.trusted.packages`?
java
、
spring-boot
、
apache-kafka
、
apache-kafka-streams
有人知道如何为卡夫卡流配置
spring
.json.trusted.packages
吗
?
我
使用
以下配置:@
EnableKafka
public class KafkaStreamsConfig { ));
浏览 10
提问于2022-03-25
得票数 0
回答已采纳
1
回答
Kafka
-如何在springboot yml文件
中
定义用户和密码?
spring-boot
、
apache-kafka
、
sasl
我
已经安装了
kafka
并将用户和密码定义为SASL_PLAINTEXT协议,
我
在
控制台中创建了一些示例,
我
可以向主题发送消息并
使用
它们各自
的
凭据接收这些消息,现在
我
需
要在
我
的
spring
boot
应用程序
中
复制该配置这是
我
的
application.yml文件: server:<em
浏览 144
提问于2019-01-08
得票数 1
回答已采纳
1
回答
如何在消费者
应用程序
中
自动配置kafkaTransactionManager
java
、
spring
、
spring-boot
、
spring-kafka
只有
在
设置了“
Spring
.
kafka
.
Producer
.Transaction-id-前缀”属性时,才会配置kafkaTransactionManager bean。
在
一个只消耗来自主题
的
数据并且没有任何生产者逻辑
的
应用程序
中
,设置这个属性可以获得这个自配置
的
bean
吗
?
我
将在
我
的
消费者
应用程序
中
实现1pc最
浏览 11
提问于2022-04-01
得票数 0
回答已采纳
1
回答
将属性注入到非
spring
托管web
应用程序
中
的
spring
boot自动配置类
java
、
spring
、
spring-boot
、
java-ee-8
我
使用
Spring
Boot创建了一个用作
kafka
客户端
的
库,实际上,库
中
只有一些类,每个类都带有@SpringBootConfiguration和@EnableAutoConfiguration
注释
jar,这个JAR将通过CDI
在
Java EE webapp中
使用
。
我
既有
spring
.
kafka
属性组,也有通过KafkaHandlerConfiguration
中</em
浏览 44
提问于2021-03-31
得票数 0
回答已采纳
3
回答
使用
Avro Schema注册表
的
Kafka
使用
者单元测试失败
java
、
spring-boot
、
junit
、
apache-kafka
、
confluent-schema-registry
我
正在编写一个消费者,它监听
Kafka
主题,并在消息可用时消费消息。
我
通过
在
本地运行
Kafka
来测试逻辑/代码,它工作得很好。
我
在
互联网上尝试了不同
的
选项,但没有找到任何有效
的
方法。
我
甚至不确定
我
的
方法是否正确。请帮帮忙。type":"string" { "name":&qu
浏览 0
提问于2019-08-20
得票数 3
1
回答
码头环境
中
的
Spring
应用属性(map)
spring
、
spring-boot
、
docker
、
spring-kafka
我
想
使用
Docker环境配置
我
的
dockerized引导
应用程序
。该属性是一个映射,
我
在
application.yml
中
配置它,如下所示。
spring
:
producer
: "schema.registry.url": http://schema-registry.com:8081
浏览 2
提问于2021-03-11
得票数 1
回答已采纳
1
回答
Kafka
2.1.0 Java消费者对Scala消费者
java
、
scala
、
apache-kafka
我
想将我
的
团队
的
Kafka
集群从0.10.1.1升级到2.1.0。顺便说一句,卡夫卡
的
官方文件说了以下几句话。请注意,不再维护
的
旧Scala客户端不支持0.11
中
引入
的
消息格式,因此为了避免转换成本(或充分利用一次语义),必须
使用
较新
的
Java客户端。
我
不太理解那句话。目前,我们
的
团队正在
使用
用Scala编写
的
Kafka
浏览 0
提问于2019-01-03
得票数 1
2
回答
如何测试
我
在
春引导服务
中
是否正确配置了ChainedKafkaTransactionManager?
spring
、
spring-boot
、
transactions
、
spring-kafka
我
的
spring
引导服务需要将
kafka
事件从一个主题中删除,进行一些处理(包括用JPA编写数据库),然后生成一些关于新主题
的
事件。无论发生什么情况,
我
都不可能在没有更新数据库
的
情况下发布事件,
如果
有什么问题,
我
希望下一次对
使用
者
的
投票重新尝试该事件。
我
的
处理逻辑(包括db更新)是幂等
的
,所以重试是很好
的
。application
浏览 2
提问于2021-02-02
得票数 1
回答已采纳
1
回答
迁移
spring
引导时找不到Bean参数
java
、
spring
、
spring-boot
我
有以下类来配置
我
的
spring
:public class CompanyTransactionConfiguration { private TransactionTaskRunner transactionTaskRunner; } 问题是,
在
我
将依赖项更改
浏览 0
提问于2019-03-09
得票数 0
回答已采纳
4
回答
带有弹簧引导
的
简单嵌入式
Kafka
测试示例
spring-boot
、
apache-kafka
、
spring-kafka
编辑FYI: 没有显示警告或错误,仅在日志
中
显示来自
Kafka
的
垃圾信息。大多数情况下都有过度配置或过度设计
的</
浏览 2
提问于2018-02-12
得票数 48
回答已采纳
1
回答
属性文件
中
kafka
生产者
的
映射配置失败
apache-kafka
、
spring-integration
、
spring-kafka
我
正在尝试将生产者配置
添加
到我
的
项目中,
使用
Spring
Integration和下面的
Kafka
。既然
我
找不到地方放它,
我
想我应该把它
添加
到我
的
application.properties
中
,放在下面:
spring
.cloud.stream.
kafka
.bindings.output.
producer
.configuration但是,
浏览 4
提问于2019-02-18
得票数 0
1
回答
弹簧启动容器无法连接到
Kafka
容器
docker
、
spring-boot
、
apache-kafka
、
docker-compose
我
试图将microservices
Spring
Boot与
Kafka
结合
使用
,但我
的
Spring
Boot容器无法连接到
Kafka
容器。=
kafka
:9092
spring
.
kafka
.consumer.topic=
kafka
_topic 制片人中
的
appli
浏览 6
提问于2018-01-13
得票数 12
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
“事件驱动架构”Kafka中的模式注册表和模式演化
Consul 初步实现服务注册发现,配置中心,负载均衡
在你的 Java 程序里调用 Kafka 发起数据流
使用 Angular 5.0和Spring Boot 2.0 构建一个基本的 CRUD 应用
译:基于Spring Cloud Stream构建和测试 message-driven 微服务
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券