KafkaKafka汉德勒金门适配器

ct2axkht  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(362)
ERROR [main] (DsHandler.java:293) - Unable to set property on handler 'kafkahandler' (oracle.goldengate.handler.kafka.KafkaHandler). Failed to set property: T
opicName:="test" (class: oracle.goldengate.handler.kafka.KafkaHandler).
oracle.goldengate.util.ConfigException: Failed to set property: TopicName:="test" (class: oracle.goldengate.handler.kafka.KafkaHandler).
    at oracle.goldengate.util.PropertyWrapper.setProperty(PropertyWrapper.java:365)
    at oracle.goldengate.util.PropertyWrapper.setProperties(PropertyWrapper.java:342)
    at oracle.goldengate.datasource.conf.DsHandler.initListener(DsHandler.java:289)
    at oracle.goldengate.datasource.conf.DsHandler.getDataSourceListener(DsHandler.java:259)
    at oracle.goldengate.datasource.factory.DataSourceFactory.getHandlers(DataSourceFactory.java:264)
    at oracle.goldengate.datasource.factory.DataSourceFactory.getDataSource(DataSourceFactory.java:157)
    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)
    at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:588)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:
1123)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1018)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:510)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:482)
    at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:306)
    at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230)
    at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:302)
    at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197)
    at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1051)
    at oracle.goldengate.datasource.DataSourceLauncher.<init>(DataSourceLauncher.java:161)
    at oracle.goldengate.datasource.UserExitMain.main(UserExitMain.java:108)
txu3uszq

txu3uszq1#

我尝试使用金门适配器版本12.3.0.1.0将数据从oracle数据库移动到kafka
新版本中没有主题名

下面使用短表名解析主题名

gg.handler.kafkahandler.topicmappingtemplate=测试
在以前的版本中,我们有gg.handler.kafkahandler.topicname=test

相关问题