2023-08-23 11:12:52,195 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors HTTP/1.1" 200 112 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,202 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,203 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,204 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,208 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau28_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,209 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,209 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau27_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,210 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,210 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau29_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,210 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau29_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,211 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,211 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau27_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,213 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau29_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,214 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau28_sink/status HTTP/1.1" 200 4746 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,217 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau29_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,218 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,219 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau27_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,221 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau28_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,222 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,223 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau29_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,223 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau26_sink/config HTTP/1.1" 200 809 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,224 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau29_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,225 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,225 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,226 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,229 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,230 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau27_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,231 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau27_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 10 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,232 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau29_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,233 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau29_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,233 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,233 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau28_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,234 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau29_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,235 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau27_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,237 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau26_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,238 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau28_sink/tasks/0/status HTTP/1.1" 200 4635 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,237 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,239 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau28_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,241 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau29_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,242 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau29_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,243 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,242 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau29_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:12:52,245 INFO || 10.0.18.18 - - [23/Aug/2023:08:12:52 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:13:21,337 INFO || [AdminClient clientId=connector-adminclient-vk_nau29_src-0] Node 3 disconnected. [org.apache.kafka.clients.NetworkClient] 2023-08-23 11:14:08,887 INFO || [AdminClient clientId=ufo--shared-admin] Node 3 disconnected. [org.apache.kafka.clients.NetworkClient] 2023-08-23 11:14:43,656 INFO Oracle|vk_nau29|streaming LogMiner session has exceeded maximum session time of 'Optional[PT2M]', forcing restart. [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:15:34,972 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors HTTP/1.1" 200 112 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,979 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,983 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,982 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau29_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,984 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,984 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau27_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,985 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau27_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,986 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau28_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,988 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau29_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,988 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau29_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,989 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 10 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,990 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau29_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,993 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau29_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,994 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau28_sink/status HTTP/1.1" 200 4746 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,995 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,996 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,997 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau29_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:34,998 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau27_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,000 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau26_sink/config HTTP/1.1" 200 809 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,000 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau29_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,001 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,003 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,005 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau27_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,007 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:34 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,008 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau27_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,009 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau27_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,009 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,011 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau29_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,011 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau29_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 9 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,012 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau29_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 9 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,013 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau28_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 13 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,015 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,016 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,017 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau29_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,018 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,019 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,020 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau28_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,021 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,022 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau29_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,023 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,024 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau28_sink/tasks/0/status HTTP/1.1" 200 4635 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,025 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau26_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:15:35,026 INFO || 10.0.18.150 - - [23/Aug/2023:08:15:35 +0000] "GET /connectors/vk_nau28_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:16:48,204 INFO Oracle|vk_nau29|streaming LogMiner session has exceeded maximum session time of 'Optional[PT2M]', forcing restart. [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:18:21,419 INFO || [AdminClient clientId=connector-adminclient-vk_nau29_src-0] Node 1 disconnected. [org.apache.kafka.clients.NetworkClient] 2023-08-23 11:18:52,602 INFO Oracle|vk_nau29|streaming LogMiner session has exceeded maximum session time of 'Optional[PT2M]', forcing restart. [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:19:08,984 INFO || [AdminClient clientId=ufo--shared-admin] Node 1 disconnected. [org.apache.kafka.clients.NetworkClient] 2023-08-23 11:20:36,785 INFO || [Producer clientId=vk_nau29-schemahistory] Node 2 disconnected. [org.apache.kafka.clients.NetworkClient] 2023-08-23 11:20:46,024 INFO || [Producer clientId=connector-producer-vk_nau29_src-0] Node 2 disconnected. [org.apache.kafka.clients.NetworkClient] 2023-08-23 11:20:54,477 INFO Oracle|vk_nau29|streaming LogMiner session has exceeded maximum session time of 'Optional[PT2M]', forcing restart. [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:21:35,105 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors HTTP/1.1" 200 112 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,111 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau28_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,114 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau28_sink/status HTTP/1.1" 200 4746 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,116 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,117 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau29_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,117 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau29_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,119 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,120 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,123 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau27_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,126 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,125 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 9 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,127 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,128 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau28_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 10 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,129 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau29_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 10 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,129 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau28_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,129 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau29_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,130 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau26_sink/config HTTP/1.1" 200 809 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,131 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau29_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,132 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau28_sink/tasks/0/status HTTP/1.1" 200 4635 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,135 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau27_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,137 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,138 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau28_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,139 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau29_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,139 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,142 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,141 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,142 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,145 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau26_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,145 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau29_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,147 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau29_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,148 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau27_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 9 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,149 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau29_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,150 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 10 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,152 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,153 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau27_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,154 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,155 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau29_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,155 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 9 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,158 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau29_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,160 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,160 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau27_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,160 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau29_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:35,160 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:35 +0000] "GET /connectors/vk_nau27_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:41,851 INFO || Successfully processed removal of connector 'vk_nau29_src' [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2023-08-23 11:21:41,851 INFO || [Worker clientId=connect-1, groupId=ufo] Connector vk_nau29_src config removed [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:41,853 INFO || [Worker clientId=connect-1, groupId=ufo] Handling connector-only config update by stopping connector vk_nau29_src [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:41,853 INFO || Stopping connector vk_nau29_src [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:21:41,853 INFO || Scheduled shutdown for WorkerConnector{id=vk_nau29_src} [org.apache.kafka.connect.runtime.WorkerConnector] 2023-08-23 11:21:41,854 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:41 +0000] "DELETE /connectors/vk_nau29_src HTTP/1.1" 204 0 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:41,854 INFO || Completed shutdown for WorkerConnector{id=vk_nau29_src} [org.apache.kafka.connect.runtime.WorkerConnector] 2023-08-23 11:21:41,855 INFO || [Worker clientId=connect-1, groupId=ufo] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:41,855 INFO || [Worker clientId=connect-1, groupId=ufo] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:41,856 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully joined group with generation Generation{generationId=105769805, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:41,858 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully synced group in generation Generation{generationId=105769805, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:41,858 INFO || Stopping connector vk_nau29_src [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:21:41,858 WARN || Ignoring stop request for unowned connector vk_nau29_src [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:21:41,858 INFO || Stopping task vk_nau29_src-0 [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:21:41,858 WARN || Ignoring await stop request for non-present connector vk_nau29_src [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:21:41,863 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:41 +0000] "GET /connectors HTTP/1.1" 200 97 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:42,273 INFO Oracle|vk_nau29|snapshot Stopping down connector [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:44,199 INFO Oracle|vk_nau29|streaming startScn=289914431839, endScn=289914431843 [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:21:44,200 INFO Oracle|vk_nau29|streaming Streaming metrics dump: OracleStreamingChangeEventSourceMetrics{currentScn=289914431843, oldestScn=-1, committedScn=289914431839, offsetScn=289914431783, logMinerQueryCount=17234, totalProcessedRows=22361370, totalCapturedDmlCount=9, totalDurationOfFetchingQuery=PT3H5M58.150736S, lastCapturedDmlCount=0, lastDurationOfFetchingQuery=PT0.102222S, maxCapturedDmlCount=2, maxDurationOfFetchingQuery=PT21.798728S, totalBatchProcessingDuration=PT5H52M42.539847S, lastBatchProcessingDuration=PT0.116024S, maxBatchProcessingThroughput=21, currentLogFileName=[/u02/oradata/naument1/redo_01a.log, /u04/oradata/naument1/redo_01b.log], minLogFilesMined=2, maxLogFilesMined=2, redoLogStatus=[/u02/oradata/naument1/redo_07a.log | ACTIVE, /u04/oradata/naument1/redo_07b.log | ACTIVE, /u02/oradata/naument1/redo_06a.log | ACTIVE, /u04/oradata/naument1/redo_06b.log | ACTIVE, /u02/oradata/naument1/redo_05a.log | ACTIVE, /u04/oradata/naument1/redo_05b.log | ACTIVE, /u02/oradata/naument1/redo_04a.log | ACTIVE, /u04/oradata/naument1/redo_02b.log | ACTIVE, /u04/oradata/naument1/redo_04b.log | ACTIVE, /u02/oradata/naument1/redo_03a.log | ACTIVE, /u04/oradata/naument1/redo_03b.log | ACTIVE, /u02/oradata/naument1/redo_02a.log | ACTIVE, /u02/oradata/naument1/redo_01a.log | CURRENT, /u04/oradata/naument1/redo_01b.log | CURRENT], switchCounter=0, batchSize=20000, millisecondToSleepBetweenMiningQuery=3000, keepTransactionsDuration=PT0S, networkConnectionProblemsCounter0, batchSizeDefault=20000, batchSizeMin=1000, batchSizeMax=100000, sleepTimeDefault=1000, sleepTimeMin=0, sleepTimeMax=3000, sleepTimeIncrement=200, totalParseTime=PT0.000695S, totalStartLogMiningSessionDuration=PT1H51M19.18902S, lastStartLogMiningSessionDuration=PT0.004228S, maxStartLogMiningSessionDuration=PT20.221593S, totalProcessTime=PT5H52M42.539847S, minBatchProcessTime=PT0.074175S, maxBatchProcessTime=PT1M53.799582S, totalResultSetNextTime=PT33M3.139624S, lagFromTheSource=DurationPT1.193043S, maxLagFromTheSourceDuration=PT3M50.137629S, minLagFromTheSourceDuration=PT0.124118S, lastCommitDuration=PT0.000001S, maxCommitDuration=PT0.091698S, activeTransactions=0, rolledBackTransactions=73099, oversizedTransactions=0, committedTransactions=4242552, abandonedTransactionIds={}, rolledbackTransactionIds={12000d00212c2a00=12000d00212c2a00, 0a001900f2fc3000=0a001900f2fc3000, 010013001b982500=010013001b982500, 11001400340e2b00=11001400340e2b00, 10000d00f3112a00=10000d00f3112a00, 07000300b19b2d00=07000300b19b2d00, 0600040039e82900=0600040039e82900, 01000800b4962500=01000800b4962500, 0f001f00b3cd2900=0f001f00b3cd2900, 0300170004982800=0300170004982800}, registeredDmlCount=9, committedDmlCount=10, errorCount=0, warningCount=0, scnFreezeCount=0, unparsableDdlCount=0, miningSessionUserGlobalAreaMemory=35176824, miningSessionUserGlobalAreaMaxMemory=55841816, miningSessionProcessGlobalAreaMemory=113359688, miningSessionProcessGlobalAreaMaxMemory=416463688} [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:21:44,200 INFO Oracle|vk_nau29|streaming Offsets: OracleOffsetContext [scn=289914431839, commit_scn=["289914431839:1:0c001600bd382b00"]] [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:21:44,200 INFO Oracle|vk_nau29|streaming Finished streaming [io.debezium.pipeline.ChangeEventSourceCoordinator] 2023-08-23 11:21:44,200 INFO Oracle|vk_nau29|streaming Connected metrics set to 'false' [io.debezium.pipeline.ChangeEventSourceCoordinator] 2023-08-23 11:21:44,200 INFO Oracle|vk_nau29|snapshot SignalProcessor stopped [io.debezium.pipeline.signal.SignalProcessor] 2023-08-23 11:21:44,224 INFO Oracle|vk_nau29|snapshot Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2023-08-23 11:21:44,224 INFO Oracle|vk_nau29|snapshot [Producer clientId=vk_nau29-schemahistory] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer] 2023-08-23 11:21:44,225 INFO Oracle|vk_nau29|snapshot Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:44,225 INFO Oracle|vk_nau29|snapshot Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:44,225 INFO Oracle|vk_nau29|snapshot Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:44,225 INFO Oracle|vk_nau29|snapshot App info kafka.producer for vk_nau29-schemahistory unregistered [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:44,225 INFO Oracle|vk_nau29|snapshot [Producer clientId=connector-producer-vk_nau29_src-0] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer] 2023-08-23 11:21:44,227 INFO Oracle|vk_nau29|snapshot Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:44,227 INFO Oracle|vk_nau29|snapshot Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:44,227 INFO Oracle|vk_nau29|snapshot Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:44,227 INFO Oracle|vk_nau29|snapshot App info kafka.producer for connector-producer-vk_nau29_src-0 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:44,227 INFO || App info kafka.admin.client for connector-adminclient-vk_nau29_src-0 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:44,228 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:44,228 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:44,228 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:44,229 INFO || [Worker clientId=connect-1, groupId=ufo] Finished stopping tasks in preparation for rebalance [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:44,231 INFO || [Worker clientId=connect-1, groupId=ufo] Finished flushing status backing store in preparation for rebalance [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:44,231 INFO || [Worker clientId=connect-1, groupId=ufo] Joined group at generation 105769805 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', leaderUrl='http://172.18.0.7:8083/', offset=2276, connectorIds=[vk_nau29_sink, vk_nau28_sink, vk_nau27_sink, vk_nau26_sink, vk_nau25_sink, vk_nau24_sink], taskIds=[vk_nau29_sink-0, vk_nau28_sink-0, vk_nau27_sink-0, vk_nau26_sink-0, vk_nau25_sink-0, vk_nau24_sink-0], revokedConnectorIds=[vk_nau29_src], revokedTaskIds=[vk_nau29_src-0], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:44,231 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connectors and tasks using config offset 2276 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:44,231 INFO || [Worker clientId=connect-1, groupId=ufo] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:44,231 INFO || [Worker clientId=connect-1, groupId=ufo] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:44,231 INFO || [Worker clientId=connect-1, groupId=ufo] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:44,233 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully joined group with generation Generation{generationId=105769806, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:44,234 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully synced group in generation Generation{generationId=105769806, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:44,234 INFO || [Worker clientId=connect-1, groupId=ufo] Joined group at generation 105769806 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', leaderUrl='http://172.18.0.7:8083/', offset=2276, connectorIds=[vk_nau29_sink, vk_nau28_sink, vk_nau27_sink, vk_nau26_sink, vk_nau25_sink, vk_nau24_sink], taskIds=[vk_nau29_sink-0, vk_nau28_sink-0, vk_nau27_sink-0, vk_nau26_sink-0, vk_nau25_sink-0, vk_nau24_sink-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:44,234 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connectors and tasks using config offset 2276 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:44,234 INFO || [Worker clientId=connect-1, groupId=ufo] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:44,236 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:41 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2371 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,236 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:41 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2371 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,236 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:41 +0000] "GET /connectors/vk_nau27_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2372 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,237 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:41 +0000] "GET /connectors/vk_nau29_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2371 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,239 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau28_sink/status HTTP/1.1" 200 4746 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,240 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:41 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 2375 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,240 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:41 +0000] "GET /connectors/vk_nau28_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2374 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,242 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau27_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,243 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,244 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,245 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,247 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau29_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,248 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau27_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,248 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,249 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau28_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,250 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,250 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau26_sink/config HTTP/1.1" 200 809 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,254 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,254 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau28_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,255 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau27_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,255 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,256 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,257 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau29_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,258 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau27_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,259 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,260 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau29_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,261 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,263 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,264 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau28_sink/tasks/0/status HTTP/1.1" 200 4635 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,264 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,264 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau29_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,265 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau27_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,266 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,267 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau29_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,268 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau28_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:44,269 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:44 +0000] "GET /connectors/vk_nau26_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:54,176 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:54 +0000] "GET /connectors HTTP/1.1" 200 97 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:54,180 INFO || Loading the custom source info struct maker plugin: io.debezium.connector.oracle.OracleSourceInfoStructMaker [io.debezium.config.CommonConnectorConfig] 2023-08-23 11:21:54,235 INFO || Database Version: Oracle Database 12c Enterprise Edition Release 12.2.0.1.0 - 64bit Production [io.debezium.connector.oracle.OracleConnection] 2023-08-23 11:21:54,237 INFO || Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2023-08-23 11:21:54,237 INFO || AbstractConfig values: [org.apache.kafka.common.config.AbstractConfig] 2023-08-23 11:21:54,240 INFO || [Worker clientId=connect-1, groupId=ufo] Connector vk_nau30_src config updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:54,241 INFO || [Worker clientId=connect-1, groupId=ufo] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:54,241 INFO || [Worker clientId=connect-1, groupId=ufo] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:54,241 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:54 +0000] "POST /connectors HTTP/1.1" 201 1564 "-" "ReactorNetty/1.1.6" 64 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:54,242 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully joined group with generation Generation{generationId=105769807, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:54,243 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully synced group in generation Generation{generationId=105769807, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:54,244 INFO || [Worker clientId=connect-1, groupId=ufo] Joined group at generation 105769807 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', leaderUrl='http://172.18.0.7:8083/', offset=2277, connectorIds=[vk_nau30_src, vk_nau29_sink, vk_nau28_sink, vk_nau27_sink, vk_nau26_sink, vk_nau25_sink, vk_nau24_sink], taskIds=[vk_nau29_sink-0, vk_nau28_sink-0, vk_nau27_sink-0, vk_nau26_sink-0, vk_nau25_sink-0, vk_nau24_sink-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:54,244 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connectors and tasks using config offset 2277 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:54,244 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connector vk_nau30_src [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:54,244 INFO || Creating connector vk_nau30_src of type io.debezium.connector.oracle.OracleConnector [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:21:54,244 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2023-08-23 11:21:54,244 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-23 11:21:54,244 INFO || EnrichedSourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.default.exclude = [] topic.creation.default.include = [.*] topic.creation.default.partitions = 1 topic.creation.default.replication.factor = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SourceConnectorConfig$EnrichedSourceConnectorConfig] 2023-08-23 11:21:54,244 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.default.exclude = [] topic.creation.default.include = [.*] topic.creation.default.partitions = 1 topic.creation.default.replication.factor = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-23 11:21:54,245 INFO || Instantiated connector vk_nau30_src with version 2.4.0.Alpha2 of type class io.debezium.connector.oracle.OracleConnector [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:21:54,245 INFO || Finished creating connector vk_nau30_src [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:21:54,245 INFO || [Worker clientId=connect-1, groupId=ufo] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:54,246 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:54 +0000] "GET /connectors/vk_nau30_src HTTP/1.1" 200 1564 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:54,248 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2023-08-23 11:21:54,248 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-23 11:21:54,248 INFO || EnrichedSourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.default.exclude = [] topic.creation.default.include = [.*] topic.creation.default.partitions = 1 topic.creation.default.replication.factor = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SourceConnectorConfig$EnrichedSourceConnectorConfig] 2023-08-23 11:21:54,248 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.default.exclude = [] topic.creation.default.include = [.*] topic.creation.default.partitions = 1 topic.creation.default.replication.factor = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-23 11:21:54,251 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:54 +0000] "GET /connectors/vk_nau30_src/status HTTP/1.1" 404 73 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:54,254 INFO || [Worker clientId=connect-1, groupId=ufo] Tasks [vk_nau30_src-0] configs updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:54,255 INFO || [Worker clientId=connect-1, groupId=ufo] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:54,255 INFO || [Worker clientId=connect-1, groupId=ufo] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:54,256 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully joined group with generation Generation{generationId=105769808, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:54,258 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully synced group in generation Generation{generationId=105769808, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:21:54,258 INFO || [Worker clientId=connect-1, groupId=ufo] Joined group at generation 105769808 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', leaderUrl='http://172.18.0.7:8083/', offset=2279, connectorIds=[vk_nau30_src, vk_nau29_sink, vk_nau28_sink, vk_nau27_sink, vk_nau26_sink, vk_nau25_sink, vk_nau24_sink], taskIds=[vk_nau30_src-0, vk_nau29_sink-0, vk_nau28_sink-0, vk_nau27_sink-0, vk_nau26_sink-0, vk_nau25_sink-0, vk_nau24_sink-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:54,258 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connectors and tasks using config offset 2279 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:54,258 INFO || [Worker clientId=connect-1, groupId=ufo] Starting task vk_nau30_src-0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:54,258 INFO || Creating task vk_nau30_src-0 [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:21:54,259 INFO || ConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_src predicates = [] tasks.max = 1 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig] 2023-08-23 11:21:54,259 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_src predicates = [] tasks.max = 1 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-23 11:21:54,259 INFO || TaskConfig values: task.class = class io.debezium.connector.oracle.OracleConnectorTask [org.apache.kafka.connect.runtime.TaskConfig] 2023-08-23 11:21:54,259 INFO || Instantiated task vk_nau30_src-0 with version 2.4.0.Alpha2 of type io.debezium.connector.oracle.OracleConnectorTask [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:21:54,260 INFO || AvroConverterConfig values: auto.register.schemas = true basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.connect.avro.AvroConverterConfig] 2023-08-23 11:21:54,260 INFO || KafkaAvroSerializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.remove.java.properties = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroSerializerConfig] 2023-08-23 11:21:54,260 INFO || KafkaAvroDeserializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] specific.avro.reader = false use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroDeserializerConfig] 2023-08-23 11:21:54,260 INFO || AvroDataConfig values: connect.meta.data = true discard.type.doc.default = false enhanced.avro.schema.support = false generalized.sum.type.support = false ignore.default.for.nullables = false schemas.cache.config = 1000 scrub.invalid.names = false [io.confluent.connect.avro.AvroDataConfig] 2023-08-23 11:21:54,260 INFO || AvroConverterConfig values: auto.register.schemas = true basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.connect.avro.AvroConverterConfig] 2023-08-23 11:21:54,261 INFO || KafkaAvroSerializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.remove.java.properties = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroSerializerConfig] 2023-08-23 11:21:54,261 INFO || KafkaAvroDeserializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] specific.avro.reader = false use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroDeserializerConfig] 2023-08-23 11:21:54,261 INFO || AvroDataConfig values: connect.meta.data = true discard.type.doc.default = false enhanced.avro.schema.support = false generalized.sum.type.support = false ignore.default.for.nullables = false schemas.cache.config = 1000 scrub.invalid.names = false [io.confluent.connect.avro.AvroDataConfig] 2023-08-23 11:21:54,261 INFO || Set up the key converter class io.confluent.connect.avro.AvroConverter for task vk_nau30_src-0 using the connector config [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:21:54,261 INFO || Set up the value converter class io.confluent.connect.avro.AvroConverter for task vk_nau30_src-0 using the connector config [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:21:54,261 INFO || Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task vk_nau30_src-0 using the worker config [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:21:54,261 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2023-08-23 11:21:54,262 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-23 11:21:54,262 INFO || EnrichedSourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.default.exclude = [] topic.creation.default.include = [.*] topic.creation.default.partitions = 1 topic.creation.default.replication.factor = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SourceConnectorConfig$EnrichedSourceConnectorConfig] 2023-08-23 11:21:54,262 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.default.exclude = [] topic.creation.default.include = [.*] topic.creation.default.partitions = 1 topic.creation.default.replication.factor = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-23 11:21:54,262 INFO || Initializing: org.apache.kafka.connect.runtime.TransformationChain{} [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:21:54,262 INFO || ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [broker1:29092, broker2:29092, broker3:29092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = connector-producer-vk_nau30_src-0 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 9223372036854775807 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer [org.apache.kafka.clients.producer.ProducerConfig] 2023-08-23 11:21:54,266 INFO || These configurations '[metrics.context.connect.kafka.cluster.id, metrics.context.connect.group.id]' were supplied but are not used yet. [org.apache.kafka.clients.producer.ProducerConfig] 2023-08-23 11:21:54,266 INFO || Kafka version: 3.5.1 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,266 INFO || Kafka commitId: 2c6fb6c54472e90a [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,266 INFO || Kafka startTimeMs: 1692778914266 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,266 INFO || AdminClientConfig values: auto.include.jmx.reporter = true bootstrap.servers = [broker1:29092, broker2:29092, broker3:29092] client.dns.lookup = use_all_dns_ips client.id = connector-adminclient-vk_nau30_src-0 connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2023-08-23 11:21:54,267 INFO || These configurations '[group.id, max.partition.fetch.bytes, rest.advertised.port, task.shutdown.graceful.timeout.ms, plugin.path, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, value.converter, key.converter, message.max.bytes, config.storage.topic, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.host.name, offset.flush.timeout.ms, config.storage.replication.factor, offset.flush.interval.ms, rest.port, key.converter.schemas.enable, max.request.size, replica.fetch.max.bytes, value.converter.schemas.enable, offset.storage.replication.factor]' were supplied but are not used yet. [org.apache.kafka.clients.admin.AdminClientConfig] 2023-08-23 11:21:54,267 INFO || Kafka version: 3.5.1 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,267 INFO || Kafka commitId: 2c6fb6c54472e90a [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,267 INFO || Kafka startTimeMs: 1692778914267 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,268 INFO || [Producer clientId=connector-producer-vk_nau30_src-0] Cluster ID: gVJjK6cZTd-nXsXP2EIHEQ [org.apache.kafka.clients.Metadata] 2023-08-23 11:21:54,268 INFO || [Worker clientId=connect-1, groupId=ufo] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:21:54,268 INFO || Starting OracleConnectorTask with configuration: [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || connector.class = io.debezium.connector.oracle.OracleConnector [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || topic.creation.default.partitions = 1 [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || tasks.max = 1 [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || schema.history.internal.store.only.captured.tables.ddl = true [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || schema.history.internal.store.only.captured.databases.ddl = true [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || include.schema.changes = true [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || topic.prefix = vk_nau30 [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || decimal.handling.mode = precise [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || schema.history.internal.kafka.topic = vk_nau30_src.schema-changes [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || topic.creation.default.include = vk_nau30\.* [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || topic.creation.default.replication.factor = 1 [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || lob.enabled = true [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || value.converter = io.confluent.connect.avro.AvroConverter [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || errors.log.enable = true [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || key.converter = io.confluent.connect.avro.AvroConverter [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || snapshot.lock.timeout.ms = 5000 [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || database.user = debezium [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || database.dbname = NAUMENT1 [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || datatype.propagate.source.type = .* [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || topic.creation.default.compression.type = lz4 [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || database.connection.adapter = logminer [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || schema.history.internal.kafka.bootstrap.servers = broker1:29092,broker3:29092,broker3:29092 [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || topic.creation.default.retention.ms = 432000000 [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || database.port = 1521 [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || topic.creation.enable = true [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || value.converter.schema.registry.url = http://naument-sr:8081 [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,269 INFO || log.mining.session.max.ms = 120000 [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,270 INFO || task.class = io.debezium.connector.oracle.OracleConnectorTask [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,270 INFO || database.hostname = naumen-db-test.rgs.ru [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,270 INFO || database.password = ******** [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,270 INFO || schema.name.adjustment.mode = avro [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,270 INFO || name = vk_nau30_src [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,270 INFO || table.include.list = DEBEZIUM.GBC_TBL_SERVICECALL_NC30 [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,270 INFO || key.converter.schema.registry.url = http://naument-sr:8081 [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,270 INFO || snapshot.mode = always [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,270 INFO || field.name.adjustment.mode = avro [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,270 INFO || Loading the custom source info struct maker plugin: io.debezium.connector.oracle.OracleSourceInfoStructMaker [io.debezium.config.CommonConnectorConfig] 2023-08-23 11:21:54,270 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:54 +0000] "GET /connectors/vk_nau30_src HTTP/1.1" 200 1601 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:54,270 INFO || Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy [io.debezium.config.CommonConnectorConfig] 2023-08-23 11:21:54,273 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:54 +0000] "GET /connectors/vk_nau30_src/tasks/0/status HTTP/1.1" 404 70 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:54,273 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:54 +0000] "GET /connectors/vk_nau30_src/tasks HTTP/1.1" 200 1624 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:54,274 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:54 +0000] "GET /connectors/vk_nau30_src/status HTTP/1.1" 200 112 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:54,320 INFO || Database Version: Oracle Database 12c Enterprise Edition Release 12.2.0.1.0 - 64bit Production [io.debezium.connector.oracle.OracleConnection] 2023-08-23 11:21:54,328 INFO || KafkaSchemaHistory Consumer config: {key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, enable.auto.commit=false, group.id=vk_nau30-schemahistory, bootstrap.servers=broker1:29092,broker3:29092,broker3:29092, fetch.min.bytes=1, session.timeout.ms=10000, auto.offset.reset=earliest, client.id=vk_nau30-schemahistory} [io.debezium.storage.kafka.history.KafkaSchemaHistory] 2023-08-23 11:21:54,328 INFO || KafkaSchemaHistory Producer config: {retries=1, value.serializer=org.apache.kafka.common.serialization.StringSerializer, acks=1, batch.size=32768, max.block.ms=10000, bootstrap.servers=broker1:29092,broker3:29092,broker3:29092, buffer.memory=1048576, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=vk_nau30-schemahistory, linger.ms=0} [io.debezium.storage.kafka.history.KafkaSchemaHistory] 2023-08-23 11:21:54,328 INFO || Requested thread factory for connector OracleConnector, id = vk_nau30 named = db-history-config-check [io.debezium.util.Threads] 2023-08-23 11:21:54,329 INFO || Idempotence will be disabled because acks is set to 1, not set to 'all'. [org.apache.kafka.clients.producer.ProducerConfig] 2023-08-23 11:21:54,329 INFO || ProducerConfig values: acks = 1 auto.include.jmx.reporter = true batch.size = 32768 bootstrap.servers = [broker1:29092, broker3:29092, broker3:29092] buffer.memory = 1048576 client.dns.lookup = use_all_dns_ips client.id = vk_nau30-schemahistory compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 10000 max.in.flight.requests.per.connection = 5 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 1 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.StringSerializer [org.apache.kafka.clients.producer.ProducerConfig] 2023-08-23 11:21:54,330 INFO || Kafka version: 3.5.1 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,330 INFO || Kafka commitId: 2c6fb6c54472e90a [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,330 INFO || Kafka startTimeMs: 1692778914330 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,333 INFO || [Producer clientId=vk_nau30-schemahistory] Cluster ID: gVJjK6cZTd-nXsXP2EIHEQ [org.apache.kafka.clients.Metadata] 2023-08-23 11:21:54,335 INFO || No previous offsets found [io.debezium.connector.common.BaseSourceTask] 2023-08-23 11:21:54,335 INFO || Connector started for the first time, database schema history recovery will not be executed [io.debezium.connector.oracle.OracleConnectorTask] 2023-08-23 11:21:54,335 INFO || ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [broker1:29092, broker3:29092, broker3:29092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = vk_nau30-schemahistory client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = vk_nau30-schemahistory group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer [org.apache.kafka.clients.consumer.ConsumerConfig] 2023-08-23 11:21:54,336 INFO || Kafka version: 3.5.1 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,336 INFO || Kafka commitId: 2c6fb6c54472e90a [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,336 INFO || Kafka startTimeMs: 1692778914336 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,338 INFO || [Consumer clientId=vk_nau30-schemahistory, groupId=vk_nau30-schemahistory] Cluster ID: gVJjK6cZTd-nXsXP2EIHEQ [org.apache.kafka.clients.Metadata] 2023-08-23 11:21:54,339 INFO || [Consumer clientId=vk_nau30-schemahistory, groupId=vk_nau30-schemahistory] Resetting generation and member id due to: consumer pro-actively leaving the group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:21:54,339 INFO || [Consumer clientId=vk_nau30-schemahistory, groupId=vk_nau30-schemahistory] Request joining group due to: consumer pro-actively leaving the group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:21:54,340 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:54,340 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:54,340 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:54,340 INFO || App info kafka.consumer for vk_nau30-schemahistory unregistered [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,340 INFO || AdminClientConfig values: auto.include.jmx.reporter = true bootstrap.servers = [broker1:29092, broker3:29092, broker3:29092] client.dns.lookup = use_all_dns_ips client.id = vk_nau30-schemahistory connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 1 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2023-08-23 11:21:54,341 INFO || These configurations '[value.serializer, acks, batch.size, max.block.ms, buffer.memory, key.serializer, linger.ms]' were supplied but are not used yet. [org.apache.kafka.clients.admin.AdminClientConfig] 2023-08-23 11:21:54,341 INFO || Kafka version: 3.5.1 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,341 INFO || Kafka commitId: 2c6fb6c54472e90a [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,341 INFO || Kafka startTimeMs: 1692778914341 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,373 INFO || Database schema history topic '(name=vk_nau30_src.schema-changes, numPartitions=1, replicationFactor=default, replicasAssignments=null, configs={cleanup.policy=delete, retention.ms=9223372036854775807, retention.bytes=-1})' created [io.debezium.storage.kafka.history.KafkaSchemaHistory] 2023-08-23 11:21:54,373 INFO || App info kafka.admin.client for vk_nau30-schemahistory unregistered [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:21:54,374 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:54,374 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:54,374 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:21:54,375 INFO || Requested thread factory for connector OracleConnector, id = vk_nau30 named = SignalProcessor [io.debezium.util.Threads] 2023-08-23 11:21:54,375 INFO || Requested thread factory for connector OracleConnector, id = vk_nau30 named = change-event-source-coordinator [io.debezium.util.Threads] 2023-08-23 11:21:54,375 INFO || Requested thread factory for connector OracleConnector, id = vk_nau30 named = blocking-snapshot [io.debezium.util.Threads] 2023-08-23 11:21:54,375 INFO || Creating thread debezium-oracleconnector-vk_nau30-change-event-source-coordinator [io.debezium.util.Threads] 2023-08-23 11:21:54,376 INFO Oracle|vk_nau30|snapshot Metrics registered [io.debezium.pipeline.ChangeEventSourceCoordinator] 2023-08-23 11:21:54,376 INFO Oracle|vk_nau30|snapshot Context created [io.debezium.pipeline.ChangeEventSourceCoordinator] 2023-08-23 11:21:54,376 INFO Oracle|vk_nau30|snapshot Snapshot mode is set to ALWAYS, not checking exiting offset. [io.debezium.connector.oracle.OracleSnapshotChangeEventSource] 2023-08-23 11:21:54,376 INFO Oracle|vk_nau30|snapshot According to the connector configuration both schema and data will be snapshot. [io.debezium.connector.oracle.OracleSnapshotChangeEventSource] 2023-08-23 11:21:54,376 INFO || SignalProcessor started. Scheduling it every 5000ms [io.debezium.pipeline.signal.SignalProcessor] 2023-08-23 11:21:54,376 INFO Oracle|vk_nau30|snapshot Snapshot step 1 - Preparing [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-23 11:21:54,376 INFO || Creating thread debezium-oracleconnector-vk_nau30-SignalProcessor [io.debezium.util.Threads] 2023-08-23 11:21:54,377 INFO Oracle|vk_nau30|snapshot Snapshot step 2 - Determining captured tables [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-23 11:21:54,377 INFO Oracle|vk_nau30|snapshot WorkerSourceTask{id=vk_nau30_src-0} Source task finished initialization and start [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] 2023-08-23 11:21:55,432 INFO Oracle|vk_nau30|snapshot Adding table NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC30 to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-23 11:21:55,437 INFO Oracle|vk_nau30|snapshot Created connection pool with 1 threads [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-23 11:21:55,437 INFO Oracle|vk_nau30|snapshot Snapshot step 3 - Locking captured tables [NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC30] [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-23 11:21:55,441 INFO Oracle|vk_nau30|snapshot Snapshot step 4 - Determining snapshot offset [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-23 11:21:55,566 INFO Oracle|vk_nau30|snapshot No in-progress transactions will be captured. [io.debezium.connector.oracle.logminer.LogMinerAdapter] 2023-08-23 11:21:55,568 INFO Oracle|vk_nau30|snapshot Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2023-08-23 11:21:55,568 INFO Oracle|vk_nau30|snapshot Snapshot step 5 - Reading structure of captured tables [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-23 11:21:55,568 INFO Oracle|vk_nau30|snapshot Only captured tables schema should be captured, capturing: [NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC30] [io.debezium.connector.oracle.OracleSnapshotChangeEventSource] 2023-08-23 11:21:56,145 INFO Oracle|vk_nau30|snapshot Snapshot step 6 - Persisting schema history [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-23 11:21:56,145 INFO Oracle|vk_nau30|snapshot Capturing structure of table NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC30 [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-23 11:21:56,890 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors HTTP/1.1" 200 112 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,895 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,896 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,897 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau28_sink/status HTTP/1.1" 200 4746 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,898 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau28_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,899 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau29_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,900 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau27_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,900 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau30_src HTTP/1.1" 200 1601 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,902 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau30_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,903 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,903 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 9 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,904 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,904 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau27_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,905 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau29_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,908 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau28_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,908 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau26_sink/config HTTP/1.1" 200 809 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,909 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,910 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau30_src/config HTTP/1.1" 200 1504 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,911 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,912 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau28_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,913 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau27_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,914 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau29_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,914 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,915 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,917 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,918 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau28_sink/tasks/0/status HTTP/1.1" 200 4635 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,918 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau30_src/tasks HTTP/1.1" 200 1624 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,919 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,921 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau28_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,923 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 11 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,923 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau29_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,924 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau27_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 9 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,924 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 9 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,924 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau30_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,926 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,928 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,930 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau29_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,929 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau29_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,931 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau30_src/topics HTTP/1.1" 200 30 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,931 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau27_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,932 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau26_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,933 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:56,934 INFO || 10.0.18.18 - - [23/Aug/2023:08:21:56 +0000] "GET /connectors/vk_nau27_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:21:58,536 WARN Oracle|vk_nau30|snapshot The Kafka Connect schema name 'CLAIM$TRANSFERDATE' is not a valid Avro schema name, so replacing with 'CLAIM_TRANSFERDATE' [io.debezium.schema.SchemaNameAdjuster] 2023-08-23 11:21:58,540 INFO Oracle|vk_nau30|snapshot Already applied 1 database changes [io.debezium.relational.history.SchemaHistoryMetrics] 2023-08-23 11:21:58,541 INFO Oracle|vk_nau30|snapshot Snapshot step 7 - Snapshotting data [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-23 11:21:58,541 INFO Oracle|vk_nau30|snapshot Creating snapshot worker pool with 1 worker thread(s) [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-23 11:21:58,541 INFO Oracle|vk_nau30|snapshot For table 'NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC30' using select statement: 'SELECT "ID", "CREATION_DATE", "CLAIM$TRANSFERDATE" FROM "DEBEZIUM"."GBC_TBL_SERVICECALL_NC30" AS OF SCN 289914432011' [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-23 11:21:58,542 INFO Oracle|vk_nau30|snapshot Exporting data from table 'NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC30' (1 of 1 tables) [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-23 11:21:58,700 INFO Oracle|vk_nau30|snapshot Finished exporting 2000 records for table 'NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC30' (1 of 1 tables); total duration '00:00:00.159' [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-23 11:21:58,702 INFO Oracle|vk_nau30|snapshot Snapshot - Final stage [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource] 2023-08-23 11:21:58,702 INFO Oracle|vk_nau30|snapshot Snapshot completed [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource] 2023-08-23 11:21:58,702 INFO Oracle|vk_nau30|snapshot Snapshot ended with SnapshotResult [status=COMPLETED, offset=OracleOffsetContext [scn=289914432011, commit_scn=[]]] [io.debezium.pipeline.ChangeEventSourceCoordinator] 2023-08-23 11:21:58,702 INFO Oracle|vk_nau30|streaming Connected metrics set to 'true' [io.debezium.pipeline.ChangeEventSourceCoordinator] 2023-08-23 11:21:58,702 INFO Oracle|vk_nau30|streaming Starting streaming [io.debezium.pipeline.ChangeEventSourceCoordinator] 2023-08-23 11:21:58,899 INFO Oracle|vk_nau30|snapshot The task will send records to topic 'vk_nau30' for the first time. Checking whether topic exists [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] 2023-08-23 11:21:58,901 INFO Oracle|vk_nau30|snapshot Creating topic 'vk_nau30' [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] 2023-08-23 11:21:58,932 INFO Oracle|vk_nau30|snapshot Created topic (name=vk_nau30, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={compression.type=lz4, retention.ms=432000000}) on brokers at broker1:29092,broker2:29092,broker3:29092 [org.apache.kafka.connect.util.TopicAdmin] 2023-08-23 11:21:58,932 INFO Oracle|vk_nau30|snapshot Created topic '(name=vk_nau30, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={compression.type=lz4, retention.ms=432000000})' using creation group TopicCreationGroup{name='default', inclusionPattern=.*, exclusionPattern=, numPartitions=1, replicationFactor=1, otherConfigs={compression.type=lz4, retention.ms=432000000}} [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] 2023-08-23 11:21:58,933 WARN || [Producer clientId=connector-producer-vk_nau30_src-0] Error while fetching metadata with correlation id 3 : {vk_nau30=UNKNOWN_TOPIC_OR_PARTITION} [org.apache.kafka.clients.NetworkClient] 2023-08-23 11:21:58,973 INFO Oracle|vk_nau30|streaming Redo Log Group Sizes: [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:21:58,973 INFO Oracle|vk_nau30|streaming Group #1: 536870912 bytes [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:21:58,973 INFO Oracle|vk_nau30|streaming Group #2: 536870912 bytes [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:21:58,973 INFO Oracle|vk_nau30|streaming Group #3: 536870912 bytes [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:21:58,973 INFO Oracle|vk_nau30|streaming Group #4: 536870912 bytes [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:21:58,973 INFO Oracle|vk_nau30|streaming Group #5: 536870912 bytes [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:21:58,973 INFO Oracle|vk_nau30|streaming Group #6: 536870912 bytes [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:21:58,973 INFO Oracle|vk_nau30|streaming Group #7: 536870912 bytes [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-23 11:21:59,034 WARN || [Producer clientId=connector-producer-vk_nau30_src-0] Error while fetching metadata with correlation id 4 : {vk_nau30=UNKNOWN_TOPIC_OR_PARTITION} [org.apache.kafka.clients.NetworkClient] 2023-08-23 11:21:59,135 WARN || [Producer clientId=connector-producer-vk_nau30_src-0] Error while fetching metadata with correlation id 5 : {vk_nau30=UNKNOWN_TOPIC_OR_PARTITION} [org.apache.kafka.clients.NetworkClient] 2023-08-23 11:21:59,235 WARN || [Producer clientId=connector-producer-vk_nau30_src-0] Error while fetching metadata with correlation id 6 : {vk_nau30=UNKNOWN_TOPIC_OR_PARTITION} [org.apache.kafka.clients.NetworkClient] 2023-08-23 11:21:59,347 INFO Oracle|vk_nau30|snapshot The task will send records to topic 'vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30' for the first time. Checking whether topic exists [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] 2023-08-23 11:21:59,348 INFO Oracle|vk_nau30|snapshot Creating topic 'vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30' [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] 2023-08-23 11:21:59,376 INFO Oracle|vk_nau30|snapshot Created topic (name=vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={compression.type=lz4, retention.ms=432000000}) on brokers at broker1:29092,broker2:29092,broker3:29092 [org.apache.kafka.connect.util.TopicAdmin] 2023-08-23 11:21:59,376 INFO Oracle|vk_nau30|snapshot Created topic '(name=vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={compression.type=lz4, retention.ms=432000000})' using creation group TopicCreationGroup{name='default', inclusionPattern=.*, exclusionPattern=, numPartitions=1, replicationFactor=1, otherConfigs={compression.type=lz4, retention.ms=432000000}} [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] 2023-08-23 11:21:59,378 WARN || [Producer clientId=connector-producer-vk_nau30_src-0] Got error produce response with correlation id 11 on topic-partition vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30-0, retrying (2147483646 attempts left). Error: UNKNOWN_TOPIC_OR_PARTITION [org.apache.kafka.clients.producer.internals.Sender] 2023-08-23 11:21:59,378 WARN || [Producer clientId=connector-producer-vk_nau30_src-0] Received unknown topic or partition error in produce request on partition vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30-0. The topic-partition may not exist or the user may not have Describe access to it [org.apache.kafka.clients.producer.internals.Sender] 2023-08-23 11:21:59,477 WARN || [Producer clientId=connector-producer-vk_nau30_src-0] Error while fetching metadata with correlation id 12 : {vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30=UNKNOWN_TOPIC_OR_PARTITION} [org.apache.kafka.clients.NetworkClient] 2023-08-23 11:21:59,477 INFO || [Producer clientId=connector-producer-vk_nau30_src-0] Resetting the last seen epoch of partition vk_nau30-0 to 0 since the associated topicId changed from null to sM-w7qlFSh2ktSItfSTrWw [org.apache.kafka.clients.Metadata] 2023-08-23 11:21:59,578 WARN || [Producer clientId=connector-producer-vk_nau30_src-0] Error while fetching metadata with correlation id 13 : {vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30=UNKNOWN_TOPIC_OR_PARTITION} [org.apache.kafka.clients.NetworkClient] 2023-08-23 11:21:59,679 INFO || [Producer clientId=connector-producer-vk_nau30_src-0] Resetting the last seen epoch of partition vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30-0 to 0 since the associated topicId changed from null to 46GWAVplTRC11emfeIqNDw [org.apache.kafka.clients.Metadata] 2023-08-23 11:21:59,679 WARN || [Producer clientId=connector-producer-vk_nau30_src-0] Got error produce response with correlation id 15 on topic-partition vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30-0, retrying (2147483645 attempts left). Error: UNKNOWN_TOPIC_OR_PARTITION [org.apache.kafka.clients.producer.internals.Sender] 2023-08-23 11:21:59,679 WARN || [Producer clientId=connector-producer-vk_nau30_src-0] Received unknown topic or partition error in produce request on partition vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30-0. The topic-partition may not exist or the user may not have Describe access to it [org.apache.kafka.clients.producer.internals.Sender] 2023-08-23 11:21:59,780 WARN || [Producer clientId=connector-producer-vk_nau30_src-0] Got error produce response with correlation id 17 on topic-partition vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30-0, retrying (2147483644 attempts left). Error: UNKNOWN_TOPIC_OR_PARTITION [org.apache.kafka.clients.producer.internals.Sender] 2023-08-23 11:21:59,780 WARN || [Producer clientId=connector-producer-vk_nau30_src-0] Received unknown topic or partition error in produce request on partition vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30-0. The topic-partition may not exist or the user may not have Describe access to it [org.apache.kafka.clients.producer.internals.Sender] 2023-08-23 11:22:00,041 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors HTTP/1.1" 200 112 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,046 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau28_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,047 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,048 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau30_src HTTP/1.1" 200 1601 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,049 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau29_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,051 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,051 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,052 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 9 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,052 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau29_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,052 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau27_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,053 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau30_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,054 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,055 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau29_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,058 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau28_sink/status HTTP/1.1" 200 4746 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,058 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau27_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,060 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,061 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau26_sink/config HTTP/1.1" 200 809 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,061 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,061 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau29_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,062 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau30_src/config HTTP/1.1" 200 1504 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,064 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,065 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau27_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,067 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau28_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,068 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau29_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,068 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,069 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau27_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,070 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau30_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,070 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,071 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau30_src/tasks HTTP/1.1" 200 1624 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,072 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,073 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,074 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau30_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,076 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau29_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,077 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau27_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,079 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,079 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau27_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,079 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau28_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,081 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,081 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,081 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau28_sink/tasks/0/status HTTP/1.1" 200 4635 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,083 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,084 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau26_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:00,085 INFO || 10.0.18.18 - - [23/Aug/2023:08:22:00 +0000] "GET /connectors/vk_nau28_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:42,480 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:42 +0000] "GET /connectors HTTP/1.1" 200 112 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:42,484 INFO || AbstractConfig values: [org.apache.kafka.common.config.AbstractConfig] 2023-08-23 11:22:42,485 INFO || [Worker clientId=connect-1, groupId=ufo] Connector vk_nau30_sink config updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:22:42,487 INFO || [Worker clientId=connect-1, groupId=ufo] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:22:42,487 INFO || [Worker clientId=connect-1, groupId=ufo] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:22:42,487 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:42 +0000] "POST /connectors HTTP/1.1" 201 867 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:42,489 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully joined group with generation Generation{generationId=105769809, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:22:42,490 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully synced group in generation Generation{generationId=105769809, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:22:42,490 INFO || [Worker clientId=connect-1, groupId=ufo] Joined group at generation 105769809 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', leaderUrl='http://172.18.0.7:8083/', offset=2280, connectorIds=[vk_nau30_sink, vk_nau30_src, vk_nau29_sink, vk_nau28_sink, vk_nau27_sink, vk_nau26_sink, vk_nau25_sink, vk_nau24_sink], taskIds=[vk_nau30_src-0, vk_nau29_sink-0, vk_nau28_sink-0, vk_nau27_sink-0, vk_nau26_sink-0, vk_nau25_sink-0, vk_nau24_sink-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:22:42,490 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connectors and tasks using config offset 2280 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:22:42,491 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connector vk_nau30_sink [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:22:42,491 INFO || Creating connector vk_nau30_sink of type io.debezium.connector.jdbc.JdbcSinkConnector [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:22:42,491 INFO || SinkConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_sink predicates = [] tasks.max = 1 topics = [] topics.regex = vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SinkConnectorConfig] 2023-08-23 11:22:42,491 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_sink predicates = [] tasks.max = 1 topics = [] topics.regex = vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-23 11:22:42,491 INFO || Instantiated connector vk_nau30_sink with version 2.4.0.Alpha2 of type class io.debezium.connector.jdbc.JdbcSinkConnector [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:22:42,491 INFO || Finished creating connector vk_nau30_sink [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:22:42,491 INFO || [Worker clientId=connect-1, groupId=ufo] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:22:42,492 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:42 +0000] "GET /connectors/vk_nau30_sink HTTP/1.1" 200 867 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:42,492 INFO || SinkConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_sink predicates = [] tasks.max = 1 topics = [] topics.regex = vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SinkConnectorConfig] 2023-08-23 11:22:42,492 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_sink predicates = [] tasks.max = 1 topics = [] topics.regex = vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-23 11:22:42,495 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:42 +0000] "GET /connectors/vk_nau30_sink/status HTTP/1.1" 200 111 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:42,497 INFO || [Worker clientId=connect-1, groupId=ufo] Tasks [vk_nau30_sink-0] configs updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:22:42,499 INFO || [Worker clientId=connect-1, groupId=ufo] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:22:42,499 INFO || [Worker clientId=connect-1, groupId=ufo] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:22:42,499 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully joined group with generation Generation{generationId=105769810, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:22:42,501 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully synced group in generation Generation{generationId=105769810, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-23 11:22:42,501 INFO || [Worker clientId=connect-1, groupId=ufo] Joined group at generation 105769810 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', leaderUrl='http://172.18.0.7:8083/', offset=2282, connectorIds=[vk_nau30_sink, vk_nau30_src, vk_nau29_sink, vk_nau28_sink, vk_nau27_sink, vk_nau26_sink, vk_nau25_sink, vk_nau24_sink], taskIds=[vk_nau30_sink-0, vk_nau30_src-0, vk_nau29_sink-0, vk_nau28_sink-0, vk_nau27_sink-0, vk_nau26_sink-0, vk_nau25_sink-0, vk_nau24_sink-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:22:42,501 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connectors and tasks using config offset 2282 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:22:42,501 INFO || [Worker clientId=connect-1, groupId=ufo] Starting task vk_nau30_sink-0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:22:42,501 INFO || Creating task vk_nau30_sink-0 [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:22:42,502 INFO || ConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_sink predicates = [] tasks.max = 1 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig] 2023-08-23 11:22:42,502 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_sink predicates = [] tasks.max = 1 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-23 11:22:42,502 INFO || TaskConfig values: task.class = class io.debezium.connector.jdbc.JdbcSinkConnectorTask [org.apache.kafka.connect.runtime.TaskConfig] 2023-08-23 11:22:42,502 INFO || Instantiated task vk_nau30_sink-0 with version 2.4.0.Alpha2 of type io.debezium.connector.jdbc.JdbcSinkConnectorTask [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:22:42,502 INFO || AvroConverterConfig values: auto.register.schemas = true basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.connect.avro.AvroConverterConfig] 2023-08-23 11:22:42,502 INFO || KafkaAvroSerializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.remove.java.properties = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroSerializerConfig] 2023-08-23 11:22:42,503 INFO || KafkaAvroDeserializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] specific.avro.reader = false use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroDeserializerConfig] 2023-08-23 11:22:42,503 INFO || AvroDataConfig values: connect.meta.data = true discard.type.doc.default = false enhanced.avro.schema.support = false generalized.sum.type.support = false ignore.default.for.nullables = false schemas.cache.config = 1000 scrub.invalid.names = false [io.confluent.connect.avro.AvroDataConfig] 2023-08-23 11:22:42,503 INFO || AvroConverterConfig values: auto.register.schemas = true basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.connect.avro.AvroConverterConfig] 2023-08-23 11:22:42,503 INFO || KafkaAvroSerializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.remove.java.properties = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroSerializerConfig] 2023-08-23 11:22:42,503 INFO || KafkaAvroDeserializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] specific.avro.reader = false use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroDeserializerConfig] 2023-08-23 11:22:42,503 INFO || AvroDataConfig values: connect.meta.data = true discard.type.doc.default = false enhanced.avro.schema.support = false generalized.sum.type.support = false ignore.default.for.nullables = false schemas.cache.config = 1000 scrub.invalid.names = false [io.confluent.connect.avro.AvroDataConfig] 2023-08-23 11:22:42,503 INFO || Set up the key converter class io.confluent.connect.avro.AvroConverter for task vk_nau30_sink-0 using the connector config [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:22:42,503 INFO || Set up the value converter class io.confluent.connect.avro.AvroConverter for task vk_nau30_sink-0 using the connector config [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:22:42,503 INFO || Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task vk_nau30_sink-0 using the worker config [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:22:42,504 INFO || Initializing: org.apache.kafka.connect.runtime.TransformationChain{} [org.apache.kafka.connect.runtime.Worker] 2023-08-23 11:22:42,504 INFO || SinkConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_sink predicates = [] tasks.max = 1 topics = [] topics.regex = vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SinkConnectorConfig] 2023-08-23 11:22:42,504 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau30_sink predicates = [] tasks.max = 1 topics = [] topics.regex = vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-23 11:22:42,504 INFO || ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [broker1:29092, broker2:29092, broker3:29092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = connector-consumer-vk_nau30_sink-0 client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = connect-vk_nau30_sink group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer [org.apache.kafka.clients.consumer.ConsumerConfig] 2023-08-23 11:22:42,506 INFO || These configurations '[metrics.context.connect.kafka.cluster.id, metrics.context.connect.group.id]' were supplied but are not used yet. [org.apache.kafka.clients.consumer.ConsumerConfig] 2023-08-23 11:22:42,507 INFO || Kafka version: 3.5.1 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:22:42,507 INFO || Kafka commitId: 2c6fb6c54472e90a [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:22:42,507 INFO || Kafka startTimeMs: 1692778962507 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:22:42,507 INFO || [Worker clientId=connect-1, groupId=ufo] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-23 11:22:42,507 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Subscribed to pattern: 'vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30' [org.apache.kafka.clients.consumer.KafkaConsumer] 2023-08-23 11:22:42,508 INFO || Starting JdbcSinkConnectorConfig with configuration: [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,508 INFO || connector.class = io.debezium.connector.jdbc.JdbcSinkConnector [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,508 INFO || table.name.format = vk_nau30_tbl_servicecall [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,508 INFO || primary.key.mode = record_key [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,508 INFO || connection.password = ******** [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,508 INFO || tasks.max = 1 [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,508 INFO || connection.username = debeziumt [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,508 INFO || quote.identifiers = true [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,508 INFO || topics.regex = vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30 [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,508 INFO || value.converter.schema.registry.url = http://naument-sr:8081 [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,508 INFO || delete.enabled = true [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,508 INFO || schema.evolution = basic [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,508 INFO || auto.evolve = true [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,508 INFO || task.class = io.debezium.connector.jdbc.JdbcSinkConnectorTask [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,509 INFO || name = vk_nau30_sink [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,509 INFO || auto.create = true [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,509 INFO || value.converter = io.confluent.connect.avro.AvroConverter [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,509 INFO || connection.url = jdbc:postgresql://dwh-db-test.rgs.ru:5438/db_ods_test?currentSchema=naument1 [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,509 INFO || insert.mode = upsert [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,509 INFO || key.converter = io.confluent.connect.avro.AvroConverter [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,509 INFO || key.converter.schema.registry.url = http://naument-sr:8081 [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-23 11:22:42,509 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:42 +0000] "GET /connectors/vk_nau30_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:42,515 INFO || HHH000130: Instantiating explicit connection provider: org.hibernate.c3p0.internal.C3P0ConnectionProvider [org.hibernate.engine.jdbc.connections.internal.ConnectionProviderInitiator] 2023-08-23 11:22:42,515 INFO || HHH010002: C3P0 using driver: null at URL: jdbc:postgresql://dwh-db-test.rgs.ru:5438/db_ods_test?currentSchema=naument1 [org.hibernate.orm.connections.pooling.c3p0] 2023-08-23 11:22:42,515 INFO || HHH10001001: Connection properties: {password=****, user=debeziumt} [org.hibernate.orm.connections.pooling.c3p0] 2023-08-23 11:22:42,515 INFO || HHH10001003: Autocommit mode: false [org.hibernate.orm.connections.pooling.c3p0] 2023-08-23 11:22:42,515 WARN || HHH10001006: No JDBC Driver class was specified by property hibernate.connection.driver_class [org.hibernate.orm.connections.pooling.c3p0] 2023-08-23 11:22:42,516 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:42 +0000] "GET /connectors/vk_nau30_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:42,520 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:42 +0000] "GET /connectors/vk_nau30_sink/status HTTP/1.1" 200 111 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:42,520 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:42 +0000] "GET /connectors/vk_nau30_sink/tasks/0/status HTTP/1.1" 404 71 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:42,538 INFO || HHH10001007: JDBC isolation level: [org.hibernate.orm.connections.pooling.c3p0] 2023-08-23 11:22:42,539 INFO || Initializing c3p0 pool... com.mchange.v2.c3p0.PoolBackedDataSource@912af7bd [ connectionPoolDataSource -> com.mchange.v2.c3p0.WrapperConnectionPoolDataSource@ff190a07 [ acquireIncrement -> 32, acquireRetryAttempts -> 30, acquireRetryDelay -> 1000, autoCommitOnClose -> false, automaticTestTable -> null, breakAfterAcquireFailure -> false, checkoutTimeout -> 0, connectionCustomizerClassName -> null, connectionTesterClassName -> com.mchange.v2.c3p0.impl.DefaultConnectionTester, contextClassLoaderSource -> caller, debugUnreturnedConnectionStackTraces -> false, factoryClassLocation -> null, forceIgnoreUnresolvedTransactions -> false, forceSynchronousCheckins -> false, identityToken -> 2rw1gkax1xb7t5zy4t5mp|372d5a23, idleConnectionTestPeriod -> 0, initialPoolSize -> 5, maxAdministrativeTaskTime -> 0, maxConnectionAge -> 0, maxIdleTime -> 0, maxIdleTimeExcessConnections -> 0, maxPoolSize -> 32, maxStatements -> 0, maxStatementsPerConnection -> 0, minPoolSize -> 5, nestedDataSource -> com.mchange.v2.c3p0.DriverManagerDataSource@e06f1e01 [ description -> null, driverClass -> null, factoryClassLocation -> null, forceUseNamedDriverClass -> false, identityToken -> 2rw1gkax1xb7t5zy4t5mp|6b679676, jdbcUrl -> jdbc:postgresql://dwh-db-test.rgs.ru:5438/db_ods_test?currentSchema=naument1, properties -> {password=******, user=******} ], preferredTestQuery -> null, privilegeSpawnedThreads -> false, propertyCycle -> 0, statementCacheNumDeferredCloseThreads -> 0, testConnectionOnCheckin -> false, testConnectionOnCheckout -> false, unreturnedConnectionTimeout -> 0, usesTraditionalReflectiveProxies -> false; userOverrides: {} ], dataSourceName -> null, extensions -> {}, factoryClassLocation -> null, identityToken -> 2rw1gkax1xb7t5zy4t5mp|3963859f, numHelperThreads -> 3 ] [com.mchange.v2.c3p0.impl.AbstractPoolBackedDataSource] 2023-08-23 11:22:42,562 INFO || HHH000400: Using dialect: org.hibernate.dialect.PostgreSQLDialect [SQL dialect] 2023-08-23 11:22:42,574 INFO || HHH000490: Using JtaPlatform implementation: [org.hibernate.engine.transaction.jta.platform.internal.NoJtaPlatform] [org.hibernate.engine.transaction.jta.platform.internal.JtaPlatformInitiator] 2023-08-23 11:22:42,575 INFO || Using dialect io.debezium.connector.jdbc.dialect.postgres.PostgresDatabaseDialect [io.debezium.connector.jdbc.dialect.DatabaseDialectResolver] 2023-08-23 11:22:42,579 INFO || Database TimeZone: Europe/Moscow [io.debezium.connector.jdbc.dialect.GeneralDatabaseDialect] 2023-08-23 11:22:42,579 INFO || Database version 13.2.0 [io.debezium.connector.jdbc.JdbcChangeEventSink] 2023-08-23 11:22:42,579 INFO || WorkerSinkTask{id=vk_nau30_sink-0} Sink task finished initialization and start [org.apache.kafka.connect.runtime.WorkerSinkTask] 2023-08-23 11:22:42,579 INFO || WorkerSinkTask{id=vk_nau30_sink-0} Executing sink task [org.apache.kafka.connect.runtime.WorkerSinkTask] 2023-08-23 11:22:42,582 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Cluster ID: gVJjK6cZTd-nXsXP2EIHEQ [org.apache.kafka.clients.Metadata] 2023-08-23 11:22:42,582 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Discovered group coordinator broker1:29092 (id: 2147483646 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,583 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] (Re-)joining group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,585 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Request joining group due to: need to re-join with the given member-id: connector-consumer-vk_nau30_sink-0-69d01673-08d4-4d82-b188-975a0c72fb64 [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,586 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,586 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] (Re-)joining group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,587 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Successfully joined group with generation Generation{generationId=1, memberId='connector-consumer-vk_nau30_sink-0-69d01673-08d4-4d82-b188-975a0c72fb64', protocol='range'} [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,587 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Finished assignment for group at generation 1: {connector-consumer-vk_nau30_sink-0-69d01673-08d4-4d82-b188-975a0c72fb64=Assignment(partitions=[vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30-0])} [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,611 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Successfully synced group in generation Generation{generationId=1, memberId='connector-consumer-vk_nau30_sink-0-69d01673-08d4-4d82-b188-975a0c72fb64', protocol='range'} [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,611 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Notifying assignor about the new Assignment(partitions=[vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30-0]) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,611 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Adding newly assigned partitions: vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30-0 [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,611 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Found no committed offset for partition vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30-0 [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,612 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Resetting offset for partition vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker1:29092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] Hibernate: CREATE TABLE "vk_nau30_tbl_servicecall" ("ID" decimal(19,0) NOT NULL, "CREATION_DATE" timestamp(6) NOT NULL, "CLAIM$TRANSFERDATE" timestamp(6) NULL, PRIMARY KEY("ID")) 2023-08-23 11:22:42,669 ERROR || Failed to process record: Failed to process a sink record [io.debezium.connector.jdbc.JdbcSinkConnectorTask] org.apache.kafka.connect.errors.ConnectException: Failed to process a sink record at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:82) at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:93) at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:587) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:336) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:237) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:206) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259) at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:181) 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:829) Caused by: org.apache.kafka.connect.errors.DataException: CLAIM$TRANSFERDATE is not a valid field name at org.apache.kafka.connect.data.Struct.lookupField(Struct.java:254) at org.apache.kafka.connect.data.Struct.get(Struct.java:74) at io.debezium.connector.jdbc.dialect.GeneralDatabaseDialect.getColumnValueFromValueField(GeneralDatabaseDialect.java:653) at io.debezium.connector.jdbc.dialect.GeneralDatabaseDialect.columnQueryBindingFromField(GeneralDatabaseDialect.java:632) at io.debezium.connector.jdbc.dialect.postgres.PostgresDatabaseDialect.lambda$getUpsertStatement$1(PostgresDatabaseDialect.java:89) at io.debezium.connector.jdbc.dialect.SqlStatementBuilder.appendList(SqlStatementBuilder.java:37) at io.debezium.connector.jdbc.dialect.SqlStatementBuilder.appendLists(SqlStatementBuilder.java:55) at io.debezium.connector.jdbc.dialect.postgres.PostgresDatabaseDialect.getUpsertStatement(PostgresDatabaseDialect.java:89) at io.debezium.connector.jdbc.JdbcChangeEventSink.write(JdbcChangeEventSink.java:226) at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:79) ... 13 more 2023-08-23 11:22:42,680 ERROR || WorkerSinkTask{id=vk_nau30_sink-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: JDBC sink connector failure [org.apache.kafka.connect.runtime.WorkerSinkTask] org.apache.kafka.connect.errors.ConnectException: JDBC sink connector failure at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:83) at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:587) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:336) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:237) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:206) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259) at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:181) 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:829) Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to process a sink record at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:82) at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:93) ... 12 more Caused by: org.apache.kafka.connect.errors.DataException: CLAIM$TRANSFERDATE is not a valid field name at org.apache.kafka.connect.data.Struct.lookupField(Struct.java:254) at org.apache.kafka.connect.data.Struct.get(Struct.java:74) at io.debezium.connector.jdbc.dialect.GeneralDatabaseDialect.getColumnValueFromValueField(GeneralDatabaseDialect.java:653) at io.debezium.connector.jdbc.dialect.GeneralDatabaseDialect.columnQueryBindingFromField(GeneralDatabaseDialect.java:632) at io.debezium.connector.jdbc.dialect.postgres.PostgresDatabaseDialect.lambda$getUpsertStatement$1(PostgresDatabaseDialect.java:89) at io.debezium.connector.jdbc.dialect.SqlStatementBuilder.appendList(SqlStatementBuilder.java:37) at io.debezium.connector.jdbc.dialect.SqlStatementBuilder.appendLists(SqlStatementBuilder.java:55) at io.debezium.connector.jdbc.dialect.postgres.PostgresDatabaseDialect.getUpsertStatement(PostgresDatabaseDialect.java:89) at io.debezium.connector.jdbc.JdbcChangeEventSink.write(JdbcChangeEventSink.java:226) at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:79) ... 13 more 2023-08-23 11:22:42,680 ERROR || WorkerSinkTask{id=vk_nau30_sink-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted [org.apache.kafka.connect.runtime.WorkerTask] org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception. at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:618) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:336) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:237) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:206) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259) at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:181) 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:829) Caused by: org.apache.kafka.connect.errors.ConnectException: JDBC sink connector failure at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:83) at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:587) ... 11 more Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to process a sink record at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:82) at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:93) ... 12 more Caused by: org.apache.kafka.connect.errors.DataException: CLAIM$TRANSFERDATE is not a valid field name at org.apache.kafka.connect.data.Struct.lookupField(Struct.java:254) at org.apache.kafka.connect.data.Struct.get(Struct.java:74) at io.debezium.connector.jdbc.dialect.GeneralDatabaseDialect.getColumnValueFromValueField(GeneralDatabaseDialect.java:653) at io.debezium.connector.jdbc.dialect.GeneralDatabaseDialect.columnQueryBindingFromField(GeneralDatabaseDialect.java:632) at io.debezium.connector.jdbc.dialect.postgres.PostgresDatabaseDialect.lambda$getUpsertStatement$1(PostgresDatabaseDialect.java:89) at io.debezium.connector.jdbc.dialect.SqlStatementBuilder.appendList(SqlStatementBuilder.java:37) at io.debezium.connector.jdbc.dialect.SqlStatementBuilder.appendLists(SqlStatementBuilder.java:55) at io.debezium.connector.jdbc.dialect.postgres.PostgresDatabaseDialect.getUpsertStatement(PostgresDatabaseDialect.java:89) at io.debezium.connector.jdbc.JdbcChangeEventSink.write(JdbcChangeEventSink.java:226) at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:79) ... 13 more 2023-08-23 11:22:42,680 INFO || Closing session. [io.debezium.connector.jdbc.JdbcChangeEventSink] 2023-08-23 11:22:42,681 INFO || Closing the session factory [io.debezium.connector.jdbc.JdbcChangeEventSink] 2023-08-23 11:22:42,683 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Revoke previously assigned partitions vk_nau30.DEBEZIUM.GBC_TBL_SERVICECALL_NC30-0 [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,683 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Member connector-consumer-vk_nau30_sink-0-69d01673-08d4-4d82-b188-975a0c72fb64 sending LeaveGroup request to coordinator broker1:29092 (id: 2147483646 rack: null) due to the consumer is being closed [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,683 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Resetting generation and member id due to: consumer pro-actively leaving the group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,683 INFO || [Consumer clientId=connector-consumer-vk_nau30_sink-0, groupId=connect-vk_nau30_sink] Request joining group due to: consumer pro-actively leaving the group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-23 11:22:42,686 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:22:42,686 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:22:42,686 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2023-08-23 11:22:42,687 INFO || App info kafka.consumer for connector-consumer-vk_nau30_sink-0 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2023-08-23 11:22:45,123 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors HTTP/1.1" 200 128 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,128 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,130 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,130 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,134 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau26_sink/config HTTP/1.1" 200 809 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,136 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau29_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,138 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau30_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,138 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,140 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau28_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,141 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,142 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau28_sink/status HTTP/1.1" 200 4746 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,143 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,144 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau27_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 9 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,144 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau30_src HTTP/1.1" 200 1601 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,145 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau29_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,146 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,147 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau27_sink/status HTTP/1.1" 200 2228 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,151 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau27_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,151 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau28_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,152 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,153 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau30_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,154 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,154 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau30_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,155 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau29_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,156 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,158 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau26_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,160 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau28_sink/tasks/0/status HTTP/1.1" 200 4635 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,161 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,162 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau29_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,162 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,163 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau30_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,164 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau30_src/config HTTP/1.1" 200 1504 "-" "ReactorNetty/1.1.6" 9 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,164 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau28_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 11 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,166 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,168 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau27_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 12 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,169 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau30_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,170 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau30_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,172 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau29_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,172 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau30_src/tasks HTTP/1.1" 200 1624 "-" "ReactorNetty/1.1.6" 8 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,173 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,174 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau27_sink/tasks/0/status HTTP/1.1" 200 2117 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,174 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau28_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,175 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau30_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,176 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau29_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,177 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 9 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,178 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,179 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau30_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,179 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau30_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-23 11:22:45,180 INFO || 10.0.18.150 - - [23/Aug/2023:08:22:45 +0000] "GET /connectors/vk_nau27_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer]