apache-kafka - NotEnoughReplicasException : The size of the current ISR Set(2) is insufficient to satisfy the min. isr 要求 3-6ren

apache-kafka - NotEnoughReplicasException : The size of the current ISR Set(2) is insufficient to satisfy the min. isr 要求 3

转载作者：行者123 更新时间：2023-12-02 19:23:06

我有以下设置经纪人:3 - 全部启动并运行 min.insync.replicas=3。

我创建了一个topic，配置如下

bin\windows\kafka-topics --zookeeper 127.0.0.1:2181 --topictopic-ack-all --create --partitions 4 --replication-factor 3

我用“ack = all”触发了生产者，生产者能够发送消息。但是，当我启动消费者时，问题就开始了

bin\windows\kafka-console-consumer --bootstrap-server localhost:9094,localhost:9092 --topic topic-ack-all --from-beginning

错误是

NotEnoughReplicasException: The size of the current ISR Set(2) isinsufficient to satisfy the min.isr requirement of 3NotEnoughReplicasException:The size of thecurrent ISR Set(3) is insufficient to satisfy the min.isr requirementof 3 for partition __con

我在这里看到两种错误。我浏览了文档并且也了解了“min.isr”，但是，这些错误消息并不清楚。

当前 ISR 集是什么意思？每个主题是否有所不同及其含义？
我猜 min.isr 和 min.insync.replicas 一样。我希望它至少应该与“复制因子”具有相同的值(value)？

更新 #1

Topic: topic-ack-all    PartitionCount: 4       ReplicationFactor: 3    Configs:            
        Topic: topic-ack-all    Partition: 0    Leader: 1       Replicas: 1,2,3 Isr: 1,2,3  
        Topic: topic-ack-all    Partition: 1    Leader: 1       Replicas: 2,3,1 Isr: 1,2,3  
        Topic: topic-ack-all    Partition: 2    Leader: 1       Replicas: 3,1,2 Isr: 1,2,3  
        Topic: topic-ack-all    Partition: 3    Leader: 1       Replicas: 1,3,2 Isr: 1,2,3

更新 2

Topic: __consumer_offsets       PartitionCount: 50      ReplicationFactor: 1    Configs: compression.type=producer,cleanup.policy=compact,segment.bytes=104857600
    Topic: __consumer_offsets       Partition: 0    Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 1    Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 2    Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 3    Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 4    Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 5    Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 6    Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 7    Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 8    Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 9    Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 10   Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 11   Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 12   Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 13   Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 14   Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 15   Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 16   Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 17   Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 18   Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 19   Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 20   Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 21   Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 22   Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 23   Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 24   Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 25   Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 26   Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 27   Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 28   Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 29   Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 30   Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 31   Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 32   Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 33   Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 34   Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 35   Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 36   Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 37   Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 38   Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 39   Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 40   Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 41   Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 42   Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 43   Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 44   Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 45   Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 46   Leader: 3       Replicas: 3     Isr: 3
    Topic: __consumer_offsets       Partition: 47   Leader: 1       Replicas: 1     Isr: 1
    Topic: __consumer_offsets       Partition: 48   Leader: 2       Replicas: 2     Isr: 2
    Topic: __consumer_offsets       Partition: 49   Leader: 3       Replicas: 3     Isr: 3

最佳答案

从您粘贴的输出来看，__consumer_offsets 主题似乎是使用单个副本创建的。

您的代理似乎也设置了 min.insync.replicas = 3。

使用此配置，如果消费者提交偏移量，预计会得到 NotEnoughReplicasException。

__consumer_offsets 主题在第一个消费者连接到集群时自动创建。结束你的情况的一种常见方法是，如果你在只有一个代理运行的情况下运行一个消费者。在这种情况下，__consumer_offsets 将使用单个副本创建。

假设这是一个开发环境，回到有效状态的最简单方法是删除 __consumer_offsets 并在所有 3 个代理都启动时重新运行您的消费者。

关于apache-kafka - NotEnoughReplicasException : The size of the current ISR Set(2) is insufficient to satisfy the min. isr 要求 3，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/62770272/

文章推荐： javascript - 如何在运行时在 HTML5 Canvas 中绘制正方形？

文章推荐： spring-boot - 运行Spring Boot应用程序的jar文件时出错

文章推荐： docker - ECS Fargate NGINX容器在CloudWatch日志中未显示错误

文章推荐： TeamCity 将工件从一个代理复制到另一个代理

