Regex для подписки на канал в Python - PullRequest
Новая
       44

Regex для подписки на канал в Python

0 голосов
/ 06 июня 2019

Я хочу совпасть с шаблоном подписки на канал kafka, в котором изменено предварительное исправление в коде пользователя python kafka.

Например: 

testsetup-test-topic
prodsetup-test-topic

Я попробовал следующее 

c.subscribe(["*test-topic"])
But didnt get the message at the consumer.

Тогда 

c.subscribe(["^*test-topic"])
But got the following error

KafkaException: KafkaError {code = _INVALID_ARG, val = -186, str = "Не удалось установить подписку: Local: неверный аргумент или конфигурация"} Не могли бы вы, пожалуйстапомогите мне в вышесказанном? 

c.subscribe(["*test-topic"])

c.subscribe(["^*test-topic"])
...