Added support for kafka message types (string and json)