我认为你的生产者配置是错误的。以下是Kafka官方文档中的示例:
Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("acks", "all"); props.put("retries", 0); props.put("batch.size", 16384); props.put("linger.ms", 1); props.put("buffer.memory", 33554432); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
只需尝试较小的值 batch.size 和 buffer.memory 。
batch.size
buffer.memory
看起来Netbeans执行错误的类 - 而不是你的 kafka.Kafka 上课,但是 KafkaServer (看起来这是卡夫卡本身的主要类别)。请配置Netbeans以执行正确的类。
kafka.Kafka
KafkaServer
我建议从现有的Producer样本开始 汇合的例子 ,并重新使用Maven项目......