如何按类型使用来自Kafka的消息

Question

我对Kafka很陌生，对它有一些疑问。我已经配置了一个kafka消费者来消费来自主题的消息，并且我有不同类型的事件进入主题。f、 e、。

class Event {
    String type;
    Object event;
}

我想配置不同的kafka监听器来消费不同类型的事件。我认为有两种方法可以做到这一点，比如使用字符串(json)格式的事件，转换成事件对象，在不同类型之间切换，执行业务逻辑，或者配置不同的kafka监听器工厂

    public ConcurrentKafkaListenerContainerFactory<String, String> businessEventStreamListenerContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, String> factory =
                new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(consumerFactory());
        factory.setRecordFilterStrategy(consumerRecord -> !consumerRecord.value().contains("typeOfObjectIWantToConsume"));
        return factory;
    }

因此，第一种方法不是 SOLID，对于第二种方法，我需要创建许多工厂类。有没有办法更优雅地做到这一点？

Answer 1

这种业务需求是我们引入< code>@KafkaHandler的真正原因。

在文档中查看更多信息：https://docs.spring.io/spring-kafka/docs/current/reference/html/#class-level-kafkalistener.