Hi,   Thanks for your reply.   Below is our props file.   eshop_kc.props   gg.handlerlist = kafkahandler gg.handler.kafkahandler.type = kafka gg.handler.kafkahandler.KafkaProducerConfigFile=custom_kafka_producer.properties gg.handler.kafkahandler.topicMappingTemplate=BUBB-MX_ALL_SOFT 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.BlockingSend =false gg.handler.kafkahandler.includeTokens=true gg.handler.kafkahandler.mode =op gg.schemareplaceregex=[$|#] gg.schemareplacestring=CDATA[] goldengate.userexit.timestamp=utc goldengate.userexit.writers=javawriter javawriter.stats.display=TRUE javawriter.stats.full=TRUE gg.log=log4j gg.log.level=DEBUG gg.report.time=30sec gg.classpath=dirprm/:/goldengate/kafka2/*:/goldengate/12.3.BD/ggjava/resources/lib/* javawriter.bootoptions=-Xmx2048m -Xms1024m -Djava.class.path=/goldengate/12.3.BD/ggjava/ggjava.jar -Djava.security.auth.login.config=/goldengate/12.3.BD/dirprm/jaas.conf -Djava.security.krb5.conf=/goldengate/12.3.BD/dirprm/krb5.conf -Dcom.ibm.security.krb5.debug=true gg.handler.kafkahandler.authType=kerberos gg.handler.kafkahandler.kerberosKeytabFile=/goldengate/12.3.BD/dirprm/kafka.keytab gg.handler.kafkahandler.kerberosPrincipal=kafka/prd-din-kaf-F9a-z1.corporate.google.com@MLK_PRD_YAHOO.COM ... View more

You can find the architecture and real-time data flow in the link.We have implemented same data flow.   https://dzone.com/articles/creates-a-cdc-stream-from-oracle-database-to-kafka   But topic is worked fine before we migrated from linux to aix .     Br, TVR ... View more

Hi,   Kafka Vesion:2.1 Oracle GoldenGate:12.3   Please let me know if you need any other inputs.   Thanks in advance         ... View more