我编写了一些程序，使用两个代理发送消息，如下所示：

val kafkaBrokers = "172.16.50.64:9092,172.16.50.65:9093"

IP是集群节点的地址，但我得到

java.nio.channels.ClosedChannelException
org.apache.spark.SparkException: java.nio.channels.ClosedChannelException
java.nio.channels.ClosedChannelException..

我想知道哪些端口可以用于mapr集群。。