スパークストリーム差別カフカトピック

Question

私は複数のトピックので、同じように私火花ストリーミングアプリケーションを供給した場合：

私は私のストリームから把握することができますどのように自分のアプリケーションを実行

val ssc = new StreamingContext(sc, Seconds(2)) 
    val topics = Set("raw_1", "raw_2) 
    val kafkaParams = Map("metadata.broker.list" -> "localhost:9092") 
    val stream = KafkaUtils.createDirectStream[String, String, StringDecoder, StringDecoder](ssc, kafkaParams, topics) 

どのような違いどのトピック間それはから引っ張っている？やるべきことはありますか？私は

val lines = stream.print() 

ような何かをした場合、私は、分化の何を取得していないのです。カフカメッセージキーを重要な要素にする唯一の方法はありますか？

Answer 1

はい、メッセージのメタデータにアクセスできるcreateDirectStreamのMessageAndMetadataバージョンを使用できます。

例の実装hereがあります。