java—为库存nifi处理器创建自定义distributedmapcacheclient控制器服务

8iwquhpp  于 2021-06-30  发布在  Java
关注(0)|答案(1)|浏览(382)

我似乎无法为库存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)

yuvru6vn

yuvru6vn1#

但是处理器无法启动,因为nifi说我的nar“与atomicdistributedmaccacheclient不兼容”。
有两个潜在原因(可能都适用):
你需要实施 AtomicDistributedMapCacheClient ,不是 DistributedMapCacheClient .
您需要将项目依赖项与正在运行的nifi版本同步(如1.12.1到1.12.1;必须严格遵守这些服务)
至少,#1适用,因为 AtomicDistributedMapCacheClient 是的子接口 DistributedMapCacheClient .

相关问题