更改保留策略主题kafka

Question

我想将一个主题的默认保留时间更改为“rentation.ms=100”，但在python中找不到解决方案。有人能帮我吗，拜托

Answer 1

您可以使用confluent-kafka-pythonalter_configs（），kafka-python客户机当前已为alter_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)

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