Yes, backwards incompatibility is a problem when using Java/Scala object serialization. At LinkedIn, we use Avro as the serialization format for Kafka data.
Thanks, Neha On Tue, Jun 17, 2014 at 11:58 AM, S Ahmed <sahmed1...@gmail.com> wrote: > My app is in scala and a quick search on serializing a scala class seems to > have potential issues with different versions of scala (I could be wrong as > I did a quick search). > > Is it generally just a better idea to use plain old java classes for kafka > messages? > > i.e. I simply use jackson like: > > public class User implements Serializable { > ... > } > > // kakfa > val it = stream.iterator() > while (it.hasNext()) { > val messageAndTopic = it.next > > val user = mapper.readValue(messageAndTopic.message(), classOf[User]) >