Last active
September 30, 2022 06:54
-
-
Save rmoff/221b4a1903a85568042e3a1b9b07ab95 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
REPLICAT rkafavro | |
TARGETDB LIBFILE libggjava.so SET property=dirprm/kafkaconnect_handler_avro.props | |
REPORTCOUNT EVERY 1 MINUTES, RATE | |
GROUPTRANSOPS 1000 | |
MAP *.*.*, TARGET *.*.*; |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
I am gettting this error:
oracle.goldengate.util.GGException: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'userExitDataSource' defined in class path resource [oracle/goldengate/datasource/DataSource-context.xml]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [oracle.goldengate.datasource.GGDataSource]: Factory method 'getDataSource' threw exception; nested exception is oracle.goldengate.util.ConfigException: Failed to load the Kafka producer properties file [kafka-producer-default.properties].
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'userExitDataSource' defined in class path resource [oracle/goldengate/datasource/DataSource-context.xml]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [oracle.goldengate.datasource.GGDataSource]: Factory method 'getDataSource' threw exception; nested exception is oracle.goldengate.util.ConfigException: Failed to load the Kafka producer properties file [kafka-producer-default.properties].
at oracle.goldengate.datasource.DataSourceLauncher.(DataSourceLauncher.java:168)
at oracle.goldengate.datasource.UserExitMain.main(UserExitMain.java:123)
Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [oracle.goldengate.datasource.GGDataSource]: Factory method 'getDataSource' threw exception; nested exception is oracle.goldengate.util.ConfigException: Failed to load the Kafka producer properties file [kafka-producer-default.properties].
at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:189)
at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:588)
... 11 more
Caused by: oracle.goldengate.util.ConfigException: Failed to load the Kafka producer properties file [kafka-producer-default.properties].
at oracle.goldengate.handler.kafkaconnect.KafkaConnectProperties.loadKafkaProperties(KafkaConnectProperties.java:78)
at oracle.goldengate.handler.kafkaconnect.KafkaConnectHandler.init(KafkaConnectHandler.java:67)
at oracle.goldengate.datasource.AbstractDataSource.addDataSourceListener(AbstractDataSource.java:591)
at oracle.goldengate.datasource.factory.DataSourceFactory.getDataSource(DataSourceFactory.java:161)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:162)
... 12 more
Caused by: java.lang.NullPointerException
at java.util.Properties$LineReader.readLine(Properties.java:434)
at java.util.Properties.load0(Properties.java:353)
at java.util.Properties.load(Properties.java:341)
at oracle.goldengate.handler.kafkaconnect.KafkaConnectProperties.loadKafkaProperties(KafkaConnectProperties.java:75)
... 20 more.