Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Spring Kafka:轮询新消息,而不是使用“onMessage”通知
我在我的项目中使用 Spring Kafka 因为在基于 Spring 的项目中使用 Kafka 消息似乎是一个自然的选择 要使用消息 我可以利用MessageListener界面 Spring Kafka 在内部负责调用我的onMessa
Spring
ApacheKafka
kafkaconsumerapi
springKafka
如何从环境变量将动态主题名称传递给@KafkaListener(topics)
我正在写一个卡夫卡消费者 我需要将环境变量主题名称传递给 KafkaListener topics 这是我到目前为止所尝试过的 import org springframework beans factory annotation Auto
Java
springboot
kafkaconsumerapi
springKafka
springel
Spring Boot中创建KafkaTemplate的正确方法
我尝试配置阿帕奇卡夫卡 in 弹簧靴应用 我读了这个文档 https docs spring io spring boot docs current reference html boot features messaging html b
Java
Spring
springboot
ApacheKafka
springKafka
嵌入式kafka和testcontainers kafka的区别?
我有简单的 spring boot kafka 监听器 我想测试一下 使用嵌入式 kafka 进行测试 VS 使用测试容器 kafka 进行测试有何缺点 我熟悉测试容器 它提供了完全功能性的kafka 嵌入式kafka相对于容器有什么局限性
springboot
springKafka
Spring Apache Kafka onFailure KafkaTemplate 的回调未因连接错误而触发
我目前正在 Spring Boot 应用程序中对 Apache Kafka 进行大量实验 我当前的目标是编写一个接收一些消息负载的 REST 端点 它将使用 KafkaTemplate 将数据发送到在端口 9092 上运行的本地 Kafka
springboot
ApacheKafka
springKafka
有没有办法从 Kafka 主题获取最后一条消息?
我有一个具有多个分区的 Kafka 主题 我想知道 Java 中是否有一种方法可以获取该主题的最后一条消息 我不关心分区 我只想获取最新消息 我努力了 KafkaListener但它仅在主题更新时才获取消息 如果应用程序打开后没有发布任何内
Java
ApacheKafka
springKafka
无法解码Spring云流DefaultKafkaHeaderMapper中的json类型
我们正在使用 spring cloud stream 并计划升级我们的 Kafka 版本 我们的应用程序使用spring cloud stream 2 0 0 spring kafka 2 1 7 与 apache kafka 服务器1 0
停止 Stream 监听器消费消息
我正在寻找一种方法来停止使用流监听器消费消息 StreamListener MBinding M INPUT public void consumeMessage Message
springboot
springKafka
为Spring Kafka设置authorizationExceptionRetryInterval
任何人都知道如何设置新属性 authorizationExceptionRetryInterval 而无需手动创建 ConcurrentKafkaListenerContainerFactory 我本来想说 Component class
springboot
springKafka
Reactive Kafka:仅一次处理事务
最初通过 api 调用触发 1 Service A produces m1 to topic1 non transactional send 2 Service B consumes topic1 and does some process
ApacheKafka
springKafka
projectreactor
reactivekafka
将 ConsumerRebalanceListener 添加到 ConcurrentKafkaListenerContainerFactory
在 Spring Boot 应用程序中 我使用一个带有 KafkaListener 注释的类作为消息侦听器 我想向我的应用程序添加 ConsumerRebalanceLister 以管理重新平衡时的缓存数据 如何将 ConsumerReba
Java
ApacheKafka
springKafka
如何在reactor-kafka中重试失败的ConsumerRecord
我正在尝试使用reactor kafka来消费消息 其他一切都工作正常 但我想为失败的消息添加重试 2 spring kafka默认已经重试失败记录3次 我想使用reactor kafka实现相同的效果 我使用 spring kafka 作
springKafka
reactor
reactorkafka
如何使用 Spring Kafka 检查 Kafka 是否为空?
当我重新启动应用程序时 我需要处理 Kafka 中的剩余消息 直到它为空 然后我的应用程序应该继续正常工作 我的问题是如何检查 Kafka 主题是否为空 我正在使用 Spring Kafka Set the idleEventInterva
ApacheKafka
springKafka
在 Spring Kafka 中结合阻塞和非阻塞重试
我正在尝试通过单个主题固定回退来实现非阻塞重试 感谢文档 我能够做到这一点https docs spring io spring kafka reference html single topic fixed delay retries 现
springKafka
Spring Kafka 中的 Kafka 消费者/生产者测试
我目前正在研究我正在使用的 Kafka 模块spring kafka卡夫卡通信的抽象 我能够从实际实现的角度集成生产者和消费者 但是 我不确定如何测试 特别是集成测试 消费者周围的业务逻辑 KafkaListener 我试着跟随spring
Java
Spring
ApacheKafka
springtest
springKafka
嵌入式Kafka:KTable+KTable leftJoin产生重复记录
我来寻求神秘的知识 首先 我有两对主题 每对中的一个主题融入另一个主题 后面的主题形成两个KTable 用于KTable KTable leftJoin 问题是 当我向任一 KTable 生成一条记录时 leftJoin 会生成三个记录 我
如何为 Kubernetes 中托管的多个应用程序选择 Kafka 事务 ID?
我有一个经典的微服务架构 所以 有不同的应用 每个应用程序可能有1 N实例 该系统部署到Kubernetes 所以 我们有很多不同PODs 可以随时启动和停止 我想实施读 处理 写模式 所以我需要 Kafka 事务 要配置交易 我需要设置一
Java
Kubernetes
ApacheKafka
springKafka
kafkaproducerapi
具有相同 GroupId 的多个 Kafka 监听器都接收消息
我在 Spring Boot 应用程序中配置了一个 kafka 监听器 如下所示 KafkaListener topicPartitions TopicPartition topic data all partitions 0 1 2 gr
Java
Spring
springboot
ApacheKafka
springKafka
无法从 JSON 进行转换;意外字符('f'(代码 102)):在(字符串)“5f19a7e99933db43cb23e83d”处需要用空格分隔根级别值
KafkaListener id ProductTopicConstants GET PRODUCT topics ProductTopicConstants GET PRODUCT SendTo public Product GetPro
Java
Spring
springboot
springKafka
如何在Spring-kafka中实现ConsumerSeekAware?
我正在尝试使用 KafkaListener 实现消费者 我正在使用Spring2 3 7版本 这是到目前为止我的代码 public class SampleListener KafkaListener topics test topic c
Spring
kafkaconsumerapi
springKafka
«
1
2
3
4
5
6
»