optional run syncInit.py to send all oracle table-data into kafka
# python syncInit.py
Usage: python syncInit.py [option] <table_name>
forceDrop Force to DROP MySQL Table
insertAll Insert all rows from oracle to kafka
optional run util_compile.py to get a executable release
# python util_compile.py
environments
items
Source
Destination
IP
192.168.1.88
192.168.1.157
User
oracle
root
DB
Oracle 11.2
MySQL5.7
OGG
OGG 12.1.2.1.0 for 11.2
OGG bd 12.3.2.1.1
Kafka
-
Kafka_2.11-2.4.0
python 3.7.7:
# wget -c https://www.python.org/ftp/python/3.7.7/Python-3.7.7.tgz# tar -zxvf python-3.7.7.tgz# cd python-3.7.7# mkdir -p /usr/local/python3# ./configure --prefix=/usr/local/python3# make && make install# ln -s /usr/local/python3/bin/python3 /usr/local/bin/python3# ln -s /usr/local/python3/bin/pip3 /usr/local/bin/pip3# python3 -V# pip3 --version