feat:kafka

app/src/main/java/com/jiejing/fitness/finance/app/FitnessFinanceApplication.java

@@ -3,10 +3,12 @@ package com.jiejing.fitness.finance.app;
 import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure;
 import com.jiejing.common.config.idgen.EnableLeaseIdWorker;
 import com.jiejing.filecenter.api.common.event.ResourceEvent;
+import com.jiejing.fitness.finance.service.event.ListenerService;
 import com.jiejing.paycenter.common.event.MerchantEvent;
 import com.jiejing.paycenter.common.event.MerchantSubChannelConfigEvent;
 import com.jiejing.paycenter.common.event.PayEvent;
 import com.xiaomai.event.annotation.EnableEventBinding;
+import com.xiaomai.event.annotation.EventConfig;
 import lombok.extern.slf4j.Slf4j;
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
@@ -24,12 +26,13 @@ import org.springframework.scheduling.annotation.EnableScheduling;
 @EnableScheduling
 @EnableLeaseIdWorker
 @MapperScan(value = {"com.jiejing.fitness.finance.repository.mapper"})
-@EnableEventBinding(listenerClass = {
-    PayEvent.class,
-    MerchantEvent.class,
-    MerchantSubChannelConfigEvent.class,
-    ResourceEvent.class
-})
+@EnableEventBinding(
+    configs = {
+        @EventConfig(event = PayEvent.class, binder = "biz-kafka"),
+        @EventConfig(event = MerchantEvent.class, binder = "biz-kafka"),
+        @EventConfig(event = MerchantSubChannelConfigEvent.class, binder = "biz-kafka")
+    },
+    listenerClass = {ListenerService.class})
 @EnableFeignClients(basePackages = {
     "com.jiejing.filecenter.api",
     "com.jiejing.paycenter.api",