Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
无法使用传入消息调用侦听器方法,并且 ConsumerRecord 的 Backoff 未耗尽
下面是我的 kafka 侦听器的方法定义 如果有效负载接收到 null 或空字符串 我想我会遇到以下错误 您能帮忙吗 KafkaListener topics kafka consumer topic name reservation gr
springboot
ApacheKafka
springKafka
使用KafkaListener时,如何检查主题消息是否已读完?
使用 KafkaListener时 如何检查主题消息是否已读完 See 这个答案 https stackoverflow com questions 55430893 how to check if kafka is empty using
springboot
ApacheKafka
springKafka
Kafka 事务失败但仍提交偏移量
我正在尝试了解 Kafka 事务和一次性事务 我创建了一个事务消费者 我想确保我读取并处理某个主题的所有消息 如果事务失败并且消息因此丢失 Kafka 仍会提交偏移量 更正式地说 如果流处理应用程序消费消息 A 并生成消息 B 使得 B F
Java
Spring
Transactions
ApacheKafka
springKafka
无法从外部机器连接到kafka
我从 Apache Kafka 开始 当我尝试从外部机器连接时遇到问题 使用下面的配置 如果应用程序和 docker 在同一台机器上运行 则一切正常 但是当我将应用程序放入机器 A 并将 docker 放入机器 B 时 应用程序无法连接 我
Spring
Docker
ApacheKafka
springKafka
@SentTo 如何将消息发送到相关主题?
我在 Rest 控制器中使用 ReplyingKafkaTemplate 来返回同步响应 我还设置了标头 REPLY TOPIC 对于监听器微服务部分 KafkaListener topics kafka topic request top
ApacheKafka
kafkaconsumerapi
kafkaproducerapi
springKafka
我们可以在 Spring Boot 中使用多个 kafka 模板吗?
在我的 spring boot kafka 发布者应用程序中 我想提供对以 String json 或字节格式发布消息的支持 因为我想同时提供对 json 和 avro 的支持 但是 Spring Boot 中的 Kafka 模板让我们只定
ApacheKafka
springKafka
kafkaproducerapi
Spring boot:排除一些自动配置的bean
我有一个使用 spring kafka 的 Spring boot 项目 在这个项目中 我构建了一些包装 spring kafka beans 的事件驱动组件 即 KafkaTemplate 和 ConcurrentKafkaListene
springboot
springKafka
如何配置 spring-kafka 忽略格式错误的消息?
我们的 Kafka 主题之一存在问题 该主题被DefaultKafkaConsumerFactory ConcurrentMessageListenerContainer组合描述here http docs spring io spring
errorhandling
ApacheKafka
springKafka
如何决定spring kafka设置的并发数?
我正在使用 KafkaListener 注释编写一个 kafka 消费者 我知道有一种方法可以使用 ConcurrentKafkaListenerContainerFactory 中的方法增加来自不同分区的并发 kafka 消费者的数量 e
ApacheKafka
kafkaconsumerapi
springKafka
Kafka 更新元数据失败
我正在使用 Kafka v0 10 1 1弹簧启动 我正在尝试在 Kafka 主题中生成一条消息mobile user使用以下生产者代码 Topic mobile user有 5 个分区和 2 个复制因子 我已附上我的问题末尾的Kafka设
Java
ApacheKafka
kafkaconsumerapi
kafkaproducerapi
springKafka
如何配置 Spring Boot Kafka 客户端使其不尝试连接
这与Spring Boot Kafka 客户端有 断路器 吗 https stackoverflow com q 69914621 2886891 但我仍然认为这是一个不同的问题 我们需要配置 Spring Boot Kafka 客户端 以
Java
springboot
configuration
apachekafkastreams
springKafka
根据异常类型调用ContainerStoppingErrorHandler
我使用的是 spring kafka 版本 2 2 4 Release 和 Kafka 版本 2 11 我在用容器停止错误处理程序作为我的错误处理程序 每当出现异常时 就会调用此方法并停止容器 现在 我需要根据异常类型停止容器 如果发生某些
springboot
ApacheKafka
springKafka
启用 @KafkaListener 从 application.yml 文件中获取变量主题名称
我正在尝试将多个主题加载到一个主题中 KafkaListener但我遇到了麻烦 因为我相信它正在寻找一个恒定值 但正在初始化topics变量来自application yml文件导致出现问题 我想知道是否有人可以帮助我解决这个问题 或者为我
springboot
springKafka
配置 Spring Kafka 以使用 DeadLetterPublishingRecoverer
我正在使用 Spring Boot 2 1 3 并尝试配置 SpringSeekToCurrentErrorHandler with a DeadLetterPublishingRecoverer将错误记录发送到不同的主题 创建新的 DLT
springKafka
Spring Integration Kafka 与 Spring Kafka
我们正在尝试在工作者 Spring 应用程序和消费者 Spring 应用程序之间实现消息通道 同一消费者在多个 JVM 上会有副本 使用 Java 配置 Spring 集成的文档有限 我能够找到 Spring Kafka 的文档 我不太确定
Java
Spring
springintegration
springKafka
升级到 kafka-streams:5.5.0-css (Apache Kafka 2.5.0) 后获取 GlobalKTable 的存储崩溃 [已解决]
我有一个使用 GlobalKTable 的 Spring Boot 应用程序 它工作正常 直到从 5 3 2 css 更新到 kafka streams 5 5 0 css 与 Apache Kafka 2 5 0 兼容的 Confluen
Java
Spring
ApacheKafka
apachekafkastreams
springKafka
Kafka消费者动态拾取主题
我在 Spring Boot 中配置了一个 Kafka 消费者 这是配置类 EnableKafka Configuration PropertySource classpath kafka properties public class K
springboot
configuration
kafkaconsumerapi
springKafka
使用 Spring Kafka 添加自定义标头
我计划使用 Spring Kafka 客户端在 Spring Boot 应用程序中使用 kafka 设置并生成消息 我看到 Kafka 0 11 中对自定义标头的支持详情here https issues apache org jira b
Spring
ApacheKafka
springKafka
SpringBootTest
Spring Kafka 错误处理 - v1.1.x
如何处理错误处理春天卡夫卡 questions tagged spring kafka版本1 1 x 据我所知 它是在版本中引入的2 0 https github com spring projects spring kafka blob
errorhandling
ApacheKafka
springKafka
Spring Boot中事务同步与Database+kafka示例
我想使用 Spring boot 编写一个新应用程序 使用 MySQL Mango 数据库和 Spring Kafka 进行消息传递 我尝试使用 Many POC 来同步 Kafka 和 DB 之间的事务 但在某些情况下失败了 并且我还搜索
springboot
SpringDataJPA
springKafka
«
1
2
3
4
5
6
»