[ https://issues.apache.org/jira/browse/SPARK-13106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139242#comment-15139242 ]
Cody Koeninger commented on SPARK-13106: ---------------------------------------- https://issues.apache.org/jira/browse/SPARK-10963 was resolved, making the KafkaCluster methods for accessing offsets public. Hopefully that addresses this issue as well. > KafkaUtils.createDirectStream method with messageHandler and topics > ------------------------------------------------------------------- > > Key: SPARK-13106 > URL: https://issues.apache.org/jira/browse/SPARK-13106 > Project: Spark > Issue Type: Improvement > Components: Streaming > Reporter: Luis Alves > Labels: newbie > > Regarding the KafkaUtils.createDirectStream method here: > https://github.com/apache/spark/blob/master/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala#L473 > I purpose to also allow to pass the a messageHandler as argument instead of > using the one that is setted inside the method: > {code} > val messageHandler = (mmd: MessageAndMetadata[K, V]) => (mmd.key, > mmd.message) > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org