我在我的Windows PC上构建了一个小测试环境并写下以下代码来测试kafka(使用org.apache.kafka中的kafka_2.10：0.9.0.1) .

package iii.functiontesting;

import java.text.ParseException;

import java.util.Properties;

import org.apache.kafka.clients.producer.KafkaProducer;

import org.apache.kafka.clients.producer.ProducerRecord;

/**

* Hello world!

*

*/

public class test4

{

public static void main( String[] args ) throws ParseException

{

Properties producerProps=new Properties();

producerProps.put("bootstrap.servers", "localhost:9092");

producerProps.put("serializer.class",org.apache.kafka.common.serialization.StringSerializer.class.getName());

producerProps.put("key.serializer",org.apache.kafka.common.serialization.StringSerializer.class.getName());

producerProps.put("value.serializer",org.apache.kafka.common.serialization.StringSerializer.class.getName());

producerProps.put("request.required.acks","1");

KafkaProducer kafkawriter= new KafkaProducer(producerProps);

ProducerRecord msg=new ProducerRecord<>("TEST3","ImKey","teststring1");

kafkawriter.send(msg);

}

}

我使用以下命令检查消息是否正确写入队列

D：\ Work \ kafkaenv \ kafka_2.10-0.9.0.1 \ bin \ windows> . \ kafka-console-consumer.bat --zookeeper localhost：2181 --topic TEST3 - from-beginning

但是，我发现kafka-console-consumer没有显示任何内容 .

我怀疑我的kafka服务器运行不正常，所以我使用console-producer进行测试 .

D：\ Work \ kafkaenv \ kafka_2.10-0.9.0.1 \ bin \ windows> . \ kafka-console-producer.bat --broker-list localhost：9092 --topic TEST3 aaaaa

这次我可以看到aaaaa清楚地显示在控制台消费者之下 . 我无法弄清楚会发生什么 . 谁能帮我？