본문 바로가기

Open Source

 (32)
JDBC Sink Connector For Oracle { "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector", "transforms.TimestampConverter.target.type": "Timestamp", "connection.password": "******", "transforms.TimestampConverter.field": "update_date", "tasks.max": "1", "transforms": "unwrap, route, TimestampConverter", "tombstones.on.delete": "true", "transforms.route.type": "org.apache.kafka.connect.transforms.RegexRouter", "schema...
JDBC Sink Connector For My Sql { "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector", "transforms.TimestampConverter.target.type": "Timestamp", "connection.password": "******", "transforms.TimestampConverter.field": "update_date", "tasks.max": "1", "transforms": "unwrap, route, TimestampConverter", "tombstones.on.delete": "true", "transforms.route.type": "org.apache.kafka.connect.transforms.RegexRouter", "schema...
Kafka Connect에 어떤 플러그인이 설치되었나 확인하기 카르카 커넥트가 설치되어있다면 http://localhost:8083/connector-plugins 호출해 보자 아래의 그림과 같이 리스트가 나온다 필자의 경우는 JdbcInkConnector, OracleSourceConnector,PostgresConnector,FileStreamSourceConnector등이 있다.
Kafaka Source Connector 특정 Table만 snapshot뜨기 Source Connector Configuration에서 아래의 요소만 추가해 주면 된다. 테이블은 콤마 구분자로 여러개 등록 할수 있다. "table.whitelist": "customer", { "connector.class": "io.debezium.connector.postgresql.PostgresConnector", "database.user": "UserName", "database.dbname": "postgres", "slot.name": "slot1", "database.server.name": "postgre_source", "plugin.name": "pgoutput", "value.converter.schema.registry.url": "http://schema-registry..
Debezium Build GitHub - debezium/debezium: Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ. git clone 하자 Git 2.2.1 or later JDK 17 or later, e.g. OpenJDK Docker Engine or Docker Desktop 1.9 or later Apache Maven 3.8.4 or later (or invoke the wrapper with ./mvnw for Maven commands) 위의 조건을 충족해야한다. mvn dependency:purge-local-repository pom.xml 에 명시된 depend..
Debezium Git 주소 GitHub - debezium/debezium: Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.
Debezium For Oracle oracle db 설정 Oracle Database Prerequisites | Confluent Documentation grant select_catalog_role to myuser; 해당 권한도 준다
Debezium CDC DataSource For Mysql 첨부된 프로젝트의 압축을 푼다. CMD창을 연다 DebeziumCDC\src\main\resources로 폴더를 이동한다. docker-compose -f docker-compose-mysql.yaml up 명령어를 실행한다. Docker에 my sql을 docker-compose를 통해 실행됨을 확인할 수 있다. 2개의 mysql서버가 구동되고 있다 하나는 source용 mysql:3305 다른 하나는 target용 mysql:3306이다 username : root password : root로 DBeaver에서 접속해 본다. DebeziumCDC\src\main\resources\customer.sql의 명령어를 차례대로 실행한다. customer테이블을 생성하고 springboot 프로젝트를 실행..

티스토리툴바