@staticmethod<EOL><INDENT>def _get_stream_schema(fields):<DEDENT>
stream_schema = topology_pb2.StreamSchema()<EOL>for field in fields:<EOL><INDENT>key = stream_schema.keys.add()<EOL>key.key = field<EOL>key.type = topology_pb2.Type.Value("<STR_LIT>")<EOL><DEDENT>return stream_schema<EOL>
Returns a StreamSchema protobuf message