Как интегрировать Keycloak с kafka?

Question

Я настроил 3 узла кафки кластера.Теперь мы хотим настроить безопасность с Keycloak для kafka.Пожалуйста, дайте мне знать, как можно сделать то же самое.

Вопрос 1: Как реализовать безопасность для брокера Кафка для брокера Кафка с помощью keycloak?

Вопрос 2: Как реализовать безопасность для Кафкиклиент к брокеру kafka с keycloak?

Примечание: у нас уже была настройка Keycloak.

Answer 1

Вы можете настроить Kafka для использования AUTHBEARER, который реализован в последней версии kafka. Вы можете найти больше информации о том, как настроить здесь .

А также получить дополнительную информацию офункция из Kafka doc

Вам необходимо реализовать org.apache.kafka.common.security.auth.AuthenticateCallbackHandler, чтобы получить токен из Keycloak и проверить токен из Keycloak.