def _get_comp_config(self):
proto_config = topology_pb2.Config()<EOL>key = proto_config.kvs.add()<EOL>key.key = TOPOLOGY_COMPONENT_PARALLELISM<EOL>key.value = str(self.parallelism)<EOL>key.type = topology_pb2.ConfigValueType.Value("<STR_LIT>")<EOL>if self.custom_config is not None:<EOL><INDENT>sanitized = self._sanitize_config(self.custom_config)<EOL>for key, value in sanitized.items():<EOL><INDENT>if isinstance(value, str):<EOL><INDENT>kvs = proto_config.kvs.add()<EOL>kvs.key = key<EOL>kvs.value = value<EOL>kvs.type = topology_pb2.ConfigValueType.Value("<STR_LIT>")<EOL><DEDENT>else:<EOL><INDENT>kvs = proto_config.kvs.add()<EOL>kvs.key = key<EOL>kvs.serialized_value = default_serializer.serialize(value)<EOL>kvs.type = topology_pb2.ConfigValueType.Value("<STR_LIT>")<EOL><DEDENT><DEDENT><DEDENT>return proto_config<EOL>
Returns component-specific Config protobuf message

        It first adds ``topology.component.parallelism``, and is overriden by
        a user-defined component-specific configuration, specified by spec().