topic.blacklist配置的用途是什么？

Question

我没有完全理解主题黑名单配置的用例。你能举例说明它什么时候可以使用吗？(PS:我知道它是用来忽略元数据信息中的一些主题的，只是不确定它是否是一种过滤机制？)如果可能，请详细说明。谢谢!

Answer 1

假设我有六个主题: abc，acd，bcd，test1，test2，test3。如果我想编写一个使用后三个参数的消费者，我可以这样写：

TopicFilter filter =新建黑名单(“a.*，b.*")；

int threadNumber = xxx；

streams = connector.createMessageStreamsByFilter(filter，threadNumber)；...

这将只消耗后三个主题，而忽略前三个主题。我之所以可以在正则表达式中使用逗号，是因为Kafka将其替换为'|‘符号，以表达OR逻辑。