Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Spring Kafka中检测broker断开连接
我正在尝试为我的卡夫卡消费者编写健康检查 当应用程序启动并运行时 我关闭 Kafka 我看到很多 Connection to node 1001 127 0 0 1 9092 could not be established Broker
springKafka
Consumer.endOffsets 在 Kafka 中如何工作?
假设我有一个无限期运行的计时器任务 它会迭代 kafka 集群中的所有消费者组 并输出每个组的所有分区的延迟 提交偏移量和结束偏移量 与 Kafka 控制台消费者组脚本的工作方式类似 只不过它适用于所有组 就像是 单个消费者 不工作 不返回
Java
ApacheKafka
kafkaconsumerapi
springKafka
Spring Kafka 与嵌入式 Kafka 集成测试
我有一个 Spring Boot 应用程序 它有一个消费者从一个集群中的主题消费并生成到不同集群中的另一个主题 现在我正在尝试使用 Spring 嵌入式 Kafka 编写集成测试用例 但遇到了问题KafkaTemplate could no
Java
springboot
ApacheKafka
springKafka
springkafkatest
Kafka应用程序启动时无法配置主题,但稍后可以通信
我们有一个使用 spring kafka 2 2 5 RELEASE 的 Spring Boot 应用程序 在启动时总是出现此错误 Could not configure topics org springframework kafka K
springboot
ApacheKafka
springKafka
当引导服务器关闭时,具有 transactionIdPrefix 的 DefaultKafkaProducerFactory 会无限等待
Hy 我正在使用 spring kafka 1 3 0 RELEASE 创建事务生产者 当引导服务器关闭时 DefaultKafkaProducerFactory 会无休止地等待 直到引导服务器启动 我究竟做错了什么 我可以设置超时和 或其
Java
ApacheKafka
kafkaproducerapi
springKafka
反序列化后如何处理SerializationException
我在 Spring Kafka 设置中使用 Avro 和 Schema 注册表 我想以某种方式处理SerializationException 在反序列化期间可能会抛出该异常 我找到了以下两个资源 https github com spri
serialization
errorhandling
deserialization
springKafka
Spring Kafka 和事务
我想将 Spring Kafka 与事务一起使用 但我不太明白它应该如何配置以及它如何工作 这是我的配置 props put ProducerConfig ENABLE IDEMPOTENCE CONFIG true props put P
Spring
ApacheKafka
springtransactions
springKafka
Spring Boot - 在 application.properties 中获取 Spring-Kafka 客户端 ID 的主机名
我正在使用 Spring Kafka 和 Boot 开发一个项目 并且希望在 application properties 中获取属性 spring kafka consumer client Id 的主机名 以便可以在服务器端日志中区分我
springboot
springKafka
批处理模式下 Kafka headers 作为列表
我试图在以批处理模式消费消息的同时访问一些标头 如果我设置监听器来处理Message data Acknowledgment ack throws SQLException for int i 0 i lt data size Object
ApacheKafka
kafkaconsumerapi
springKafka
Kafka:获取偏移量超出分区范围。如何避免数据丢失?
Fetcher INFO Fetch offset is out of range for partition resetting offset 试图了解发生这种情况时会发生什么 如果我们试图读取的偏移量丢失了 我假设是因为kafka GC
ApacheKafka
springKafka
通过使用 Docker-Compose 和 Spring Boot 运行的 IP 地址访问远程主机中的 Kafka
我有一个 docker compose yml 在其中运行动物园管理员 Kafka 卡夫卡连接 and KafDrop 问题是 当我在本地运行时 我可以从我的春季启动应用程序来消费一些主题消息 我需要的是在 Linux 机器上运行相同的配置
springboot
ApacheKafka
dockercompose
springKafka
spring-kafka AckMode 中的 MANUAL 和 MANUAL_IMMEDIATE 有什么区别
从 spring docs 中 我可以看到 MANUAL 消息监听器负责acknowledge 确认 之后 应用与 BATCH 相同的语义 手动 立即 当侦听器调用 Acknowledgment acknowledge 方法时立即提交偏移量
ApacheKafka
kafkaconsumerapi
springKafka
Spring Cloud Stream Kafka - 方法必须是声明性的
我已经使用 Spring Cloud Stream 配置了一个基于 Spring Boot 的应用程序 我正在尝试处理 KStream 但不断收到错误 java lang IllegalArgumentException 方法必须是声明性的
Spring
springboot
springcloudstream
springKafka
当与 Apache Kafka 服务器的连接丢失时,如何使用 Spring Kafka Listener 停止微服务?
我目前正在实现一个微服务 它从 Apache Kafka 主题读取数据 我对微服务使用 spring boot 版本 1 5 6 RELEASE 对同一微服务中的侦听器使用 spring kafka 版本 1 2 2 RELEASE 这是我
Spring
springboot
ApacheKafka
springKafka
无法使用传入消息调用侦听器方法,并且 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
«
1
2
3
4
5
6
»