Kafka streams:将内部主题清理策略设置为删除不起作用

我想把 和改变 清理策略 到 以防止存储空间被填满。所以我在卡夫卡流代码中设置了以下配置:

Properties props = new Properties();
props.put(StreamsConfig.TOPIC_PREFIX + TopicConfig.RETENTION_BYTES_CONFIG, Constants.INTERNAL_TOPICS_RETENTION_BYTES);
props.put(StreamsConfig.TOPIC_PREFIX + TopicConfig.CLEANUP_POLICY_CONFIG, TopicConfig.CLEANUP_POLICY_DELETE);
KafkaStreams streams = new KafkaStreams(builder.build(), props);

但是,当生成新主题时, 保留配置将应用于新生成的内部主题,清理策略仍保留 契约 .

我用卡夫卡的版本 1.0.0 1.0.0