code: def _get_stream_schema(fields):
      
      stream_schema = topology_pb2.StreamSchema()
      for field in fields:
        key = stream_schema.keys.add()
        key.key = field
        key.type = topology_pb2.Type.Value("OBJECT")
  
      return stream_schema
docs: Returns a StreamSchema protobuf message