问题描述
因此,我有一种情况想与我所订阅主题的模式相匹配。我主题的结构是3部分的“ part1.part2.part3”,例如DbServerName.Domain.DbTableName。
现在根据这篇文章https://github.com/confluentinc/confluent-kafka-dotnet/issues/245,如果我在主题名称前添加“ ^”,则应该可以。
所以consumer.Subscribe("^")
工作正常-给出所有主题consumer.Subscribe("^DbServerName.public.DbTableName")
也工作正常。
但是,如果我想将主题仅与DbTableName匹配,而无论DbserverName和域可能是什么,都将无效
所以
consumer.Subscribe("^.^.tableName")
不起作用
consumer.Subscribe("^tablename")
也不起作用。
关于如何实现此功能的任何建议将不胜感激。欢呼!!
解决方法
根据描述,^
是一个功能切换,因此模式将是
"^" + ".*tablename"