PulsarAdminException$ConflictException: при попытке вывести список функций с помощью Java-клиента администратора Pulsar JAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 PulsarAdminException$ConflictException: при попытке вывести список функций с помощью Java-клиента администратора Pulsar

Сообщение Anonymous »

У меня есть приложение 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
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»