Looking at
https://docs.confluent.io/3.0.0/control-center/docs/clients.html#adding-the-interceptor-to-your-kafka-consumer
, it seems that the class name in interceptor.classes had a typo (extra
'e').
Can you double check ?
Cheers
On Tue, Dec 19, 2017 at 11:00 PM, Somasundaram Sekar <
somasundar.se...@tigeranalytics.com> wrote:
> 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
> i...@tigeranalytics.com 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.
>
