ksql CREATE SOURCE CONNECTOR

Giriş

Debezium Connector yaratır

Örnek

Şöyle yaparız. demo.demo.orders diye yeni bir topic yaratır

ksql> CREATE SOURCE CONNECTOR SOURCE_MYSQL_02 WITH ( 
    'connector.class' = 'io.debezium.connector.MySQL.MySQLConnector', 
    'database.hostname' = 'MySQL', 
    'database.port' = '3306', 
    'database.user' = 'mysql_user', 
    'database.password' = 'mysql_pw', 
    'database.server.id' = '1', 
    'database.server.name' = 'demo', 
    'table.whitelist' = 'demo.orders', 
    'database.history.Kafka.bootstrap.servers' = 'Kafka:29092', 
    'database.history.Kafka.topic' = 'orders' , 
    'include.schema.changes' = 'false', 
    'key.converter'= 'org.apache.Kafka.connect.storage.StringConverter', 
    'value.converter'= 'io.confluent.connect.avro.AvroConverter', 
    'value.converter.schema.registry.url'= 'http://schema-registry:8081' 
    ); 
 
Message 
----------------------------------- 
Created connector SOURCE_MYSQL_02