satisfiability - 可以使用 SAT 求解器找到所有解吗？
我写了一个我认为是 quite interesting question 的答案，但不幸的是，在我发布之前，该问题已被作者删除。我在这里重新发布问题的摘要和我的答案，以防其他人有用。假设我有一个 S
haskell - 约束以查看一个类型是否为 "satisfies"另一个
有没有办法写约束: C t1 t2 :: Constraint 如果 t2 与 t1 匹配，它“满足”(这是正确的词)。例如: C (forall a. Num a => a -> a -> a)
Matlab求解: Solution not satisfying the equation
我正在尝试用这段代码求解方程: a = [-0.0008333 -0.025 -0.6667 -20]; length_OnePart = 7.3248; xi = -6.4446; yi = -16
MySQL 安全模式 : What Satisfies the Requirements?
我知道我可以关闭 MySQL 中的安全模式，所以我不会尝试解决这个问题。我有一个简单的表格: create table rubbish( id int auto_increment prim
extjs - Sencha : Cannot satisfy requirements for "ext"
尝试刷新我的 sencha extjs 应用程序并总是收到此错误: 命令: sencha 应用程序刷新 sencha 应用升级总是同样的错误: [ERR] Cannot satisfy requir
haskell - 创建测试套件时出错 : "cannot satisfy -package-id"
我正在尝试为我的项目创建一个测试套件，HaskSplit在我的 .cabal 配置中: -- Initial HaskSplit.cabal generated by cabal init. For
mifare卡认证错误 "6982:Security status not satisfied"
我有 pc/sc 读卡器和非接触式卡(mifare 卡)，我可以连接到该卡，并且我也成功执行 getdate 命令，但是当我想进行身份验证时，我看到此错误“6982:安全状态不满足”我已经尝试了这 3
java - Spring集成中的"Repeat until condition satisfied"
简而言之，流程如下: inputChannel->transformer->firstOutboundAdapter->pollingOutboundAdapter 概要:inputChannel 接
带问号运算符的使用rust 错误 "the trait bound is not satisfied"
这个问题在这里已经有了答案: Why do try!() and ? not compile when used in a function that doesn't return Option o
rust - 在 "Sized is not satisfied"中打印切片矢量结果
我正在尝试切片矢量并在 Rust 中同时打印它。这是我的代码: fn main() { let a = vec![1, 2, 3, 4]; println!("{:?}", a[1..
ios - 如何解决Unable simultaneously satisfy constraints
我正在尝试自定义约束菜单栏类: import UIKit class ManuBar: UIView { override init(frame: CGRect) { sup
amazon-web-services - 云锋 : The request could not be satisfied
我遇到了这个问题，我有一个聊天服务器需要与托管在 aws 中的 lambda 服务进行通信，但云前端会引发以下错误。 BODY: ERROR: The request could not be s
multithreading - 在将包含Arc的self移到新线程中时，为什么会出现 “Sync is not satisfied”错误？
我有一个包含Arc>的结构，我试图添加一个获取self所有权的方法，并将所有权移到新线程中并启动它。但是，我得到了错误 error[E0277]: the trait bound `std::sync
types - 为什么由于缺少类型注释而收到错误 "trait bound FromStr is not satisfied"？
我遇到了一个编译错误，似乎突出显示了我对类型系统不了解的内容。我想将字符串转换为整数，如果字符串不是有效整数，则带有自定义 panic 消息。我做一个match在 Result由 parse() 返
excel - 错误 1400 : there is no such cell that satisfies criterias
这是应用过滤器后复制数据的代码。 Sub read_excel_file(path_to_current_work_book As String, path_to_destination_work
pip - 隐藏 "Requirement already satisfied"警告
我们有一个 shell 脚本，可以自动准备虚拟环境，然后在其中运行测试。部分脚本安装要求: pip install -r requirements.txt 当脚本多次运行时，它会针对每个要求打印一条警
iOS 11 : "Unable to simultaneously satisfy constraints"
总是遇到 FoodTracker 教程；遵循此步骤:“实现自定义控件” https://developer.apple.com/library/content/referencelibrary/Get
iphone - 错误 : Unable to simultaneously satisfy constraints
我收到此错误: Unable to simultaneously satisfy constraints. Probably at least one of the constraints in th
ios - UITableViewCell : unable to simultaneously satisfy constraints
我有一个 UITableViewCell我正在创建，并且我正在使用带有完全在代码中构建的约束的自动布局。虽然应用程序中的实际输出很好(即，它看起来就像我设计的那样)，但我收到了著名的“无法同时满足约
ios - 关闭 : "Unable to simultaneously satisfy constraints"
这个问题在这里已经有了答案: Disable autolayout constraint error messages in debug console output in Xcode (5 个回答)

行者123

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

apache-kafka - NotEnoughReplicasException : The size of the current ISR Set(2) is insufficient to satisfy the min. isr 要求 3