Starting Sink connector on Confluent Kafka setup throws up the below
exception, understand that it is because of some configured interceptor,
any advice on how to disable it?
[2017-12-20 06:51:11,235] ERROR Task {} failed initialization and will not
be started. (org.apache.kafka.connect.runtimee
.WorkerSinkTask:115)
org.apache.kafka.connect.errors.ConnectException: Failed to create consumer
at
org.apache.kafka.connect.runtime.WorkerSinkTask.createConsumer(WorkerSinkTask.java:397)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.initialize(WorkerSinkTask.java:112)
at
org.apache.kafka.connect.runtime.Worker.startTask(Worker.java:390)
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder.startTask(DistributedHerder.java:830)
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder.access$1600(DistributedHerder.java:100)
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder$13.call(DistributedHerder.java:844)
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder$13.call(DistributedHerder.java:840)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.common.KafkaException: Failed to construct
kafka consumer
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:765)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:602)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:585)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.createConsumer(WorkerSinkTask.java:395)
... 10 more
*Caused by: org.apache.kafka.common.KafkaException:
io.confluent.monitoring.clients.interceptor.MonitoringConsumerIntercee*
*ptor ClassNotFoundException exception occurred*
* at
org.apache.kafka.common.config.AbstractConfig.getConfiguredInstances(AbstractConfig.java:288)*
* at
org.apache.kafka.common.config.AbstractConfig.getConfiguredInstances(AbstractConfig.java:263)*
*Regards,*
*Somasundaram S*
--
*Disclaimer*: This e-mail is intended to be delivered only to the named
addressee(s). If this information is received by anyone other than the
named addressee(s), the recipient(s) should immediately notify
[email protected] and promptly delete the transmitted material from
your computer and server. In no event shall this material be read, used,
stored, or retained by anyone other than the named addressee(s) without the
express written consent of the sender or the named addressee(s). Computer
viruses can be transmitted viaemail. The recipient should check this email and
any attachments for viruses. The company accepts no liability for any
damage caused by any virus transmitted by this email.
