Я настроил 3 узла кафки (версия 2.0.0) и 3 узла кластера zookeeper.И создал одну тему с фактором репликации 3, разделами 1 и уровнем посредников min-in-sync-replicas = 2.
Случай 1: Когда я отключаю 2 узла kafka, мой производитель Java может отправлять данные, даже если я настроил свойство ' acks = all '.то есть, не выдавая ошибку NotEnoughReplicas
.
Случай 2: Когда я отключаю 2 узла kafka, мой производитель консоли не может отправлять данные, когда я настроил свойство ' request.required.acks all».то есть, выдав NotEnoughReplicas
ошибку.
, какие конфигурации следует передать производителю java в случае kafka 2.0.0?