@Override
    public void close() {
        AtomicInteger atomicInteger = clientIdIndex.get(clientId);
        if (atomicInteger == null) {
            return;
        }
        atomicInteger.decrementAndGet();
    }
reduce the number of total producer when this one is closed.
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/PartitionerSelector.java