如果一个经纪人做了2个小时后又回来了，那么kafka中的副本是如何工作的呢？

文章/答案/技术大牛

发布

1回答

apache-kafka

我们有3个zookeeper和3个kafka broker节点作为集群设置，在AWS的不同系统中运行，我们更改了以下属性以确保高可用性和防止数据丢失。offsets.topic.replication.factor=3transaction.state.log.min.isr=1 我有以下问题，假设经纪人A，B，C 由于我们将复制因子设为3，因此所有数据都将在所有A、B、C代理中可用，如果A代理宕机，

浏览 18提问于2021-05-11得票数 0

1回答

：带有异步请求、批处理和最大在飞行中的最大KafkaTemplate行为

java、apache-kafka、publish-subscribe、spring-kafka、kafka-producer-api

如果我打倒所有kafka经纪人3-5分钟，然后将集群恢复在线，应用程序的发行者立即重新建立与kafka的连接，并继续发布消息。问题行为:但是，在执行负载测试时，如果我将所有kafka代理关闭3到5分钟，然后将集群恢复联机，应用程序的发行者将继续显示所有发布尝试的失败。考虑到我有单独的线程，所有线程都用单独的消息和回调调用kafkatemplate.send()，并

浏览 1提问于2019-10-03得票数 1

回答已采纳

1回答

修正Git中凌乱的提交历史

git、github、version-control

我做了一些修改，然后提交并在GitHub上推送它们。如果我把它压缩在一起，我能修复它吗？(它会忽略添加并删除的代码吗)？如果我将它重置回原来的状态，并再次提交我的<

浏览 0提问于2019-05-03得票数 0

3回答

卡夫卡能被要求在JoinGroup期间等待的时间比JoinGroup少吗？

apache-kafka

背景：I有一个在Kubernetes中运行的应用程序，它使用Kafka作为集中消息总线。我的应用程序中的Kafka客户端可能非常慢。对于这个应用程序中的大多数工作人员，我可以将max.poll.interval.ms设置为几分钟的顺序。然而，对于速度较慢的工人，我需要将其设置为几个小时。当一切正常工作时，这不会引起问题。<em

浏览 6提问于2020-04-15得票数 1

2回答

卡夫卡配置min.insync.replicas不工作

apache-kafka、kafka-consumer-api、kafka-producer-api

这是我学习卡夫卡的早期。我正在检查本地机器中的每一个卡夫卡属性/概念。所以我偶然发现了这个属性，min.insync.replicas，这是我的理解。如果我误解了什么，请纠正我。如果可用的活动代理(间接地，同步副本)的数量少于指定的min.insync.replicas，那么生产者将引发一个异常，无法发布消息。分区:0领导人:1副本: 2,0,1 Is

浏览 2提问于2019-11-09得票数 2

6回答

没有小组协调员-卡夫卡

java、apache-kafka

当我给卡夫卡写一个主题时，有一个错误：Offset commit failed2016-10-29 14:52:56.387 INFO [nioEventLoopGroup-3-1][org.apache.kafka.common.uti

浏览 3提问于2016-10-29得票数 22

回答已采纳

1回答

WinAPI的Sleep()有多精确？

winapi、sleep

我不是指精确到1毫秒，我是问当我想使用Sleep(60 * 60 * 1000)延迟一个小时的情况。会不会是一个小时，而不是55或70分钟？线程能保证永远唤醒而不是休眠吗？

浏览 2提问于2012-11-08得票数 1

回答已采纳

1回答

chrome-dev源文件的限制是什么？

javascript、php、drupal-7、google-chrome-devtools

fromdate,$todate);$items['my_module_name']['#items']['data'] = $result;如果我试图将所有这一切回

浏览 0提问于2016-05-04得票数 1

1回答

AlwaysOn DDL和模式更改

sql-server、availability-groups

有人能讨论如何逐步地将discuss更改与可用性组结合起来吗？我们有一个主副本在一个状态，第二个副本在另一个状态位置。辅助副本将是只读异步的。我的假设还需

浏览 0提问于2017-07-09得票数 2

回答已采纳

5回答

卡夫卡服务器配置-侦听器与advertised.listeners

amazon-ec2、apache-kafka

要运行Kafka，需要在config/server.properties文件中设置一些属性。有两个设置我不明白。我什么时候必须使用哪一种设置？

浏览 9提问于2017-03-24得票数 76

回答已采纳

1回答

java、logging

我们正在工作中进行讨论，提出了一个有趣的问题：现在问题来了。由于您的产品是一个库，如果您的客户使用的是somelib，并且碰巧使用的是同一日志库的不同版本，那么他们自己会

浏览 0提问于2012-03-29得票数 2

2回答

堆栈是如何在NodeJs上工作的？

node.js

最近，我开始阅读NodeJs (和JS)，并对NodeJS中的回调工作方式感到有点困惑。1) 好的，那么我的第一个问题是假设它的一个堆栈是否由主事件循环线程运行回调函数？如果是这样的话，那么如果我们有一个站点通过回调(从db获取和推送请求)来服务内容，并且我们有1000个并发的，那么<

浏览 6提问于2013-04-11得票数 0

回答已采纳

5回答

记得我和会话超时有什么不同？

php、session、cakephp、cookies

我在CakePHP中构建了一个应用程序，允许用户登录并做一些事情，我认为默认情况下，它会让用户登录大约24小时。正如所要做的那样，创建另一个cookie来设置一个超时并让用户登录.但是这个功能在默认情况下存在于每个应用程序和会话中，对吗？这是恼人的，因为我有一个1小时的应用程序到期，但即使当客户端使用该网站，它将在1小时后，无论活动。如果有人能回答这两个问题，那

浏览 5提问于2012-06-20得票数 6

4回答

HQL子字符串最后x个字符

java、hibernate、hql

我是Hibernate的新手，我想获取字符串的最后N个字符。我找到了substring方法，但这并没有真正的帮助:(提亚

浏览 0提问于2014-08-04得票数 2

1回答

React-本机RNCamera onGoogleVisionBarcodesDetected无法检测QR_CODE类型

react-native、react-native-android、barcode、barcode-scanner、react-native-camera

我已经实现了一个条形码扫描仪应用程序。直到今天，一切都运行良好。然而，今天该应用程序开始以不同的方式检测条形码。我得到的条形码类型是'TEXT‘而不是'QR_CODE’。版本是3.13.1。，它以前是如何正确工作的呢？这是我在侦测中得到的 [{"bounds": {"origin": [Object], "size": [Object]

浏览 0提问于2020-02-21得票数 1

点击加载更多