The Kafka Sink Connector and Kafka Source Connector for Oracle Transactional Event Queues. The Sink Connector reads messages from a specified Kafka topic and stores them in a specified Oracle Transactional Event Queue topic on an Oracle Database. The Source Connector reads messages from a specified Oracle Transactional Event Queue and stores them into a specified Kafka topic.
Enhancements:
- Sink connector will be able to connect to required nodes on a RAC to perform bulk enqueue.
- Add built in schema for certain JMS Message types (JMS_BYTES, JMS_TEXT, and JMS_MAP) if use.schema.for.jms.msgs property is set to true in the source connector configuration properties file.
- If the TxEventQ message has a correlation id specified the SourceRecord created when moving the messages into Kafka will store the correlation id as the key for the SourceRecord.
Note: This distribution also contains version 23.6.1.0 of the Kafka Java Client for Oracle Transactional Event Queues project.