是因为默认的java heap size是50M,将broker_max_heap_size参数设置为512M后,重启kafka服务即可

相关文章: