ERROR [2021-02-15 18:17:55,554] io.debezium.embedded.EmbeddedEngine: Error while trying to run connector class 'io.debezium.connector.oracle.OracleConnector'
! io.debezium.DebeziumException: Supplemental logging not configured for table TRVQA.DBO.hotel. Use command: ALTER TABLE DBO.hotel ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS
! at io.debezium.connector.oracle.logminer.LogMinerHelper.checkSupplementalLogging(LogMinerHelper.java:441)
! at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:142)
! ... 7 common frames omitted
! Causing: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
! at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42)
! at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:209)
! at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:140)
! at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:113)
! at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
! at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
! at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
! at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
! at java.base/java.lang.Thread.run(Thread.java:834)

------------------------------

SQL> ALTER TABLE DBO.hotel ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS
2 ;
ALTER TABLE DBO.hotel ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS
*
ERROR at line 1:
ORA-32588: supplemental logging attribute all column exists

-------------------------------
 
 
SQL> SELECT LOG_GROUP_TYPE FROM ALL_LOG_GROUPS WHERE OWNER = 'DBO' AND TABLE_NAME = 'HOTEL';
h2. LOG_GROUP_TYPE

ALL COLUMN LOGGING
PRIMARY KEY LOGGING
USER LOG GROUP

--------------------------------------

 

SQL> SELECT SUPPLEMENTAL_LOG_DATA_MIN FROM V$DATABASE;
h2. SUPPLEME

YES


SQL> SELECT SUPPLEMENTAL_LOG_DATA_ALL FROM V$DATABASE
h2. SUP

NO

------------------------------------