Как изменить конфигурацию темы с помощью Increal_alter_configs? ⇐ Python

[Anonymous]

Я пытаюсь создать скрипт Python для автоматизации создания и настройки тем.
Мне удалось заставить работать часть создания тем. Я получаю ошибку времени выполнения при попытке изменить конфигурацию.

Код: Выделить всё

ValueError: expected non-empty list of ConfigEntry to alter incrementally in incremental_configs field

Вот мой код:

Код: Выделить всё

config = {
'min.insync.replicas': '3'
}

resource = ConfigResource(ResourceType.TOPIC, name=topic_name, set_config=config, described_configs=None)

futures = admin_client.incremental_alter_configs(resources=[resource])

for config_resource, future in futures.items():
try:
future.result()
print(f'Updated topic config for topic {config_resource}')
except Exception as exception:
print(f'Failed to update topic config for topic {config_resource}, {exception}')

Мне было довольно трудно следовать документации.
Я создал этот код на основе этого примера. Судя по прочтению документации, изменение конфигурации можно выполнить аналогично созданию темы. Я не совсем понимаю, в чем дело.

Подробнее здесь: https://stackoverflow.com/questions/779 ... er-configs