flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From AndreaKinn <kinn6...@hotmail.it>
Subject Can't get keyed messages from Kafka
Date Tue, 13 Jun 2017 10:36:23 GMT
Hi, 
I already spent two days trying to get simple messages from Kafka without
success.

I have a Kafka producer written in javascript:

KeyedMessage = kafka.KeyedMessage;
keyed_message = new KeyedMessage(key, string_to_sent);
payload = [{topics: topic, messages: keyed_message }];

And I want to retrieve key and message in Flink. Firstly I have used
SimpleStringSchema (just to verify if string was correctly deserialized) and
works correctly ignoring the key.
Now I absolutely need to get also the key to group messages on key basis but
I don't find any keyed deserializer which help me. If I understand
TypeSchema is used just for flink_to_flink communication and JSONSchema
obviously doesn't fit my needs.



--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Can-t-get-keyed-messages-from-Kafka-tp13687.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Mime
View raw message