public NewTopicBuilder compacted() {
            this.configs.put(CLEANUP_POLICY_CONFIG, CLEANUP_POLICY_COMPACT);
            return this;
        }
Specify that the topic should be compacted.

@return this builder to allow methods to be chained; never null
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java