У меня есть приложение Quarkus, которое я использую для вывода списка функций в экземпляре Pulsar с помощью клиента администрирования Pulsar.
Я добавил следующее в файл application.properties: р>
quarkus.pulsar.devservices.broker-config.functionsWorkerEnabled=true
quarkus.pulsar.devservices.image-name=apachepulsar/pulsar:3.3.0
Я подтвердил, что все работает так, как ожидалось: когда я загружаю конфигурации среды выполнения брокера, я вижу, что настройка верна.
{
...removed for brevity
functionsWorkerEnabled=true
...removed for brevity
}
Я создаю клиент администратора следующим образом:
var client = PulsarAdmin.builder().serviceHttpUrl(adminBrokerUrl).build();
Я попробовал напрямую вызвать REST API и получил ту же ошибку:
Запрос:
http://localhost:65103/admin/v3/functio ... tFunctions
Ответ:
{
"reason": "Pulsar Function Worker is not enabled, probably functionsWorkerEnabled is set to false"
}
Я проверил документацию, чтобы узнать, нужно ли мне устанавливать какие-либо другие конфигурации, но, насколько я понимаю из документации, все остальные настройки наследуются от конфигурации брокера.
Ожидается, что при вызове я получу пустой список от клиента или список имен функций, настроенных в брокере:
client.functions().getFunctions(tenant, namespace);
Однако я получаю сообщение об ошибке:
Я получаю сообщение об ошибке:
Error getting functions: org.apache.pulsar.client.admin.PulsarAdminException$ConflictException: Pulsar Function Worker is not enabled, probably functionsWorkerEnabled is set to false
Подробнее здесь: https://stackoverflow.com/questions/787 ... -using-the
