OGG 동기 화 Oracle 마스터 키 없 이 Kafka 로
extract etest10
GETUPDATEBEFORES
NOCOMPRESSDELETES
NOCOMPRESSUPDATES
TranlogOptions DBLOGREADER
userid ogg_admin, password ogg_admin
exttrail /ogg/dirdat/th
table DBUS.TESTP5;
table DBUS.TESTP6,tokens(zeta_row_id= @GETENV('RECORD',' ROWID'));
table DBUS.TESTP7;
extract ptest10
passthru
userid ogg_admin, password ogg_admin
rmthost 10.10.10.206, mgrport 7890
rmttrail /ogg/dirdat/th
table DBUS.TESTP5;
table DBUS.TESTP6,tokens(zeta_row_id= @GETENV('RECORD', 'ROWID'));
table DBUS.TESTP7;
###
gg.handler.kafkahandler.includeTokens=true
test10#DBUS.TESTP5 {"table":"DBUS.TESTP5","op_type":"I","op_ts":"2019-09-27 14:52:25.452507","current_ts":"2019-09-27T14:52:31.093000","pos":"00000000080000006329","primary_keys":["ID"],"tokens":{},"after":{"ID":80478,"NAME":"name-80479","AGE":80479,"BIRTHDAY":"2019-08-02 10:00:00","HIGH":180,"SALARY":99,"MIAOSHU":null,"CL":"80479","CC":" ， ， ， ， ， ， ， ","CTSDMP":"2019-08-02 10:00:00.000000000","ADDC1":null,"ADDC2":null,"ADDC3":null}}
test10#DBUS.TESTP6 {"table":"DBUS.TESTP6","op_type":"I","op_ts":"2019-09-27 14:49:10.462259","current_ts":"2019-09-27T14:49:17.220000","pos":"00000000080000002095","primary_keys":["ID","NAME","DD","FF"],"tokens":{"zeta_row_id":"AAAb3AABEAAAA7uAAC"},"after":{"ID":444,"NAME":"eee","DD":"fgdf","FF":null}}
참고: GETENV 학습
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Spark 의 -- Spark Submit 제출 프로그램 상세 설명이 스 크 립 트 는 Spark 류 경로 (classpath) 와 응용 프로그램 의존 패 키 지 를 설정 할 수 있 고 서로 다른 Spark 가 지원 하 는 클 러 스 터 관리 와 배치 모드 를 설정 할 수 있 습 ...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
