Как использовать Kafka Idempotent производитель в керберизованном кластере?
Пытаюсь использовать производителя Idempotent на кластере с поддержкой Kerberos. Можно производить и потреблять, используя apporpriate jaas.conf. Однако когда
ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG
установлено в true, производить сбои со следующим исключением.
Exception : org.apache.kafka.common.errors.ClusterAuthorizationException: Cluster authorization failed.
Нет доступной трассировки стека.
Ниже приведены версии версий:
- брокер - 1.0.0
- клиент - 1.0.0
В Ranger я вижу, что у пользователя есть следующие разрешения:
- Публиковать
- потреблять
- Создайте
- удалять
- конфигурировать
- описывать
- Кафка
- Администратор
Есть ли что-то, что мне не хватает?