public static void resetEstimation(String topic) {
        float[] compressionRatioForTopic = getAndCreateEstimationIfAbsent(topic);
        synchronized (compressionRatioForTopic) {
            for (CompressionType type : CompressionType.values()) {
                compressionRatioForTopic[type.id] = type.rate;
            }
        }
    }
Reset the compression ratio estimation to the initial values for a topic.
clients/src/main/java/org/apache/kafka/common/record/CompressionRatioEstimator.java