我正在探索 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
我遵循了快速入门指南中给出的每一步,我做错了什么?
我什至重申了融合,但仍然得到与谷歌小组答案中提到的相同的错误
相关分类