axon4-kafka ext:未调用查询事件

wkyowqbh  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(377)

正在处理命令端事件,但未调用查询(投影仪)。使用axon kafka扩展4.0-rc2。
请检查以下代码参考。
轴对称

import org.springframework.context.annotation.Configuration;

@Configuration
public class AxonConfig {

}

应用程序.yml

server:
  port: 9001
spring:
  application:
    name: Query Application
  datasource:
    url: jdbc:postgresql://localhost:5441/orderdemo
    username: orderdemo
    password: secret
    driver-class-name: org.postgresql.Driver
  jpa:
    properties:
      hibernate:
        dialect: org.hibernate.dialect.PostgreSQL95Dialect
        jdbc:
          lob:
            non_contextual_creation: true
        hbm2ddl.auto: update
        implicit_naming_strategy: org.springframework.boot.orm.jpa.hibernate.SpringImplicitNamingStrategy
        physical_naming_strategy: org.springframework.boot.orm.jpa.hibernate.SpringPhysicalNamingStrategy    

axon:
  eventhandling:
    processors:
      query:
        mode: tracking
        source: kafkaMessageSource
  kafka:
    default-topic: axon-events
    consumer:
      group-id: query-group
      bootstrap-servers: localhost:9092
px9o7tmv

px9o7tmv1#

为使此配置正常工作,包含 @EventHandler 要调用带注解的函数来处理来自kafka的事件,需要将其作为处理组的一部分 query .
这个需求遵循您选择的配置模式,其中“axon。eventhandling.processors.query“定义要配置的处理组。要指定处理组,我认为最简单的方法是添加 @ProcessingGroup 事件处理类的注解。在注解中,您必须提供处理组的名称,该名称需要与您在配置文件中设置的名称相对应。
最后,我建议使用不同的名称 query 为您的处理组。一些更具体的查询模型,事件处理程序更新似乎更适合我。
希望这有帮助!

相关问题