kafkaconnect_avro.properties

bootstrap.servers=localhost:9092

key.converter=io.confluent.connect.avro.AvroConverter  
value.converter=io.confluent.connect.avro.AvroConverter  
key.converter.schema.registry.url=http://localhost:8081  
value.converter.schema.registry.url=http://localhost:8081

kafkaconnect_handler_avro.props

gg.handlerlist=kafkaconnect

#The handler properties  
gg.handler.kafkaconnect.type=kafkaconnect  
gg.handler.kafkaconnect.kafkaProducerConfigFile=kafkaconnect_avro.properties
# 'table' is a reserved word in KSQL and its presence in the Avro schema makes it barf. 
# Plus, we have the tablename in the topic name anyway.
gg.handler.kafkaconnect.includeTableName	

# See http://docs.oracle.com/goldengate/bd123110/gg-bd/GADBD/using-kafka-connect-handler.htm#GUID-A87CAFFA-DACF-43A0-8C6C-5C64B578D606  
gg.handler.kafkaconnect.topicMappingTemplate=ora-ogg-${schemaName}-${tableName}-avro  
gg.handler.kafkaconnect.keyMappingTemplate=${primaryKeys}

goldengate.userexit.timestamp=utc  
goldengate.userexit.writers=javawriter  
javawriter.stats.display=TRUE  
javawriter.stats.full=TRUE

gg.log=log4j  
gg.log.level=INFO  
gg.report.time=30sec

gg.classpath=dirprm/:/usr/share/java/kafka-serde-tools/*:/usr/share/java/kafka/*:/usr/share/java/confluent-common/*

javawriter.bootoptions=-Xmx512m -Xms32m -Djava.class.path=.:ggjava/ggjava.jar:./dirprm

rkafavro.prm

REPLICAT rkafavro  
TARGETDB LIBFILE libggjava.so SET property=dirprm/kafkaconnect_handler_avro.props  
REPORTCOUNT EVERY 1 MINUTES, RATE  
GROUPTRANSOPS 1000  
MAP *.*.*, TARGET *.*.*;