package com.duxinglangzi.canal.starter.annotation;
|
|
|
import com.alibaba.otter.canal.protocol.CanalEntry;
|
|
import java.lang.annotation.ElementType;
|
import java.lang.annotation.Retention;
|
import java.lang.annotation.RetentionPolicy;
|
import java.lang.annotation.Target;
|
|
|
/**
|
* @author wuqiong 2022/4/11
|
*/
|
@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
|
@Retention(RetentionPolicy.RUNTIME)
|
public @interface CanalListener {
|
|
|
/**
|
* 如果未进行配置，则使用配置文件里全部 destination
|
*/
|
String destination() default "";
|
|
/**
|
* 数据库名
|
*/
|
String database() default "";
|
|
/**
|
* 数据表名
|
*/
|
String[] table() default "";
|
|
/**
|
* 数据变动类型，此处请注意，默认不包含 DDL
|
*/
|
CanalEntry.EventType[] eventType();
|
|
|
}
|
