轴突4.0与Kafka第二次服务未处理事件

sbdsn5lh  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(238)

如上所述,我们使用的是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中处理失败。
我们尝试了多种序列化方法,包括上面提到的方法。请尽你所能提出建议。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题