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
Hi Robert ,
Hi
I have java program to send data into kafka topic. below is code for this :
private Producer producer = null
Serializer keySerializer = new StringSerializer();
Serializer valueSerializer = new ByteArraySerializer();
producer = new KafkaProducer(props, keySerializer,
valueSerializ
Hi
Thanks for the answer , then how can i measure the performance of flink ?
i want to run my application with both spark and flink . and want to
measure the performance . so i can check how fast flink process my data as
compare to spark.
Regards
prateek
On Mon, May 9, 2016 at 2:17 AM, Ufuk Cele
