apache-kafka
-
-
KafkaConsumer Java API subscribe() vs assign() 我是Kafka Java API的新手,我正在努力使用来自特定Kafka主题的记录。 我知道我可以使用方法从主题开始轮询记录。Kafka还提供了方法,如果我想从主题的选定分区开始轮询记录。 我想知道这是否
-
Kafka 流用于添加全局存储的用例 在 kafka 流中定义拓扑时,可以添加全局状态存储。它将需要一个源主题以及一个 .处理器接收记录,并可以在将它们添加到存储之前从理论上转换它们。但在还原的情况下,记录直接从源主题(c
-
消费者在 Apache Kafka 中消费消息的延迟 我正在使用Kafka 0.8.0并尝试实现下面提到的场景。 JCA API(充当生产者并向其发送数据)-----> Consumer------> HBase 一旦我使用JCA客户端获取数据,我就将每条消息发送给消费者。例如,一旦生产者
-
Kafka 使用者异常和偏移量提交 我一直在尝试为Spring Kafka做一些POC工作。具体来说,我想尝试在Kafka中使用消息时处理错误的最佳实践。 我想知道是否有人能够帮助: 分享有关 Kafka 消费者在发生故障时应执行的操作的最佳
-
Dead Letter queue (DLQ) for Kafka with spring-kafka 在 Spring Boot 2.0 应用程序中实现死信队列 (DLQ) 概念的最佳方法是什么,使用 spring-kafka 2.1.x 将所有失败的消息发送到 @KafkaListener某个预定义的 Kafka DLQ 主题,而不会丢失单个消息? 所以消耗的
-
KAFKA:60000 毫秒后无法更新元数据 我是KAFKA的新手,我知道这个问题已经在堆栈溢出中被问过多次,但没有一个解决方案对我有用,所以在这里我尝试运气再次提出同样的问题。我已经在 Centos7 VM 上下载并安装了 KFKA。VM 位于我的
-
春季卡夫卡 - 如何使用组ID将偏移量重置为最新? 我目前正在使用Spring Integration Kafka进行实时统计。但是,组名使Kafka搜索侦听器未读取的所有先前值。 我想开始最新的偏移量,而不是被旧值所困扰。是否可以重置组的偏移量?
-
-
春季卡夫卡集成测试写入高水位线文件时出错 我正在使用spring-kaka-2.2.0在spring boot应用程序中编写集成测试,我几乎成功了,我的测试用例仍然返回true,但之后我仍然看到多个错误。
标签