I see two possible options here: Considering backward compatibility, I believe that having two utility methods would be ok, but this can start making things grow and become hard to maintain and a little inflexible in the long run.
The other option would be to use generics for the key and type of the messages, similar to what is used on Kafka 0.10 streaming connector (e.g. def createDirectStream[K, V] ) Thoughts ? On Wed, Jul 5, 2017 at 4:01 AM, Rosenstark, David < david.rosenst...@intel.com> wrote: > There is an assumption that all data that arrives via MQTT is ASCII. In > our case we have a binary payload. If I want to add this functionality, can > we change existing functionality or add new one? > > --------------------------------------------------------------------- > Intel Electronics Ltd. > > This e-mail and any attachments may contain confidential material for > the sole use of the intended recipient(s). Any review or distribution > by others is strictly prohibited. If you are not the intended > recipient, please contact the sender and delete all copies. > -- Luciano Resende http://twitter.com/lresende1975 http://lresende.blogspot.com/
