Hi,
I'm trying to use KafkaUtils.createDirectStream to read avro messages from
Kafka but something is off with my type arguments:
val avroStream = KafkaUtils.createDirectStream[AvroKey[GenericRecord],
GenericRecord, NullWritable, AvroInputFormat[GenericRecord]](ssc,
kafkaParams, topicSet)
I'm
Your third and fourth type parameters need to be subclasses of
kafka.serializer.Decoder
On Thu, Sep 24, 2015 at 10:30 AM, Daniel Haviv <
daniel.ha...@veracity-group.com> wrote:
> Hi,
> I'm trying to use KafkaUtils.createDirectStream to read avro messages from
> Kafka but something is off with my
