我理解Kafka中的领导者和数据复制的概念，但我不明白为什么消费者和生产者在从分区写入/读取时总是路由到主节点，而不是能够从任何ISR (同步副本)读取
在我看来，如果所有的消费者都被重定向到一个单一的主节点是否可以在副本节点中进行读写，或者消费者/生产者将始终连接到该分区的主节点？
浏览 12提问于2021-03-02得票数 0
我有一个两个节点的Kafka集群(EC2实例)，其中每个节点被用作单独的代理。测试消息2017-01-09 13:22:39,483当获取相关id 0：{test=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) 2017-01-09 13:22:39,562警告错误时，取相关id 1：{test=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka</e
浏览 23提问于2017-01-09得票数 14
org.apache.kafka.common.errors.NotEnoughReplicasException: The size of the current ISR Set(3) is insufficientto satisfy the min.isr requirement of 2 for partition FooBar-0
奇怪的是，min.isr设置为2，ISR集有3个节点。[root@LoremIpsum kafka]#
浏览 8提问于2020-09-26得票数 1
回答已采纳
我在AWS上运行一个3节点的Kafka集群。动物园管理员版本：3.4创建一个具有复制因子3的主题，该主题将使所有3个节点上的数据可用。~ $ docker run --rm -ti ches/kafka bin/kafka-topics.sh --zookeeper "10.2.31.10:2181,10.2.31.74:2181,
浏览 2提问于2017-09-11得票数 7
回答已采纳
在我们的单节点开发环境中，卡夫卡的读取失败，我遇到了问题。org.apache.kafka.common.errors.NotEnoughReplicasException: Number of insync replicas for partition__transaction_state Par
浏览 1提问于2018-05-03得票数 3
回答已采纳
1回答
我在3个EC2实例上运行Kafka集群。每个实例运行kafka (0.11.0.1)和zookeeper (3.4)。我的主题被配置为每个都有20个分区和3个ReplicationFactor。今天，我注意到一些分区拒绝与所有三个节点同步。Replicas: 2,0,1 Isr: 2
只有节点2的所有数据是同步的。编辑:一些附加信息...如果我检查节点2(具有完整数据的节点)上的指标，它确实意识到某些分区没有正确复制。$>get -d kafka</
浏览 0提问于2018-06-27得票数 7
org.apache.kafka.common.errors.TimeoutException:305000毫秒是
浏览 2提问于2017-07-05得票数 14
其中一个节点不断抛出以下错误：
[2020-05-25 16:45:02,054] ERROR [ReplicaFetcherThread-0-1], Error for partition [atlas10-prod-serverSide-ssch,5] to broker 1:org.apache.kafka.common.errors.UnknownTopicOrPartitionException:for partition [atlas10-prod-serverSide-ssch,10] to broker 1:org.
浏览 14提问于2020-05-25得票数 0
我已经尝试了两个星期了，我在不同的机器上运行Kafka集群，而不是我的连接节点。我无法使连接正常运行。我可以读写卡夫卡没有问题。Zookeeper似乎运行得很好。groupId=connect-cluster] Discovered group coordinator 172.25.1.2:9092 (id: 2147483645 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator2018-08-21 15:45:12,1
浏览 303提问于2018-08-21得票数 15
回答已采纳
在断开管道错误消失后，Kafka代理决定离开集群，成为自己的领导者(因为它将ISR从3缩小到1)，而不是重新加入集群。 到目前为止，唯一的解决方法是重新启动代理，它将作为追随者正常地重新加入集群。:172) at org.apache.kafka.common.network.KafkaChannel.close-1 broke
浏览 63提问于2019-05-10得票数 0
我们在生产中有一个由4个节点组成的集群。我们观察到，其中一个节点遇到了一种情况，它不断地收缩和扩展ISR超过1个小时，并且无法恢复，直到代理被弹回。[skynet-large-stage,5] from 2,0 to 0 (kafka.cluster.Partition)
[2017-02-21 14:52:16,543] INFO Partition0: Shrinking ISR for partition [skynet-large-stage,13] from 1,0 to 0 (kafk
浏览 45提问于2017-02-21得票数 11
回答已采纳
我设置了一个kafka s3连接器，但是由于错误，它无法使用来自kafa的数据：kafka是一个单节点集群，似乎与其他用户合作很好，例如，偏移浏览器可以从主题中读取数据。connect-s3-sink] Updating last seen epoch from 0 to 0 for partition
prod.master.pxv.trade.eod.v1-0 (org.apache.kafka.clients.Me
浏览 3提问于2022-08-31得票数 0
我在一个由6个节点组成的集群中创建了一个主题，其中包含36个分区和4个副本。一个动物园管理节点运行在一个独立的节点上。: 6 Replicas: 6,4,5,1 Isr: 4,5,6,1 org.apache.kafka.common.errors.NotLeaderFo
浏览 1提问于2018-08-06得票数 0
1回答
假设我有一个由3个代理和3个zookeeper组成的Kafka集群。
我有一个单一的主题accountsTopic，它设置为replication factor of 3和ISR of 2。如果Leader死了，kafka将选举ISR为领导者，但是第三个(因为争论的缘故，它不是ISR)，它会在这个2节点故障转移设置中充当当前领导者的ISR吗？
浏览 1提问于2018-07-04得票数 4
我正在多节点环境中使用kafka来测试故障转移是如何工作的。实际上，我有两个VM，每个VM中有一个kafka节点，而两个VM中只有一个是动物园管理员。(好的，经纪人在VM1上可以分发VM2上被杀死的卡夫卡节点(OK)Kill on VM2 (OK )再发送一条消息给消费者接收它(好的，经纪人在VM2上可以分发被杀死的卡夫卡节点)。(好，VM2上的代理可以在VM1 (OK)上分发被杀死的卡夫卡节点(OK)。出了个错误
ERROR Error when sending me
浏览 5提问于2021-12-19得票数 0
回答已采纳
我有一个包含3个kafka节点和3个zk节点的kakfa集群。Partition: 0 Leader: 1 Replicas: 1 Isr: 1Partition: 0 Leader: 2 Replicas: 2 Isr: 2哪些设置出
浏览 0提问于2016-02-11得票数 0
1回答
我有一个3节点卡夫卡集群与1个动物园管理员节点。 /bin/kafka-run-class.sh kafka.tools.GetOffsetShell --topic AdServe --bro
浏览 1提问于2015-06-05得票数 2
我正在使用Kafka Admin client API来创建主题。主题正在创建，但是默认情况下主题是使用1个分区创建的。API未遵循提供的可配置值。不确定我是否正确地使用它。{ e.printStackTrace();但是，我可以使用Kafka
浏览 4提问于2020-02-13得票数 0
1回答
我有一个由3个节点组成的Kafka集群，每个节点有1个ZK和1个代理。我可以看到，过了一段时间，几乎没有几个主题将ISR缩小为一个单一的领导者。/opt/kafka/bin/kafka-topics.sh --describe --zookeepe
浏览 2提问于2018-07-17得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
