Kafka, Kafka Consumer, Kafka Producer, Confluent Kafka, Streaming.
'key_serializer': lambda key: key.encode('utf-8'), 'value_serializer': lambda value: value.encode('utf-8') } As you can expect, we can specify deserializer settings on the consumer side similarly. The serializer and deserializer jobs differ based on the primitive type we are working with.