腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
有
没有
办法在spring中
记录
所有传入
的
kafka
请求?
spring-boot
、
apache-kafka
、
spring-kafka
我
使用
简单
的
kafka
处理
程序: @
KafkaListener
( clientIdPrefix =
KafkaHandler
.LISTENER_ID)public class
KafkaHandler
{ @
KafkaHandler
Desc
浏览 7
提问于2021-10-15
得票数 0
1
回答
如何
使用
记录
值
没有
@
KafkaHandler
的
类
级
@
KafkaListener
处理
Kafka
记录
apache-kafka
、
spring-kafka
通常,当我们定义
类
级别的@
KafkaListener
和方法级别的@
KafkaHandler
时,我们可以定义一个默认
的
@
KafkaHandler
来
处理
意外
的
有效负载。https://docs.spring.io/spring-
kafka
/docs/current/reference/html/#class-level-
kafkalistener
但是,如果我
浏览 98
提问于2021-01-29
得票数 1
回答已采纳
1
回答
kafka
消息
的
多个实现(java泛型)
java
、
spring-boot
、
apache-kafka
、
spring-kafka
我试图根据事件
的
类型为
kafka
事件创建多个实现
类
。public class
KafkaListener
{ Service service; @
KafkaListener
(topics = ("mytopic
浏览 0
提问于2019-12-09
得票数 0
回答已采纳
2
回答
多个
KafkaListener
类
可以监听同一主题吗?
spring-kafka
我有包含多个事件(不同类型)
的
kafka
主题,我想在单个应用程序中在不同
的
处理
程序
类
中
处理
这些事件。所以我
的
问题是-我是否可以创建两个
使用
相同主题
的
类
(spring组件),但每个
类
处理
不同
的
事件(来自同一主题)?@Componentpublic class
浏览 168
提问于2020-01-14
得票数 0
回答已采纳
1
回答
用Spring从同一个
Kafka
主题反序列化不同
的
JSON有效载荷
java
、
json
、
spring-boot
、
apache-kafka
、
spring-kafka
我试图从同一个
Kafka
主题反序列化不同
的
JSON有效负载。这里提出
的
其他问题,引导我进行了第一次尝试,但我无法使它运行。正如加里提到
的
(),有一些提示(JsonSerializer.ADD_TYPE_INFO_HEADERS),但是当我发送和接收这两条消息时,我会得到一个异常。LoggingErrorHandler已经在ConsumerRecord中提到了一个(正确
的
)
值
。factory.setConsumerFactory(consumerFactoryMessageWithAddi
浏览 0
提问于2019-01-24
得票数 5
回答已采纳
1
回答
在Spring中,
没有
匹配
的
侦听器
的
消息会发生什么?
spring-kafka
我对@
KafkaListener
的
理解是,消息是通过匹配侦听器方法
的
参数类型和消息类型来
使用
的
。
没有
匹配侦听器
的
消息会发生什么情况?
浏览 0
提问于2019-08-28
得票数 0
回答已采纳
2
回答
@有效@Payload关于@
KafkaHandler
- bug还是缺少功能?
spring
、
spring-boot
、
spring-kafka
我们
使用
Spring和Spring (所有最新版本)一起
使用
。我们将对
Kafka
消息
的
处理
转换为@
KafkaHandler
注释
的
方法,并期望@Valid/@Validated与@Payload一起确保有效负载验证,但这
没有
发生。此功能适用于@
KafkaListener
,如果它也适用于@
KafkaHandler
public cla
浏览 4
提问于2021-01-09
得票数 0
回答已采纳
1
回答
禁用特定Spring Boot测试
的
Kafka
侦听器
java
、
spring
、
spring-boot
、
apache-kafka
、
spring-kafka
如何
在Spring Boot (2.2+)和Spring
Kafka
(2.4+)应用程序
的
@SpringBootTest测试中禁用@
KafkaListener
实例?目标是在特定测试中禁用
Kafka
侦听器,以便在不启动嵌入式
Kafka
代理
的
情况下运行此类测试。
浏览 39
提问于2020-01-25
得票数 3
回答已采纳
1
回答
使用
VALUE_TYPE_METHOD
的
弹簧卡夫卡
spring-boot
、
spring-kafka
TL/DR -有人能提供一个
使用
JsonDeserializer.VALUE_TYPE_METHOD
的
简单例子吗?如果数据是由不
使用
序列化程序
的
应用程序发布
的
,并且需要根据数据或其他标头将数据反序列化为不同
的
类型,则会非常有用。将这些属性设置为方法名称--一个完全限定
的
类
名,后面跟着方法名,由句点分隔。我
的
配置如下所示:
kafka
: bootst
浏览 9
提问于2022-10-04
得票数 0
1
回答
spring
kafka
:同一主题下不同
的
json负载
java
、
spring
、
apache-kafka
、
spring-integration
、
spring-kafka
我需要在相同
的
Kafka
主题上发送不同
的
JSON有效负载(例如,Foo,Bar,Car ...)不
使用
父
类
static class MultiListenerBean {
浏览 0
提问于2017-10-25
得票数 1
1
回答
使用
@
KafkaListener
处理
错误
java
、
spring
、
spring-kafka
我正在
使用
具有以下配置
的
spring-
kafka
: import com.fasterxml.jackson.databind.ObjectMapper
的
测试和参考文档,文档说应该配置适当类型
的
ErrorHandler,这个暗示我应该在ContainerProperties上配置它,尽管这只是一个错误
处理
程序,在我
的
用例中,我想定义多个(针对不同有效负载类型另外,有
没有
浏览 1
提问于2017-03-25
得票数 5
回答已采纳
2
回答
在spring boot中接收
Kafka
密钥
kafka
监听器
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我是新来
的
春天卡夫卡。我有一个微服务,它发送消息与
kafka
密钥,这是一个用户定义
的
对象。假设消息是由密钥myKey发送
的
。我想在监听程序中创建一个新
的
扩展密钥,如下所示: @
KafkaListene
浏览 1
提问于2019-09-26
得票数 2
2
回答
Spring MessageConversionException未能解析未找到
的
类
名
类
spring
、
spring-boot
、
apache-kafka
、
json-deserialization
、
spring-kafka
的
一个对象 containerFactory = "kafkaListen
浏览 0
提问于2019-02-14
得票数 12
回答已采纳
2
回答
在同一
Kafka
主题中监听多种类型
的
对象
java
、
spring-boot
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我面临
的
问题是,所有的对象都指向同一个侦听器。第二个监听程序未被
使用
。我
的
监听器与下面类似@Servicepublic class MyConsumerConfig { p
浏览 27
提问于2021-03-10
得票数 0
1
回答
如何
在@
KafkaHandler
中
使用
EntityManager/Hibernate事务
java
、
spring-boot
、
hibernate
、
apache-kafka
、
spring-kafka
假设我有一个@
KafkaListener
类
,其中包含一个@
KafkaHandler
方法,它
处理
接收到
的
任何消息并执行一些DB操作。我希望对
如何
和何时提交(或回滚)数据库更改(即手动管理DB事务)进行细粒度控制。无论DB事务结果
如何
,都可以提交所
使用
的
消息偏移量。以下是我所拥有的一个简化版本:@RequiredArgsConstructor topics =
浏览 11
提问于2021-12-23
得票数 0
回答已采纳
1
回答
使用
Spring
Kafka
自定义Apache
Kafka
头
的
转换
java
、
spring-boot
、
apache-kafka
、
spring-kafka
我在我
的
KafkaListener
中
使用
Spring Boot 2.3.0和Spring
Kafka
2.5.0,我试图将MessageHeaders映射到一个自定义
类
。下面的代码可以工作,但给了我byte[]中
的
头,然后我必须将其转换为侦听器中
的
类
(并对每个侦听器重复此操作),这是我希望避免
的
。@Slf4j @
KafkaListener
(topics = {"${sp
浏览 20
提问于2020-07-26
得票数 0
1
回答
@
KafkaHandler
收到罚款,但不发送答复@SendTo。出什么问题了?
java
、
spring-boot
、
spring-kafka
所以,我在课堂上有一个卡夫卡听众
的
课。它有两个
处理
程序方法,这两个方法都应该对在消息头中发送
的
回复主题发回答复。我们对消息
使用
AVRO模式,并启用了特定
的
读取。看起来是这样
的
:@Slf4j id = "kvk_listener", topics = {"${
kafka
.topic.request.search两个
处理
程
浏览 3
提问于2020-06-25
得票数 0
回答已采纳
1
回答
用Spring从单个主题反序列化不同消息(
使用
共享数据)
java
、
spring
、
apache-kafka
TL;博士
如何
使用
@
KafkaListener
和@
KafkaHandler
根据属性将一个主题映射到不同
的
处理
程序,映射到具体
的
对象?我有一个单一
的
主题,其中包含不同
的
信息。消息
的
格式为{type: 2, data2:"bar"} 我最好通过这样
的
单一侦听器来
使用
它们。正确地映射了具
浏览 7
提问于2021-10-13
得票数 0
1
回答
Spring-
Kafka
@
KafkaHandler
不
使用
各自
的
java对象
java
、
spring-boot
、
apache-kafka
、
spring-kafka
我可以通过@
KafkaListener
(在
类
级别上)
使用
特定
的
Java对象,但是,当我尝试
使用
来自同一主题
的
多个不同
的
JSON对象(在
类
级别
使用
@
KafkaListener
,在方法级别
使用
@
KafkaHandler
如何
使用
单一@
KafkaListener
与单个主题
使用
不同
的
JSON对象。Co
浏览 4
提问于2020-04-24
得票数 2
回答已采纳
1
回答
Spring
Kafka
监听器方法-
记录
输入
记录
logging
、
spring-kafka
我
使用
的
是spring-
kafka
,我
的
@
KafkaListener
方法有一个用@org.springframework.messaging.handler.annotation.Payload注释
的
参数,如下所示:public void consumeTrigger(@Payload InputDTO InputDTO) {...输入是json格式
的
,
浏览 18
提问于2020-05-08
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
“Spring和Kafka”Kafka整合Spring 深入挖掘-第1部分
SpringBoot整合Kafka中间件,下篇
Spark踩坑记:Spark Streaming+kafka应用及调优
初探Kafka Streams
如何将kafka中的数据快速导入Hadoop?
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券