In case if RDD is partitioned, does zipwithIndex produce the unique key?? ... View more

I have given Destination Broker List as quickstart.cloudera:9092 Source Broker List as quickstart.cloudera:9092 ... View more

Could you please give me what exactly to put into these fields on CDH kafka configuring. 1) Fill in "Source Brokers List" --> "nameOfClouderaKafkaBrokerServer.yourdomain.com:9092". This is the Server (or Servers) where you configured the Kafka Broker (NOT the MirrorMaker). 2) Fill in "Destination Brokers List" --> "nameOfRemoteBrokerServer.otherdomain.com:9092". This is supposed to be a remote Cluster that will receive Topics sent over by your MirrorMaker. If you have one, put in that one. Otherwise just put in another Server in your network, whatever Server. ... View more