1

我尝试运行此代码，但遇到了一些问题`

public class KafkaProducer {
    public static void main(String[] args) {
        long events = 100;
        Random rnd = new Random();

        Properties props = new Properties();
        props.put("metadata.broker.list", "localhost:9092" );
        props.put("producer.type","async"); // sync
        props.put("serializer.class", "kafka.serializer.StringEncoder");
        props.put("partitioner.class", "kafkaTest.KafkaPartitioner");
        props.put("request.required.acks", "1");
        ProducerConfig config = new ProducerConfig(props);

        Producer<String, String> producer = new Producer<String, String>(config);

        for (long nEvents = 0; nEvents < events; nEvents++) { 
            System.out.println("creating event "+nEvents);
            long runtime = new Date().getTime();  
            String ip = "192.168.2."+ rnd.nextInt(255); 
            String msg = runtime + ",www.om.com," + ip; 
            KeyedMessage<String, String> data11 = new KeyedMessage<String, String>("testt1", ip, msg);
            producer.send(data11);
            //System.out.println(data11);
        }
        producer.close();
    }
}

当我在沙盒上启动时：

java -jar testProducer

我有

Exception in thread "main"
java.lang.NoClassDefFoundError: kafka/producer/ProducerConfig at kafkaTest.KafkaProducer.main(KafkaProducer.java:31)
Caused by: java.lang.ClassNotFoundException: kafka.producer.ProducerConfig
4

0 回答 0