如上所述,我们使用的是kafka的axon(axonframework4.0)。我们有两项服务:
服务a
服务B
创建了一个公共库来保存 events
在这种情况下,只有一个简单的pojo @Revision(1.0) class DummyEvent(val id: String, val value: String)
这个图书馆 common.jar
是两者的依赖 ServiceA
以及 ServiceB
两者的application.yml几乎相同
axon:
kafka:
default-topic: axon-events
producer:
retries: 5
bootstrap-servers: localhost:9092
transaction-id-prefix: efcstx
consumer:
group-id: external-sync-group
bootstrap-servers: localhost:9092
distributed:
enabled: true
serializer:
messages: jackson
eventhandling:
processors:
common:
mode: tracking
source: kafkaMessageSource
当dummyevent从servicea触发时,我们可以看到它被发布到kafka,并且可以被servicea中的@eventhandler使用。serviceb无法处理事件。
当从serviceb触发事件时,会观察到相同的行为。事件已成功发布到kafka,可由serviceb中的@eventhandler使用,但在servicea中处理失败。
我们尝试了多种序列化方法,包括上面提到的方法。请尽你所能提出建议。
暂无答案!
目前还没有任何答案,快来回答吧!