This talk will cover the topics to serialize/deserialize the MQTT messages using google Protobuf and equivalent ScalaPB library, benefits of using Protobuf, pits in Spark Streaming and Spark streaming optimizations.