Hi,
I'm trying to run a kafka-stream and get a strange exception. The
streaming is created by following code:
val lines = KafkaUtils.createStream[String, VtrRecord,
StringDecoder, VtrRecordDeserializer](ssc, kafkaParams.toMap,
topicpMap, StorageLevel.MEMORY_AND_DISK_SER_2)
Hi,
I'm trying to run a kafka-stream and get a strange exception. The
streaming is created by following code:
val lines = KafkaUtils.createStream[String, VtrRecord,
StringDecoder, VtrRecordDeserializer](ssc, kafkaParams.toMap,
topicpMap, StorageLevel.MEMORY_AND_DISK_SER_2)
'VtrRecord' i
Hi,
I'm trying to run a kafka-stream and get a strange exception. The
streaming is created by following code:
val lines = KafkaUtils.createStream[String, VtrRecord,
StringDecoder, VtrRecordDeserializer](ssc, kafkaParams.toMap,
topicpMap, StorageLevel.MEMORY_AND_DISK_SER_2)
'VtrRecord' i