执行报错

Question

执行KafkaClientApp 类时报错

错误定位的37，21是这一行：

	producer.send(new KeyedMessage<Integer, String>(topic, message));

Answer 1

Michael_PK 2019-11-18 16:51:12

你的produce代码贴下看看

• 提问者 weixin_慕哥1181079 #1

  PK哥 produce代码我贴到回复里了

Answer 2

提问者 weixin_慕哥1181079 2019-11-18 18:07:16

package com.imooc.spark.kafka;

import kafka.javaapi.producer.Producer;
import kafka.producer.KeyedMessage;
import kafka.producer.ProducerConfig;

import java.util.Properties;

/**
 * Kafka 生产者
 */
public class KafkaProducer extends Thread {

    private String topic;

    private Producer<Integer, String> producer;

    public KafkaProducer(String topic) {
        this.topic = topic;

        Properties properties = new Properties();

        properties.put("metadata.broker.list",KafkaProperties.BROKER_LIST);
        properties.put("serializer.class","kafka.serializer.StringEncoder");
        properties.put("request.required.acks","1");

        producer = new Producer<Integer, String>(new ProducerConfig(properties));
    }

    @Override
    public void run() {

        int messageNo = 1;

        while(true) {
            String message = "message_" + messageNo;
            producer.send(new KeyedMessage<Integer, String>(topic, message));
            System.out.println("Sent: " + message);

            messageNo ++ ;

            try{
                Thread.sleep(2000);
            } catch (Exception e){
                e.printStackTrace();
            }
        }
    }
}

• Michael_PK #1

  报错的那行是那一句?

• 提问者 weixin_慕哥1181079 回复 Michael_PK #2

  producer.send(new KeyedMessage<Integer, String>(topic, message)); 是这一句

• Michael_PK 回复 提问者 weixin_慕哥1181079 #3

  1）看你的控制台信息 你的jdk编译怎么是1.5的？ idea里面改下  2）你的工程里的pom的所有东西都正常导入没，包括scala

点开查看后面4条评论