AnsweredAssumed Answered

Available ports for brokers in mapr clustre

Question asked by mahdi62b on Oct 17, 2016

Hi,

I have written some program which use two brokers to send the messages..as follow:

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

The IPs are the address of the cluster nodes but I get

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

..I wanted to know which ports I can use for a MapR cluster..

Outcomes