samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Michael Strobl <>
Subject Offset (counter) as String - why?
Date Thu, 28 May 2015 15:07:17 GMT
Hey Samza team!

Please, can you explain me, why the offset counter in the IncomingMessageEnvelope is stored
as a String attribute and not Long? As far as I know in Kafka the offset counter is long.
Can I simply cast the String offset to long (have to work in my job with it) or does Samza
modify (sometimes) this Kafka offset and therefore it is a String?

Thanks for helping,

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message