您可以使用合流的kafka python alter\u configs（），kafka python客户端当前已为alter\u configs（）中断

from kafka.admin import KafkaAdminClient, ConfigResource

admin_client = KafkaAdminClient(
    bootstrap_servers="localhost:9092", 
    client_id='test'
)

topic_list = []
topic_list.append(ConfigResource(restype='TOPIC','your_topic_name', set_config={"retention.ms":"1000"}, described_configs=None, error=None))
admin_client.alter_configs(resources=topic_list, validate_only=False)

注意：未包含的任何配置属性都将恢复为其默认值。这里的保留时间以毫秒为单位。