运行凝聚式Kafka 4.1.1社区。
我有。
最小同步副本=2
主题:1分区,副本计数3
共有3名经纪人。
生产者设置为ack= -1
所有其他生产者设置都是默认的。
我启动了我的应用程序,当它开始向Kafka 写记录时,我就故意把其中一位经纪人解雇了,和我立即得到了:org.apache.kafka.common.errors.NetworkException: The server disconnected before a response was received.
基于上面的设置。生产者不应该写()成功,而不是抛出一个错误吗?
Clarification
我有三个模特:
公司;
投资者;
经纪人。
在现实世界中,每个投资者都可以投资于许多公司,但在一些公司,他/她可以在经纪人的协助下进行投资。我通过了联合桌。
def change
create_join_table :companies, :investors do |t|
t.references :broker, index: true, optional: true
end
end
class Company < ApplicationRecord
has_and_belongs_to_many :investors
end
class
在本地主机上运行3个Kafka Brokers :9092,localhost:9093,localhost:9094,以及在localhost上运行的动物管理员实例:2181。
并且创建一个主题,复制因子为3。
不影响适当功能和不丢失数据的代理故障的最大数量是多少?
当这三个经纪人一个一个地倒下的时候。我们启动了一个随机代理(上面三个中的一个),它给出了一个错误消息- Received invalid metadata error in produce request on partition myTopic due to org.apache.kafka.common.errors.Not