Признание брокера Kafka производителю API Java и производителю консоли? - PullRequest
0 голосов
/ 27 ноября 2018

Я настроил 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?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...