我似乎无法为库存nifi处理器(如wait和putdributedmaccheclientservice)创建要使用的自定义distributedmaccheclientservice(名为testdistributedmaccheclientservice)。我能够让我的定制服务被wait和putdributedmaccache看到,但是处理器不能启动,因为nifi说我的nar“与atomicdistributedmaccacheclient不兼容”。
public class TestDistributedMapCacheClientService extends AbstractControllerService implements AtomicDistributedMapCacheClient<byte[]> {
:
}
等待处理器的nifi画布错误
putdistributedmapcache处理器的nifi画布错误
testdistributedmapcacheclientservice可从属性下拉列表中选择
testdistributedmapcacheclientservice可从属性下拉列表中选择
如果我选择了nifi的distributedmapcacheclientservices(比如couchbasemapcacheclient或redisbutedmapcacheclient)中的任何一个,只要选择我的自定义服务,我就不会有任何问题。谢谢你的帮助。
以下是我的项目设置及其依赖项:
我的nifi服务包
我的nifi服务
我的nifi服务api
nifi api(提供)
nifi标准服务(pom)
nifi分布式缓存客户端服务api(提供)
我的nifi服务api
nifi api(提供)
nifi分布式缓存客户端服务api(提供)
我的nifi服务
nifi标准服务api nar(nar)
我的nifi服务
我的nifi服务api nar
我的nifi服务api
nifi标准服务api nar(nar)
1条答案
按热度按时间yuvru6vn1#
但是处理器无法启动,因为nifi说我的nar“与atomicdistributedmaccacheclient不兼容”。
有两个潜在原因(可能都适用):
你需要实施
AtomicDistributedMapCacheClient
,不是DistributedMapCacheClient
.您需要将项目依赖项与正在运行的nifi版本同步(如1.12.1到1.12.1;必须严格遵守这些服务)
至少,#1适用,因为
AtomicDistributedMapCacheClient
是的子接口DistributedMapCacheClient
.