public void close()

in src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalog.java [127:135]

• 9 lines of code
• 3 McCabe index (conditional complexity)

    public void close() throws CatalogException {
        if (Objects.nonNull(mqAdminExt)) {
            mqAdminExt.shutdown();
            mqAdminExt = null;
        }
        if (Objects.nonNull(schemaRegistryClient)) {
            schemaRegistryClient = null;
        }
    }