我在centos 7(汇合)上安装了Apache,我试图在分布式模式下运行filestream连接,但是我得到了以下错误:
[2017-08-10 05:26:27,355] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:290)
Exception in thread "main" o
我有卡夫卡连接(版本2.1.1-cp1)与卡夫卡(2.0.1-cp4)和运行大约70个连接器相当繁重的工作量。有时(每2-3周),突然间,一些节点开始获得以下日志并停止工作:
INFO [Worker clientId=connect-1, groupId=dwh-prod] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
INFO [Worker clientId=connect-1, groupId=dwh-prod] Successfully joined group
我看到我的连接器的状态,我有这个异常。
org.apache.kafka.connect.errors.ConnectException: Task already exists in this worker: *name of the connector*
at org.apache.kafka.connect.runtime.Worker.startTask(Worker.java:365)
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.startTask(Distribu