Skip to content

Instantly share code, notes, and snippets.

@rmoff

rmoff/kafkaconnect_avro.properties

Last active September 30, 2022 06:54
Show Gist options
  • Star 2 You must be signed in to star a gist
  • Fork 1 You must be signed in to fork a gist
  • Save rmoff/221b4a1903a85568042e3a1b9b07ab95 to your computer and use it in GitHub Desktop.
Save rmoff/221b4a1903a85568042e3a1b9b07ab95 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
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
Raw
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
Raw
rkafavro.prm
REPLICAT rkafavro
TARGETDB LIBFILE libggjava.so SET property=dirprm/kafkaconnect_handler_avro.props
REPORTCOUNT EVERY 1 MINUTES, RATE
GROUPTRANSOPS 1000
MAP *.*.*, TARGET *.*.*;
@Gk8143197049
Copy link

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.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment