Я использую 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
Мне интересно, поддерживает ли он использование подстановочного знака, если это так, как я могу это сделать?