can i add or remove table in running state??

18 views
Skip to first unread message

최동주

unread,
Jan 19, 2022, 2:13:11 AMJan 19
to debezium
i'm trying with debezium signal

insert into debezium_signal values('test','execute-snapshot','{"data-collections": ["neos_1234.add_table"]}');

connect-log
Schema not found for table 'neos_1234.add_table', known tables [my table list ...]

but this is not working

how to add table in running state debezium???


my config 

{
"name" : "test",
"config" : {
"include.schema.changes":"true",
"snapshot.mode":"when_needed",
"connector.class" : "io.debezium.connector.mysql.MySqlConnector",
"database.hostname" : "ip",
"database.port" : "port",
"database.user":"id",
"database.password":"pwd",
"database.server.id":"51013",
"database.server.name":"klagoDev_local_test",
"database.history.kafka.bootstrap.servers":"localhost:9092,localhost:9093,localhost:9094",
"database.history.kafka.topic":"history_local_test",
"database.include.list":"neos_1234",
"table.include.list":
"neos_1234.debezium_signal,neos_1234.t_co_emp,neos_1234.t_co_dept,neos_1234.t_co_auth_relate,neos_1234.t_co_authcode,neos_1234.t_co_biz,neos_1234.t_co_code,neos_1234.t_co_code_detail,neos_1234.t_co_comment_count,neos_1234.t_co_comp,neos_1234.t_co_emp_comp,neos_1234.t_co_emp_dept,neos_1234.t_co_group,neos_1234.t_co_group_path,neos_1234.t_co_groupping,neos_1234.t_co_groupping_comp,neos_1234.t_co_menu,neos_1234.t_co_menu_auth,neos_1234.t_co_menu_favorite,neos_1234.t_co_multi_name,neos_1234.t_co_orgchart_name,neos_1234.tcmg_option_history,neos_1234.tcmg_optionset,neos_1234.tcmg_optionvalue,neos_1234.titg_code,neos_1234.titg_customset,neos_1234.titg_item,neos_1234.titg_itemset",
"database.serverTimezone":"Asia/Seoul",
"tasks.max":"1",

"transforms":"unwrap,route",
"transforms.unwrap.type":"io.debezium.transforms.ExtractNewRecordState",
"transforms.unwrap.add.fields":"op,table,db,snapshot",
"transforms.unwrap.delete.handling.mode":"rewrite",
"transforms.route.type":"org.apache.kafka.connect.transforms.RegexRouter",
"transforms.route.regex":"([^.]+)\\.([^.]+)\\.([^.]+)",
"transforms.route.replacement":"local_test",
"decimal.handling.mode":"double",
"signal.data.collection":"neos_1234.debezium_signal"
}
}
Reply all
Reply to author
Forward
0 new messages