flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From prateek arora <prateek.arora...@gmail.com>
Subject How to fetch kafka Message have [KEY,VALUE] pair
Date Thu, 21 Apr 2016 22:02:44 GMT
Hi

I am new for Apache Flink and start  using Flink version 1.0.1

In my scenario,   kafka message have key value pair [String,Array[Byte]] .

I tried to use FlinkKafkaConsumer08 to fetch data but i dont know how to
write  DeserializationSchema for that.

val stream : DataStream[(String,Array[Byte])]  = env.addSource(new
FlinkKafkaConsumer08[(String,Array[Byte])]("a-0",<DeserializationSchema> ,
properties))

please help me to solve this problem .

Regards
Prateek

Mime
View raw message