Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
编辑 Kafka Listener Spring 应用程序以更改阶段/目标
我可以利用另一个运行 Kafka 应用程序 代码库的团队来使用相同的数据 将其加载到我们的新暂存表中 而不是他们的 他们在 Messages 文件夹中有许多不同的 kafka 侦听器适配器 java 文件 每个文件消耗不同类型的数据 每个
ApacheKafka
kafkaconsumerapi
springKafka
使用Spring Cloud Stream Kafka动态更改instanceindex
如同 在运行时更改 spring cloud stream 实例索引 计数 https stackoverflow com questions 37579939 changing spring cloud stream instance i
事务性 Kafka 生产者
我正在尝试让我的卡夫卡生产者具有事务性 我正在发送 10 条消息 如果发生任何错误 则不应向 kafka 发送任何消息 即不发送或全部消息 我正在使用 Spring Boot KafkaTemplate Configuration Enab
ApacheKafka
springKafka
kafkaproducerapi
使用 spring-kafka 2.1.0 和 SpringBoot 1.5.9 的 Kafka Consumer 上的 java.lang.NoSuchMethodError
我正在尝试使用 SpringBoot 1 5 9 和 Spring kafka 2 1 0 设置 Kafka Consumer 然而 当我启动我的应用程序时 我在 Kafka MessagingMessageListenerAdapter
springKafka
Spring Kafka MessageListenerContainer
我看到 spring Kafka 代码 我有一些疑问 如果我们使用 1 个 kafkaListener 和 2 个主题 那么 spring Kafka 将创建一个 MessageListenerContainer 如果我为每个主题使用单独的
ApacheKafka
kafkaconsumerapi
springKafka
如何用 DefaultErrorHandler 替换已弃用的 SeekToCurrentErrorHandler (spring-kafka)?
我正在尝试找到一种方法来使用新的 DefaultErrorHandler 而不是 spring kafka 2 8 1 中已弃用的 SeekToCurrentErrorHandler 以便在出现错误时覆盖重试默认行为 我想 停止 重试过程
Java
Spring
springKafka
如何在 Spring Kafka 中以编程方式设置 Jsonserializer Type Value 方法
所以我无法仅使用 yaml 为 JsonSerializer 配置 JavaType 方法 还不确定原因 但与此同时 我如何以编程方式设置它 我在文档中看到了它的代码 但是该代码到底需要在哪里运行 Spring Kafka JsonDese
Java
springboot
ApacheKafka
springKafka
动态创建消费者spring kafka
我正在创建一个与另一个服务通信的服务 以便识别要收听的 kafka 主题 kafka主题可能有不同的键和值类型 因此 我想为每个配置 主题 键类型 值类型 动态创建不同的 kafka 消费者 其中配置仅在运行时已知 然而在 spring k
ApacheKafka
kafkaconsumerapi
springKafka
在反序列化之前根据标头过滤消息
有时 可以在反序列化之前根据标头值过滤掉消息 使用 spring kafka 是否有针对此场景的任何现有模式 我正在考虑实现类似于 ErrorHandlingDeserializer 除了委托之外还将过滤谓词作为属性 有什么建议么 谢谢 是
springboot
springKafka
无法对 @KafkaListener 带注释的方法进行单元测试
我正在尝试在 Spring 中对 kafka 消费者类进行单元测试 我想知道如果 kafka 消息发送到它的主题 则侦听器方法被正确调用 我的消费者类注释如下 KafkaListener topics kafka topics myTopi
Spring
unittesting
ApacheKafka
springKafka
带有 Kafka 消费者的 Spring Boot 作业调度程序
我正在开发一个 POC 我想使用来自 Kafka 主题 用户 的消息 尝试实现消费者应该从 Kafka 主题读取消息 一旦 spring boot 调度程序在预定时间或 cron 时间触发 那么我们应该开始从 kafka 主题中一一消费现有
Spring
ApacheKafka
springKafka
批量插入成功后更新 Kafka 提交偏移量
我有一个 spring kafka 消费者 它读取记录并将其移交给缓存 计划任务会定期清除缓存中的记录 我想仅在批次成功保存到数据库后更新 COMMIT OFFSET 我尝试将确认对象传递给缓存服务以调用确认方法 如下所示 public c
Java
Spring
ApacheKafka
springKafka
使用 @EmbeddedKafka 时执行 @DirtiesConfig 的正确方法是什么
我们的项目中有一个 小 问题 无法建立与节点 0 的连接 代理可能不可用 测试运行非常非常长的时间 并且该消息每秒至少记录一次 但我发现 如何摆脱它 请继续阅读 如果配置 注释有不正确的地方 请告诉我 版本优先
springboot
springKafka
springkafkatest
处理 Kafka Broker 宕机时的故障
我有一个 Kafka 代理正在运行 消息已成功消费 但我想处理 Kafka 代理在 Kafka 消费者端出现故障的情况 我读过了this https github com spring projects spring kafka issue
Java
Spring
springboot
ApacheKafka
springKafka
何时使用 RecoveryCallback 与 KafkaListenerErrorHandler
我想了解什么时候应该使用 org springframework retry RecoveryCallback 和 org springframework kafka listener KafkaListenerErrorHandler 截
springKafka
动态启动和关闭 KafkaListener 只是为了在会话开始时加载以前的消息
我有一个让 kafkalistener 从头开始 读取消息的工作代码 offset 0 一个主题 始终运行 对于我的用例 消息传递 我需要两件事 始终捕获特定主题 分区的新消息 该消费者始终在运行 并发送到前端 websocket stom
springboot
ApacheKafka
Messaging
springKafka
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
1
2
3
4
5
»