Kafka Connect 데이터베이스 소스 커넥터 : 외래 키에서 데이터를 복사하는 방법
Ajkush
데이터베이스 소스 커넥터를 사용하여 Postgres 데이터베이스 테이블에서 Kafka 주제로 데이터를 이동하고 있습니다. customerNumber 필드를 사용하는 customers 테이블이있는 외래 키가있는 orders 테이블이 있습니다.
아래는 주문을 Kafka에 복사하지만 고객 데이터는 JSON으로 복사하지 않는 커넥터입니다. 고객과 함께 주문의 전체 개체를 JSON으로 구성하는 방법을 찾고 있습니다.
커넥터는 다음과 같습니다.
{
"name": "SOURCE_CONNECTOR",
"config": {
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"transforms.createKey.type": "org.apache.kafka.connect.transforms.ValueToKey",
"connection.password": "postgres_pwd",
"transforms.cast.type": "org.apache.kafka.connect.transforms.Cast$Value",
"transforms.cast.spec": "amount:float64",
"tasks.max": "1",
"transforms": "cast,createKey,extractInt",
"transforms.extractInt.type": "org.apache.kafka.connect.transforms.ExtractField$Key",
"batch.max.rows": "25",
"table.whitelist": "orders",
"mode": "bulk",
"topic.prefix": "data_",
"transforms.extractInt.field": "uuid",
"connection.user": "postgres_user",
"transforms.createKey.fields": "uuid",
"poll.interval.ms": "3600000",
"sql.quote.identifiers": "false",
"name": "SOURCE_CONNECTOR",
"numeric.mapping": "best_fit",
"connection.url": "url"
}
}
이 기사는 인터넷에서 수집됩니다. 재 인쇄 할 때 출처를 알려주십시오.
침해가 발생한 경우 연락 주시기 바랍니다[email protected] 삭제
에서 수정
관련 기사
Related 관련 기사
- 1
Debezium 및 Kafka Connect JDBC 싱크 커넥터를 사용하여 데이터베이스를 동기화 할 때 기본 키의 이름을 바꾸는 방법은 무엇입니까?
- 2
개인 데이터를 난독 화하기 위해 Kafka 소스 커넥터에서 사용자 지정 SMT를 작성하는 방법
- 3
JDBC Kafka 소스 커넥터에서 동적 스키마 이름을 설정하는 방법
- 4
Android 데이터베이스 도우미 클래스 외부의 데이터베이스에 데이터를 삽입하는 방법
- 5
Mule 3.5 데이터베이스 커넥터의 속성 파일에서 SQL 쿼리를 읽는 방법
- 6
데이터베이스에서 데이터를 찾는 방법
- 7
magento 데이터베이스에서 외래 키 복원
- 8
kubernetes 클러스터에서 실행되는 Kafka Connect 용 MongoDB 공식 소스 커넥터를 구성하는 방법
- 9
mysql 데이터베이스에서 스키마를 복제하는 방법
- 10
Asp.Net MVC에서 데이터베이스에 데이터를 삽입 할 때 외래 키 값을 설정하는 방법
- 11
한 데이터베이스에서 다른 데이터베이스로 모든 데이터베이스 사용자를 복사하는 방법
- 12
AdonisJs에서 외래 키로 데이터베이스에 저장하는 방법을 잘 모르겠습니다.
- 13
데이터베이스에 데이터를 삽입하는 방법? -사용자 정의 클래스
- 14
PHP를 통해 외래 키가있는 데이터베이스, 테이블에 데이터를 삽입하는 방법
- 15
Laravel 5.2-다른 테이블 형식으로 외부 데이터베이스에서 사용자 데이터를 복사하는 방법
- 16
PHP SQL : 하나의 HTML 형식에서 여러 데이터베이스에 데이터를 저장하는 방법 또는 한 데이터베이스에서 다른 데이터베이스로 데이터를 자동으로 복사하는 방법
- 17
Android Studio에서 SQL 데이터베이스의 막대 그래프에 데이터를 표시하는 방법
- 18
debezium kafka connect에서받은 CDC 이벤트에서 테이블 이름과 데이터베이스 이름을 가져 오는 방법
- 19
복사하지 않고 자산의 데이터베이스에서 데이터를 읽는 방법
- 20
PropertyBag 클래스를 데이터베이스에 저장하는 방법
- 21
Rails에서 데이터베이스에 데이터를 저장하는 방법
- 22
Heroku의 데이터베이스에서 로컬 데이터베이스로 데이터를 복사하는 방법
- 23
java 데이터베이스에서 데이터를 검색하는 방법
- 24
데이터베이스 Phalcon PHP에서 데이터를 검색하는 방법
- 25
phpmyadmin 데이터베이스에서 XML 데이터를 실행하는 방법
- 26
Ionic에서 Laravel 데이터베이스 데이터를 표시하는 방법
- 27
데이터베이스의 외래 키
- 28
외부 postgresql 데이터베이스를 Django Rest에 연결하는 방법
- 29
phpfox에 외부 데이터베이스를 포함하는 방법
몇 마디 만하겠습니다