KSQL Datagen - java.lang.ClassNotFoundException:

我正在探索 confluent Kafka 并遵循confluent 的快速入门指南。java.lang.ClassNotFoundException: io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor每当我尝试使用以下命令为 Kafka 主题创建一些示例数据时,我都会收到:


bin/ksql-datagen quickstart=pageviews format=delimited topic=pageviews maxInterval=100 \ propertiesFile=etc/ksql/datagen.properties

这是堆栈跟踪


Outputting 1000000 to pageviews

[2018-08-01 11:37:06,323] INFO AvroDataConfig values: 

    schemas.cache.config = 1

    enhanced.avro.schema.support = false

    connect.meta.data = true

 (io.confluent.connect.avro.AvroDataConfig:179)

Exception in thread "main" org.apache.kafka.common.KafkaException: Failed to construct kafka producer

    at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:460)

    at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:320)

    at io.confluent.ksql.datagen.DataGenProducer.populateTopic(DataGenProducer.java:76)

    at io.confluent.ksql.datagen.DataGen.main(DataGen.java:100)

Caused by: org.apache.kafka.common.KafkaException: io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor ClassNotFoundException exception occurred

    at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstances(AbstractConfig.java:357)

    at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstances(AbstractConfig.java:332)

    at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstances(AbstractConfig.java:319)

    at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:381)

    ... 3 more


我遵循了快速入门指南中给出的每一步,我做错了什么?


我什至重申了融合,但仍然得到与谷歌小组答案中提到的相同的错误


郎朗坤
浏览 253回答 2
2回答
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Java