为什么Kafka消费者表现缓慢？

我有一个简单的主题，一个简单的Kafka使用者和生产者，使用默认配置。

程序很简单，我有两个线程。

在生产者中，它不断发送16个字节的数据。

在消费者方面，它不断接收。

我发现生产者的吞吐量大约是10MB / s，这很好。

但消费者的吞吐量仅为0.2MB / s。 我已经禁用了所有的调试日志，但这并没有让它变得更好。 测试在本地计算机上运行。 什么机构都知道出了什么问题？ 谢谢！

我使用的代码如下：制片人：

KafkaProducer producer = new KafkaProducer(props); int size = 16; byte[] payload = new byte[size]; String key = "key"; Arrays.fill(payload, (byte) 1); ProducerRecord record = new ProducerRecord("test",0,key.getBytes(),payload); while(true){ producer.send(record); } 

消费者：

 Properties consumerProps = new Properties(); consumerProps.put("zookeeper.connect", "localhost:2181"); consumerProps.put("group.id", "test"); ConsumerConnector consumer = Consumer.createJavaConsumerConnector(new ConsumerConfig(consumerProps)); Map topicCountMap = new HashMap(); topicCountMap.put("test", 1); Map<String, List<KafkaStream>> consumerMap = consumer.createMessageStreams(topicCountMap); List<KafkaStream> streams = consumerMap.get("test"); ConsumerIterator it = streams.get(0).iterator(); while(it.hasNext()){ it.next().message(); }