Confluent.net 中的模式匹配
Pattern Matching in Confluent.net
所以,我有一种情况,我想匹配我订阅的主题的模式。我的主题结构是 3 部分“part1.part2.part3”,例如DbServerName.Domain.DbTableName.
现在根据这个 post 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"
所以,我有一种情况,我想匹配我订阅的主题的模式。我的主题结构是 3 部分“part1.part2.part3”,例如DbServerName.Domain.DbTableName.
现在根据这个 post 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"