You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by Somasundaram Sekar <so...@tigeranalytics.com> on 2017/12/20 07:00:18 UTC
Unable to start Sink connectors[Confluent Kafka]
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
info@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.
Re: Unable to start Sink connectors[Confluent Kafka]
Posted by Ted Yu <yu...@gmail.com>.
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.sekar@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
> info@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.
>