Я не могу создать пользовательский DistributedMapCacheClientService (с именем TestDistributedMapCacheClientService) для стандартных процессоров nifi (таких как Wait и PutDistributedMapCache) для использования. Мне удалось получить пользовательский сервис, который будет виден через Wait и PutDistributedMapCache, но процессоры не могут быть запущены, потому что nifi говорит, что мой nar "не совместим с AtomicDistributedMapCacheClient".
public class TestDistributedMapCacheClientService extends AbstractControllerService implements AtomicDistributedMapCacheClient<byte[]> {
:
}
Ошибка холста nifi для Процессор ожидания
ошибка холста nifi для процессора PutDistributedMapCache
TestDistributedMapCacheClientService выбирается из раскрывающегося списка свойств
TestDistributedMapCacheClientService выбирается из раскрывающегося списка свойств
У меня не возникает проблем, если я выбираю какой-либо из DistributedMapCacheClientServices (например, CouchbaseMapCacheClient или RedisDistributedMapCacheClient) от nifi, только мой пользовательский. Я ценю любую помощь.
Вот мои настройки проекта и их зависимости:
- my-nifi-services-bundle
- my-nifi-services
- my-nifi-services-api
- nifi-api (предоставляется)
- nifi-standard-services (pom)
- nifi-распределенный кэш-клиент- service-api (предоставляется)
- my-nifi-services-api
- nifi-api (предоставляется)
- nifi-распределенный кэш-клиент -service-api (предоставляется)
- my-nifi-services-nar
- nifi-standard-services-api-nar (nar)
- my-nifi-services
- my-nifi-services-api-nar
- my-nifi-services-api
- nifi-standard-services -апи-нар (нар)
