My version of GoldenGate for bigdata is as follows：
Oracle GoldenGate Command Interpreter
Version 12.2.0.1.0 OGGCORE_12.2.0.1.0_PLATFORMS_151101.1925.2
Linux, x64, 64bit (optimized), Generic on Nov 10 2015 16:18:12
Operating system character set identified as UTF-8.
My kafka.props configuration:
[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
But I had a error in running the replicat process.
The error is as follows：
notationProcessor,versionInfo,dataSourceConfig,userExitFactory,userExitDataSource,trailDataSourceFactory,trailDataSource,org.springframework.beans.factory.config.Pr
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)
But I saw this version supporting this parameter.
I don't know why?