Hi Gordon, thank you for starting the discussion. I think in fact the KeyedDeserializationSchema is located in the wrong package. Its methods are very Kafka specific, maybe I should move them there.
How would the deserializationSchema for Kinesis look like? Does the Kinesis API return byte[] ? Is there any other information which is useful for users? On Tue, Jan 19, 2016 at 11:49 AM, Tzu-Li (Gordon) Tai <tzuli...@gmail.com> wrote: > Hi Max, > > Thanks for the quick response and clarification :) > I got a bit confused and thought that Flink internals would be accessing > this interface too. > > Cheers, > Gordon > > > > -- > View this message in context: > http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/What-is-the-topic-offset-used-for-in-KeyedDeserializationSchema-deserialize-tp9911p9914.html > Sent from the Apache Flink Mailing List archive. mailing list archive at > Nabble.com. >
