为了账号安全,请及时绑定邮箱和手机立即绑定

KSQL Datagen - java.lang.ClassNotFoundException:

KSQL Datagen - java.lang.ClassNotFoundException:

郎朗坤 2021-06-11 22:32:10
我正在探索 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我遵循了快速入门指南中给出的每一步,我做错了什么?我什至重申了融合,但仍然得到与谷歌小组答案中提到的相同的错误
查看完整描述

2 回答

  • 2 回答
  • 0 关注
  • 252 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信