刘伟

System.setProperty("java.security.auth.login.config", "/tmp/kafka_client_jaas.conf");

用这种方式，连接不同的kafka,账号和密码不一致怎么办的

你单条消息太大了。

我现在把max.partition.fetch.bytes加大10倍，把max.poll.records降到10，在测试运行，就是速度慢的一比

kafka 0.10.0.0之后就没有fetch.max.bytes和fetch.message.max.bytes了。
新的是：max.partition.fetch.bytes，说明如下：

服务器将返回每个分区的最大数据量。一个请求使用的最大总内存将是#partition * max.partition.fetch.bytes。这个大小必须至少与服务器允许的最大消息大小一样大，否则生产者有可能发送大于消费者可以获取的消息。如果发生这种情况，消费者在试图获取某个分区的大消息时就会被卡住。

继续加大：max.partition.fetch.bytes

试过了，不支持这个参数

新手回答，可能有误，共同探讨一下。
试试这个参数呢 fetch.max.bytes