腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(1599)
视频
沙龙
1
回答
我想通过注释启用
Kafka
错误处理。
spring-boot
、
spring-kafka
我试图通过注释实现
spring
错误处理。我还向我的设置添加了反序列化错误处理程序。
spring
.
kafka
.consumer.value-deserializer=org.springframework.
kafka
.support.serializer.ErrorHandli
浏览 8
提问于2020-03-05
得票数 0
回答已采纳
1
回答
Spring
Kafka
:
将
KafkaListenerErrorHandler
应用于
所有
KafkaListener
java
、
spring
、
apache-kafka
、
error-handling
、
spring-kafka
我想截获我的@
KafkaListener
抛出的验证错误(MethodArgumentNotValidException)。implements
KafkaListenerErrorHandler
{ public Object handleError(Message<?KafkaListenerEndpointRegistrar registrar) { } } 当我
将
这个处理程序直接放到我
浏览 465
提问于2021-02-03
得票数 0
回答已采纳
1
回答
弹簧卡夫卡与弹簧集成
java
、
spring-integration
、
spring-kafka
我不知道我是否遗漏了一些显而易见的东西,或者
spring
-integration-
kafka
:3.0.1中存在一个bug,因为它试图让多个消费者运行某个主题。这个场景是一个只包含10个分区的
Kafka
主题,以及一个听它的springboot应用程序。相关配置是:
spring
: consumer: auto-offset-resetGot message {} on {}&q
浏览 1
提问于2018-05-08
得票数 3
回答已采纳
2
回答
在
KafkaListener
注释中使用多个主题名称
apache-kafka
、
spring-kafka
下面有一个类似的问题: 如何
将
属性文件中的主题名称作为字符串数组获得?
浏览 1
提问于2017-07-17
得票数 1
回答已采纳
2
回答
如何在
Spring
Kafka
中关闭offsets提交,以便在本地存储offsets?
apache-kafka
、
spring-kafka
我想使用
Spring
Kafka
将
事件处理到本地数据库中,并将偏移量存储在数据库本身中,如“在
Kafka
之外存储偏移量”下的https://
kafka
.apache.org/25/javadoc/index.htmlorg/apache/
kafka
/clients/consumer/KafkaConsumer.html中所述。
Spring
Kafka
(
浏览 46
提问于2020-07-03
得票数 1
回答已采纳
1
回答
kafka
向
所有
具有相同group.id的消费者发送消息
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
、
spring-kafka
默认情况下,
Kafka
会将来自某个主题的消息发送到
所有
消费者组。 在我的例子中,我有一些需要重新调整的微服务。假设我们每一个都有三个实例。 我有一个服务,它为每个微服务提供必要的数据。我需要找到一种方法
将
数据发送到每个微服务的
所有
实例。这是必需元数据。 我不知道如何获得此行为,也不能更改group.id,因为这样服务将使用相同的消息两次。
浏览 71
提问于2019-01-14
得票数 1
1
回答
基于
kafka
的弹簧引导分布式处理
java
、
apache-camel
、
spring-integration
在启动时,我会使用一些配置
将
输入和输出连接到真正的
kafka
主题队列。例如,一个应用程序的输入A可以来自多个
kafka
主题队列,而来自同一应用程序的输出B可以转到其他一对
kafka
主题队列。
spring
集成可以做到这一点吗?阿帕奇骆驼?还是我最好自己写?
浏览 6
提问于2018-01-09
得票数 1
回答已采纳
1
回答
启动
Spring
Boot应用程序而不检查
Kafka
服务器
spring
、
spring-boot
、
apache-kafka
我有一个应用程序,它使用2.10.0版本中的SpringBoot 2.10.0 version和
kafka
。这个应用程序有一个简单的生产者和消费者:发送者使用KafkaTemplate,消费者使用
KafkaListener
。目前,如果没有正在运行的KafkaBroker,应用程序
将
无法启动,并显示以下错误消息: org.springframework.context.ApplicationContextException:Failed to start bean 'org.springframework.
kafka</em
浏览 216
提问于2019-01-25
得票数 2
2
回答
Kafka
Kstream和
Spring
@
KafkaListener
有什么不同?
apache-kafka
、
spring-kafka
我对
Kafka
和阅读文档有点陌生。卡夫卡办公网站有一个。其中应用程序被绑定到一个主题,并且消息一到达就被处理。结果会回发到主题或数据库。
Spring
Kafka
注解@
KafkaListener
具有相同的功能。例如,我尝试过。在这里,我们也会监听一个主题,并在发布内容时对其进行处理。 所以我很好奇地想知道1.这2个有什么不同?
浏览 5
提问于2018-01-18
得票数 1
1
回答
泉.卡夫卡.消费者.自动偏移复位在春季是如何工作的--卡夫卡
java
、
spring
、
apache-kafka
、
kafka-producer-api
、
spring-kafka
=foo在这种情况下,对
所有
条目调用@
KafkaListener
方法。但预期的结果是,只对我发送的最新3个选项调用@
KafkaListener
方法。", "foo1"); th
浏览 5
提问于2017-10-16
得票数 4
1
回答
spring
-
kafka
如何在流bean上设置重试
spring-kafka
、
spring-retry
我看到
spring
-
kafka
使用@RetryableTopic支持非阻塞Retries。我只看到@RetryableTopic正在和@
kafkaListener
一起工作。如何在
spring
-
kafka
之前做到这一点?假设一笔银行交易是这样的:
将
10美元从帐户10001转移到帐户10002。
浏览 2
提问于2021-05-03
得票数 0
2
回答
何时使用RecoveryCallback与
KafkaListenerErrorHandler
spring-kafka
我想弄清楚什么时候应该使用org.springframework.
kafka
.listener.
KafkaListenerErrorHandler
?为了向DLT发送消息,我使用了
Spring
,然后遇到了
KafkaListenerErrorHandler
和DeadLetterPublishingRecoverer。现在,请你给我建议一下,我该如何使用
KafkaListenerErrorHandler
和DeadLetterPublishingRecoverer?这能取代RecoveryCallback吗?
浏览 5
提问于2019-10-28
得票数 4
回答已采纳
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
回答
如何在
Kafka
poll()方法中使用@EventListener?
java
、
events
、
apache-kafka
、
spring-kafka
将有一个事件来自卡夫卡从其他一些应用程序,我想听这个事件使用春季事件。这些事件是通过卡夫卡传递的,但我如何才能听到这个事件呢?String name;`示例:@EventListener public void handleEvent(){ <KafkaEvent>.poll() }我不知道该如何在@EventListener方法中调用轮询
浏览 3
提问于2022-11-05
得票数 0
1
回答
与阿帕奇的KafkaConsumer相比,使用
Spring
的
KafkaListener
有什么优势?
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我知道KafkaConsumer是Apache的
Kafka
库中的一个客户端,它是可按需轮询的,因此处于一个无限循环中,它会根据时间间隔发出心跳。
KafkaListener
是一个
应用于
方法的注释,
Spring
Kafka
将
调用它来处理消息。 也就是说,我不确定这两种方法的设计优点/缺点是什么。
浏览 53
提问于2021-11-08
得票数 0
2
回答
Spring
KafkaListener
:如何知道何时准备就绪
spring
、
spring-boot
、
apache-kafka
、
spring-kafka
、
spring-kafka-test
我有一个简单的
Spring
Boot应用程序,它从
Kafka
读取和写入
Kafka
。我使用EmbeddedKafka编写了一个SpringBootTest来测试
所有
这些。主要问题是:有时测试会失败,因为测试过早地发送了
Kafka
消息。这样,在
Spring
应用程序(或者更准确地说,是它的
KafkaListener
)准备就绪之前,消息就已经写入了
Kafka
。由于侦听器从latest偏移量读取(我不想更改测试的任何配置-bootstrap.servers除外
浏览 0
提问于2019-04-11
得票数 8
1
回答
在Java客户端库中实现
Kafka
java
、
apache-kafka
一种方法是想要使用这个api的后端应用程序在他的应用程序中有
Kafka
监听器,另一个在我脑海中出现的想法是,如果我不能在我的客户端库中构建一个kakfa listner怎么办。这么做是个好主意吗?假设
Kafka
配置将出现在将要使用我的客户端库的后端应用程序中?
浏览 1
提问于2022-12-02
得票数 -1
1
回答
Spring
Reactive
kafka
接收器总是覆盖引导服务器到本地主机
spring-boot
、
apache-kafka
、
spring-data
、
project-reactor
、
spring-kafka
我正在尝试使用@EnableKafka和@
KafkaListener
注释为反应式
Kafka
消费者编写
Spring
引导应用程序。我已经配置了我的
kafka
代理在不同的机器上。当我
将
bootstrap-server提供给播发的
kafka
代理主机时,它总是覆盖播发给localhost的主机ip地址。下面是我的代码。我们可以在
Spring
boot中将EnableKafka和
KafkaListener
注解与Reactor
Kafka
一起使用吗
浏览 70
提问于2018-06-08
得票数 3
回答已采纳
1
回答
春天卡夫卡-试图了解事情如何在幕后运作。
java
、
spring
、
spring-kafka
我有一个带有@
KafkaListener
注释的方法public void listen(String message) {System.out.println("Received Message: " + message); 当我不设置并发属性时,
Spring
是否会创建一个使用者实例,一个
kafka
侦听器容器,属于在使用者工厂中指定的组如果我
将
并发性更改为3,那么
spring</em
浏览 5
提问于2018-01-14
得票数 3
回答已采纳
2
回答
不使用@
Kafkalistener
的
Spring
引导用户
spring-boot
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
我试图在不使用@
Kafkalistener
的情况下编写
kafka
使用者,下面是我用于配置侦听器的代码行: @EnableKafka private String bootstrapServers;HashMap<>(); // list of host:port pairs us
浏览 0
提问于2018-07-13
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
“Spring和Kafka”Kafka整合Spring 深入挖掘-第1部分
Kafka消息队列学习进阶(二)-项目实战
Kafka消息队列学习进阶(四)-优化(配置/代码/集群
Spring for Apache Kafka 3.0和Spring for RabbitMQ 3.0发布
Spring Cloud Stream简介
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券