You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "Thukarama Prabhu (JIRA)" <ji...@apache.org> on 2016/07/29 18:16:20 UTC
[jira] [Created] (SPARK-16799) KafkaDirectStream issue with java
Thukarama Prabhu created SPARK-16799:
----------------------------------------
Summary: KafkaDirectStream issue with java
Key: SPARK-16799
URL: https://issues.apache.org/jira/browse/SPARK-16799
Project: Spark
Issue Type: Bug
Environment: Development
Reporter: Thukarama Prabhu
I am using kafkaDirectStream API to pull data from kafka topicfrom specified offset. I found below API but could not get this worked for me. I could not find any samples online. Could you please provide some sample to resolve this issue.
public static <K,V,KD extends kafka.serializer.Decoder<K>,VD extends kafka.serializer.Decoder<V>,R> JavaInputDStream<R> createDirectStream(JavaStreamingContext jssc,
java.lang.Class<K> keyClass,
java.lang.Class<V> valueClass,
java.lang.Class<KD> keyDecoderClass,
java.lang.Class<VD> valueDecoderClass,
java.lang.Class<R> recordClass,
java.util.Map<java.lang.String,java.lang.String> kafkaParams,
java.util.Map<kafka.common.TopicAndPartition,java.lang.Long> fromOffsets,
Function<kafka.message.MessageAndMetadata<K,V>,R> messageHandler)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org