oggforbigdata 1221版本 kafka参数问题引起错误

shuyou

oggforbigdata 版本为：Version 12.2.0.1.0

kafka参数文件如下：

[ogg@server6 ogg]$ 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


是该版本不支持该参数吗？？？？