oggforbigdata 1221版本 kafka参数问题引起错误
oggforbigdata 版本为：Version 12.2.0.1.0kafka参数文件如下：
$ cat dirprm/kafka.props
gg.handlerlist = kafkahandler
gg.handler.kafkahandler.type = kafka
gg.handler.kafkahandler.KafkaProducerConfigFile = custom_kafka_producer.properties
gg.handler.kafkahandler.TopicName = tpmes
gg.handler.kafkahandler.BlockingSend = false
gg.handler.kafkahandler.includeTokens = true
gg.handler.kafkahandler.Mode = tx
gg.handler.kafkah andler.topicPartitioning = none
#json
gg.handler.kafkahandler.format = json
gg.handler.kafkahandler.format.insertOpKey = I
gg.handler.kafkahandler.format.updateOpKey = U
gg.handler.kafkahandler.format.deleteOpKey = D
gg.handler.kafkahandler.format.prettyPrint = true
gg.handler.kafkahandler.format.jsonDelimiter = CDATA[]
gg.handler.kafkahandler.format.generateSchema = true
gg.handler.kafkahandler.format.schemaDirectory = dirdef
#gg.handler.kafkahandler.format.treatAllColumnsAsString = true
gg.handler.kafkahandler.format.includePrimaryKeys = true
#gg.handler.kafkahandler.maxGroupSize =100, 1Mb
#gg.handler.kafkahandler.minGroupSize =50, 500Kb
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/:/home/ogg/kafka/libs/*
javawriter.bootoptions=-Xmx512m -Xms32m -Djava.class.path=ggjava/ggjava.jar
启动replicat复制进程报如下错误：
opertyPlaceholderConfigurer#1,org.springframework.context.annotation.ConfigurationClassPostProcessor$ImportAwareBeanPostProcessor#0]; root of factory hierarchy
Failed to set property: gg.handler.kafkahandler.format.includePrimaryKeys:="true" (class: oracle.goldengate.format.json.JsonFormatter).
Failed to set property: gg.handler.kafkahandler.format.includePrimaryKeys:="true" (class: oracle.goldengate.format.json.JsonFormatter).
at oracle.goldengate.datasource.DataSourceLauncher.<init>(DataSourceLauncher.java:161)
at oracle.goldengate.datasource.UserExitMain.main(UserExitMain.java:108)
Caused by: org.springframework.beans.factory.BeanDefinitionStoreException: Factory method [public final oracle.goldengate.datasource.GGDataSource oracle.goldengate.
datasource.factory.DataSourceFactory.getDataSource()] threw exception; nested exception is oracle.goldengate.util.ConfigException: Failed to set property: gg.handle
r.kafkahandler.format.includePrimaryKeys:="true" (class: oracle.goldengate.format.json.JsonFormatter).
at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:169)
at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:570)
... 11 more
Caused by: oracle.goldengate.util.ConfigException: Failed to set property: gg.handler.kafkahandler.format.includePrimaryKeys:="true" (class: oracle.goldengate.forma
t.json.JsonFormatter).
at oracle.goldengate.util.PropertyWrapper.setProperty(PropertyWrapper.java:354)
at oracle.goldengate.util.PropertyWrapper.setProperties(PropertyWrapper.java:316)
at oracle.goldengate.datasource.handler.NgFormattedOutputHandler.formatterInit(NgFormattedOutputHandler.java:112)
at oracle.goldengate.datasource.handler.NgFormattedOutputHandler.init(NgFormattedOutputHandler.java:97)
at oracle.goldengate.handler.kafka.KafkaHandler.init(KafkaHandler.java:71)
at oracle.goldengate.datasource.AbstractDataSource.addDataSourceListener(AbstractDataSource.java:664)
at oracle.goldengate.datasource.factory.DataSourceFactory.getDataSource(DataSourceFactory.java:154)
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:149)
... 12 more
是该版本不支持该参数吗？？？？
页:
[1]