正在处理命令端事件,但未调用查询(投影仪)。使用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
1条答案
按热度按时间px9o7tmv1#
为使此配置正常工作,包含
@EventHandler
要调用带注解的函数来处理来自kafka的事件,需要将其作为处理组的一部分query
.这个需求遵循您选择的配置模式,其中“axon。eventhandling.processors.query“定义要配置的处理组。要指定处理组,我认为最简单的方法是添加
@ProcessingGroup
事件处理类的注解。在注解中,您必须提供处理组的名称,该名称需要与您在配置文件中设置的名称相对应。最后,我建议使用不同的名称
query
为您的处理组。一些更具体的查询模型,事件处理程序更新似乎更适合我。希望这有帮助!