используйте подстановочный знак в темах Кафки, но Кафка не может его найти - PullRequest
0 голосов
/ 21 сентября 2019

Я использую kafka-node для подписки на события kafka.

  const Consumer = kafka.HighLevelConsumer;
  const client = new kafka.KafkaClient({kafkaHost: 'localhost:9092'});
  let consumer = new kafka.Consumer(
    client,
    [{ topic: "dbserver1.public.abc", partition: 0 }],
    {  autoCommit: true }
  );

Можно получать события из темы "dbserver1.public.abc", но поскольку производитель kafka может отправлять данныев нескольких темах, таких как "dbserver1.public.abc", "dbserver1.public.abc2" ... "dbserver1.public.abc-n".

Я хочу использовать подстановочный знак для подписки на тему "dbserver1.public. *».Итак, я попытался

  let consumer = new kafka.Consumer(
    client,
    [{ topic: "dbserver1.public.*", partition: 0 }],
    {  autoCommit: true }
  );

, но код выдает ошибку:

 { TopicsNotExistError: The topic(s) dbserver1.public.* do not exist

Мне интересно, поддерживает ли он использование подстановочного знака, если это так, как я могу это сделать?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...