Как создать новую тему с pykafka с разделами и репликацией?

Question

Я хочу иметь возможность программно создавать тему в Кафке, используя pykafka. Я знаю, что доступ к ThemeDict автоматически создаст тему, если ее не существует, но я не знаю, как управлять количеством разделов/реплик с этим. Кроме того, у него есть неприятная ошибка, когда он заканчивается бесконечным циклом, если Кафка опустится. В основном я хочу сделать что-то вроде следующего:

create_topic('mytopic', partitions=2, replicas=3) 

Answer 1

Pykafka является реализация Python производителя Кафки и потребительского API, что вы хотите достичь, это операция, которая в Кафки выполняется с помощью другого API, администрация/операции API (фактически группа классов Java). Я не думаю, что у Pykafka есть API/wrapper. То, что вы можете наблюдать, - это тема, автоматически создаваемая Кафкой. Что вы можете сделать, так это настроить с помощью свойств по умолчанию количество разделов и реплик для автоматически создаваемых тем.