Как использовать службу DistributedMapCacheClient как свойство в пользовательском процессоре nifi? - PullRequest
Новая
       6

Как использовать службу DistributedMapCacheClient как свойство в пользовательском процессоре nifi?

0 голосов
/ 27 сентября 2018

Я пытаюсь использовать службу DistributedMapCacheClient в качестве свойства в моем пользовательском процессоре nifi.Все было хорошо, но когда я собираюсь настроить процессор в Nifi, я получаю следующее сообщение об ошибке:

"Не найдены типы служб контроллера, применимые для этого свойства."

Вот как я настроил свойство в своем коде. 

public static final PropertyDescriptor DISTRIBUTED_CACHE_SERVICE = new PropertyDescriptor.Builder()
            .name("Distributed Cache Service")
            .description("")
            .required(false)
            .identifiesControllerService(DistributedMapCacheClient.class)
            .build();

Пожалуйста, дайте мне знать, как я могу использовать службу DistributedMapCacheClient в качестве свойства в моем процессоре.

1 Ответ

0 голосов
/ 01 октября 2018

Мне не хватало следующих зависимостей в моем pom-файле.После того как я добавил их, мой пользовательский процессор работал нормально.Я нашел ответ в этой ссылке .

  1. Добавлена ​​область действия, предусмотренная для зависимости, nifi-extended-cache-client-service-api.

  2. Добавлена ​​зависимость для nifi-standard-services-api-nar (type = nar)

...