我通过在ec2服务器上传输1k大小的消息来测试kafka 0.8.1.1。
我在两台m3.xlarge服务器上安装了zookeeper，配置如下：

dataDir=/var/zookeeper/                                                                    
clientPort=2181
initLimit=5
syncLimit=2
server.server1=zoo1:2888:3888                                
server.server2=zoo2:2888:3888

第二，我在i2.2x大型计算机上安装了一台kafka服务器，它有32gbram和额外的6个ssd驱动器，每个磁盘分区为 /mnt/a , mnt/b, etc.... . 在服务器上，我有一个代理，端口9092上有一个主题，有8个分区，复制因子为1：

broker.id=1
port=9092
num.network.threads=4
num.io.threads=8
socket.send.buffer.bytes=1048576
socket.receive.buffer.bytes=1048576
socket.request.max.bytes=104857600
log.dirs=/mnt/a/dfs-data/kafka-logs,/mnt/b/dfs-data/kafka-logs,/mnt/c/dfs-data/kafka-logs,/mnt/d/dfs-data/kafka-logs,/mnt/e/dfs-data/kafka-logs,/mnt/f/dfs-data/kafka-logs
num.partitions=8
log.retention.hours=168
log.segment.bytes=536870912
log.cleanup.interval.mins=1
zookeeper.connect=172.31.26.252:2181,172.31.26.253:2181
zookeeper.connection.timeout.ms=1000000
kafka.metrics.polling.interval.secs=5
kafka.metrics.reporters=kafka.metrics.KafkaCSVMetricsReporter
kafka.csv.metrics.dir=/tmp/kafka_metrics
kafka.csv.metrics.reporter.enabled=false
replica.lag.max.messages=10000000

我所有的测试都是在另一个示例上完成的，示例之间的延迟小于1ms。当分区键是从0到7的随机数时，我使用一个线程生产者和8个线程消费者编写了生产者/消费者java客户机。通过提供自定义编码器，我使用json序列化了每条消息。
我的消费生产者属性如下：

metadata.broker.list = 172.31.47.136:9092
topic = mytopic
group.id = mytestgroup
zookeeper.connect = 172.31.26.252:2181,172.31.26.253:2181
serializer.class = com.vanilla.kafka.JsonEncoder
key.serializer.class = kafka.serializer.StringEncoder
producer.type=async
queue.enqueue.timeout.ms = -1
batch.num.messages=200
compression.codec=0
zookeeper.session.timeout.ms=400
zookeeper.sync.time.ms=200
auto.commit.interval.ms=1000
number.messages = 100000

现在，当我发送10万条消息时，每秒的容量是10万条，延迟大约是1毫秒。
这意味着我有每秒10兆字节的速度，相当于80mb/s，这还不错，但是我希望位于同一区域的那些示例有更好的性能。
我在配置中遗漏了什么吗？