将kafka的相关BEAN初始化配置，增加过滤器接口

@@ -6,6 +6,7 @@ import com.sunyo.wlpt.message.bus.service.mapper.MessageRouterReciverFilterMappe
 import com.sunyo.wlpt.message.bus.service.model.MessageRouter;
 import com.sunyo.wlpt.message.bus.service.model.MessageRouter;
 import com.sunyo.wlpt.message.bus.service.model.MessageRouterReciverFilter;
 import com.sunyo.wlpt.message.bus.service.model.MessageRouterReciverFilter;
 import com.sunyo.wlpt.message.bus.service.service.MessageRouterReciverFilterService;
 import com.sunyo.wlpt.message.bus.service.service.MessageRouterReciverFilterService;
+import com.sunyo.wlpt.message.bus.service.utils.IdUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
 
 
 import javax.annotation.Resource;
 import javax.annotation.Resource;
@@ -19,6 +20,7 @@ public class MessageRouterReciverFilterImpl implements MessageRouterReciverFilte
 
 
     @Override
     @Override
     public int addMessageRouterReciverFilter(MessageRouterReciverFilter messageRouterReciverFilter) {
     public int addMessageRouterReciverFilter(MessageRouterReciverFilter messageRouterReciverFilter) {
+        messageRouterReciverFilter.setId(IdUtils.generateId());
         return messageRouterReciverFilterMapper.insertSelective(messageRouterReciverFilter);
         return messageRouterReciverFilterMapper.insertSelective(messageRouterReciverFilter);
     }
     }