Micronaut Kafka Listener 多主题

Question

我想为多个主题创建一个 KakfaListener。所有主题均以“masterdata”开头，例如：

masterdata.product
masterdata.supplier

我尝试实现主题模式，但它不起作用：

@KafkaListener(offsetReset = OffsetReset.EARLIEST)
    static class AnalyticsListener {

        @Topic(patterns="masterdata*")
        void updateAnalytics(String item, String topic) {
            received.add(topic);
        }
    }

有什么建议吗？

Answer 1

您的模式匹配 masterdat、materdata、masetdataa 等。a* 表示 零个或多个 a .

尝试使用 masterdata\.[a-z]+

Micronaut Kafka Listener 多主题

Micronaut Kafka Listener multi topic

java

regex

apache-kafka

micronaut