[root@master01 kafka_2.11-2.4.0]# ./bin/connect-standalone.sh ./config/connect-standalone.properties ./config/OracleSourceConnector.properties [2020-04-13 14:26:09,875] INFO Kafka Connect standalone worker initializing ... (org.apache.kafka.connect.cli.ConnectStandalone:69) [2020-04-13 14:26:09,885] INFO WorkerInfo values: jvm.args = -Xms256M, -Xmx2G, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -Djava.awt.headless=true, -Dcom.sun.management.jmxremote, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=/opt/kafka_2.11-2.4.0/bin/../logs, -Dlog4j.configuration=file:./bin/../config/connect-log4j.properties jvm.spec = Oracle Corporation, Java HotSpot(TM) 64-Bit Server VM, 1.8.0_241, 25.241-b07 jvm.classpath = .:/opt/java/jdk1.8.0_241/lib/dt.jar:/opt/java/jdk1.8.0_241/lib/tools.jar:/opt/kafka_2.11-2.1.1/lib/:/opt/kafka_2.11-2.4.0/bin/../libs/activation-1.1.1.jar:/opt/kafka_2.11-2.4.0/bin/../libs/aopalliance-repackaged-2.5.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/argparse4j-0.7.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/audience-annotations-0.5.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/commons-cli-1.4.jar:/opt/kafka_2.11-2.4.0/bin/../libs/commons-lang3-3.8.1.jar:/opt/kafka_2.11-2.4.0/bin/../libs/connect-api-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/connect-basic-auth-extension-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/connect-file-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/connect-json-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/connect-mirror-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/connect-mirror-client-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/connect-runtime-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/connect-transforms-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/guava-20.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/hk2-api-2.5.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/hk2-locator-2.5.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/hk2-utils-2.5.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jackson-annotations-2.10.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jackson-core-2.10.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jackson-databind-2.10.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jackson-dataformat-csv-2.10.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jackson-datatype-jdk8-2.10.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jackson-jaxrs-base-2.10.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jackson-jaxrs-json-provider-2.10.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jackson-module-jaxb-annotations-2.10.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jackson-module-paranamer-2.10.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jackson-module-scala_2.11-2.10.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jakarta.activation-api-1.2.1.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jakarta.annotation-api-1.3.4.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jakarta.inject-2.5.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jakarta.ws.rs-api-2.1.5.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jakarta.xml.bind-api-2.3.2.jar:/opt/kafka_2.11-2.4.0/bin/../libs/javassist-3.22.0-CR2.jar:/opt/kafka_2.11-2.4.0/bin/../libs/javax.servlet-api-3.1.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/javax.ws.rs-api-2.1.1.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jaxb-api-2.3.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jersey-client-2.28.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jersey-common-2.28.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jersey-container-servlet-2.28.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jersey-container-servlet-core-2.28.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jersey-hk2-2.28.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jersey-media-jaxb-2.28.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jersey-server-2.28.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jetty-client-9.4.20.v20190813.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jetty-continuation-9.4.20.v20190813.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jetty-http-9.4.20.v20190813.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jetty-io-9.4.20.v20190813.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jetty-security-9.4.20.v20190813.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jetty-server-9.4.20.v20190813.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jetty-servlet-9.4.20.v20190813.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jetty-servlets-9.4.20.v20190813.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jetty-util-9.4.20.v20190813.jar:/opt/kafka_2.11-2.4.0/bin/../libs/jopt-simple-5.0.4.jar:/opt/kafka_2.11-2.4.0/bin/../libs/kafka_2.11-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/kafka_2.11-2.4.0-sources.jar:/opt/kafka_2.11-2.4.0/bin/../libs/kafka-clients-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/kafka-log4j-appender-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/kafka-streams-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/kafka-streams-examples-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/kafka-streams-scala_2.11-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/kafka-streams-test-utils-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/kafka-tools-2.4.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/log4j-1.2.17.jar:/opt/kafka_2.11-2.4.0/bin/../libs/lz4-java-1.6.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/maven-artifact-3.6.1.jar:/opt/kafka_2.11-2.4.0/bin/../libs/metrics-core-2.2.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/netty-buffer-4.1.42.Final.jar:/opt/kafka_2.11-2.4.0/bin/../libs/netty-codec-4.1.42.Final.jar:/opt/kafka_2.11-2.4.0/bin/../libs/netty-common-4.1.42.Final.jar:/opt/kafka_2.11-2.4.0/bin/../libs/netty-handler-4.1.42.Final.jar:/opt/kafka_2.11-2.4.0/bin/../libs/netty-resolver-4.1.42.Final.jar:/opt/kafka_2.11-2.4.0/bin/../libs/netty-transport-4.1.42.Final.jar:/opt/kafka_2.11-2.4.0/bin/../libs/netty-transport-native-epoll-4.1.42.Final.jar:/opt/kafka_2.11-2.4.0/bin/../libs/netty-transport-native-unix-common-4.1.42.Final.jar:/opt/kafka_2.11-2.4.0/bin/../libs/ojdbc8.jar:/opt/kafka_2.11-2.4.0/bin/../libs/orai18n-12.1.0.2.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/osgi-resource-locator-1.0.1.jar:/opt/kafka_2.11-2.4.0/bin/../libs/paranamer-2.8.jar:/opt/kafka_2.11-2.4.0/bin/../libs/plexus-utils-3.2.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/reflections-0.9.11.jar:/opt/kafka_2.11-2.4.0/bin/../libs/rocksdbjni-5.18.3.jar:/opt/kafka_2.11-2.4.0/bin/../libs/scala-collection-compat_2.11-2.1.2.jar:/opt/kafka_2.11-2.4.0/bin/../libs/scala-java8-compat_2.11-0.9.0.jar:/opt/kafka_2.11-2.4.0/bin/../libs/scala-library-2.11.12.jar:/opt/kafka_2.11-2.4.0/bin/../libs/scala-logging_2.11-3.9.2.jar:/opt/kafka_2.11-2.4.0/bin/../libs/scala-reflect-2.11.12.jar:/opt/kafka_2.11-2.4.0/bin/../libs/slf4j-api-1.7.28.jar:/opt/kafka_2.11-2.4.0/bin/../libs/slf4j-log4j12-1.7.28.jar:/opt/kafka_2.11-2.4.0/bin/../libs/snappy-java-1.1.7.3.jar:/opt/kafka_2.11-2.4.0/bin/../libs/validation-api-2.0.1.Final.jar:/opt/kafka_2.11-2.4.0/bin/../libs/zookeeper-3.5.6.jar:/opt/kafka_2.11-2.4.0/bin/../libs/zookeeper-jute-3.5.6.jar:/opt/kafka_2.11-2.4.0/bin/../libs/zstd-jni-1.4.3-1.jar os.spec = Linux, amd64, 3.10.0-1062.el7.x86_64 os.vcpus = 4 (org.apache.kafka.connect.runtime.WorkerInfo:71) [2020-04-13 14:26:09,900] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectStandalone:78) [2020-04-13 14:26:09,935] INFO Loading plugin from: /opt/kafka_2.11-2.4.0/share/java/kafka/kafka-connect-oracle-1.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-04-13 14:26:10,200] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka_2.11-2.4.0/share/java/kafka/kafka-connect-oracle-1.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-04-13 14:26:10,201] INFO Added plugin 'com.ecer.kafka.connect.oracle.OracleSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:10,201] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:10,202] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:10,202] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,986] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-04-13 14:26:13,987] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,987] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,987] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,988] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,988] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,988] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,990] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,990] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,990] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,990] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,991] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,991] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,991] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,991] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,991] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,992] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,992] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,992] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,992] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,993] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,993] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,993] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,993] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,993] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,993] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,994] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,994] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,994] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,994] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,994] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,995] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,995] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,995] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,995] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,995] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,995] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,996] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,996] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,996] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,996] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,996] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,997] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,997] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-13 14:26:13,998] INFO Added aliases 'OracleSourceConnector' and 'OracleSource' to plugin 'com.ecer.kafka.connect.oracle.OracleSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:13,999] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:13,999] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:13,999] INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,000] INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,000] INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,001] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,001] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,001] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,001] INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,002] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,002] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,006] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,007] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,007] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,007] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,008] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,008] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,008] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,009] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,009] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,009] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,009] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,010] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,010] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,010] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,011] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,011] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-13 14:26:14,011] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,012] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-13 14:26:14,013] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-13 14:26:14,013] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-13 14:26:14,013] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-13 14:26:14,014] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,014] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,014] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-13 14:26:14,045] INFO StandaloneConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null bootstrap.servers = [localhost:9092] client.dns.lookup = default config.providers = [] connector.client.config.override.policy = None header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter internal.key.converter = class org.apache.kafka.connect.json.JsonConverter internal.value.converter = class org.apache.kafka.connect.json.JsonConverter key.converter = class org.apache.kafka.connect.json.JsonConverter listeners = null metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 10000 offset.flush.timeout.ms = 5000 offset.storage.file.filename = /tmp/connect.offsets plugin.path = [/opt/kafka_2.11-2.4.0/share/java/kafka] rest.advertised.host.name = null rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] rest.host.name = null rest.port = 8083 ssl.client.auth = none task.shutdown.graceful.timeout.ms = 5000 value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.standalone.StandaloneConfig:347) [2020-04-13 14:26:14,049] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43) [2020-04-13 14:26:14,055] INFO AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 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 = 120000 retries = 5 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.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.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-04-13 14:26:14,157] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-13 14:26:14,157] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-13 14:26:14,158] WARN The configuration 'offset.storage.file.filename' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-13 14:26:14,158] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-13 14:26:14,158] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-13 14:26:14,158] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-13 14:26:14,158] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-13 14:26:14,159] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-13 14:26:14,159] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-13 14:26:14,160] INFO Kafka startTimeMs: 1586759174159 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-13 14:26:14,758] INFO Kafka cluster ID: AMX-KwiHQOWcfhLWJOZFWQ (org.apache.kafka.connect.util.ConnectUtils:59) [2020-04-13 14:26:14,899] INFO Logging initialized @5796ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:169) [2020-04-13 14:26:15,021] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:131) [2020-04-13 14:26:15,022] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer:203) [2020-04-13 14:26:15,041] INFO jetty-9.4.20.v20190813; built: 2019-08-13T21:28:18.144Z; git: 84700530e645e812b336747464d6fbbf370c9a20; jvm 1.8.0_241-b07 (org.eclipse.jetty.server.Server:359) [2020-04-13 14:26:15,130] INFO Started http_8083@74bdc168{HTTP/1.1,[http/1.1]}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:293) [2020-04-13 14:26:15,131] INFO Started @6027ms (org.eclipse.jetty.server.Server:399) [2020-04-13 14:26:15,184] INFO Advertised URI: http://192.168.227.128:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:365) [2020-04-13 14:26:15,184] INFO REST server listening at http://192.168.227.128:8083/, advertising URL http://192.168.227.128:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:218) [2020-04-13 14:26:15,184] INFO Advertised URI: http://192.168.227.128:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:365) [2020-04-13 14:26:15,185] INFO REST admin endpoints at http://192.168.227.128:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:219) [2020-04-13 14:26:15,185] INFO Advertised URI: http://192.168.227.128:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:365) [2020-04-13 14:26:15,185] INFO Setting up None Policy for ConnectorClientConfigOverride. This will disallow any client configuration to be overridden (org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy:45) [2020-04-13 14:26:15,214] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-13 14:26:15,214] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-13 14:26:15,215] INFO Kafka startTimeMs: 1586759175214 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-13 14:26:15,450] INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:347) [2020-04-13 14:26:15,453] INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:347) [2020-04-13 14:26:15,470] INFO Kafka Connect standalone worker initialization took 5592ms (org.apache.kafka.connect.cli.ConnectStandalone:100) [2020-04-13 14:26:15,470] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:50) [2020-04-13 14:26:15,470] INFO Herder starting (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:93) [2020-04-13 14:26:15,470] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:184) [2020-04-13 14:26:15,471] INFO Starting FileOffsetBackingStore with file /tmp/connect.offsets (org.apache.kafka.connect.storage.FileOffsetBackingStore:58) [2020-04-13 14:26:15,489] INFO Worker started (org.apache.kafka.connect.runtime.Worker:191) [2020-04-13 14:26:15,489] INFO Herder started (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:95) [2020-04-13 14:26:15,489] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer:223) [2020-04-13 14:26:15,599] INFO Adding admin resources to main listener (org.apache.kafka.connect.runtime.rest.RestServer:240) [2020-04-13 14:26:15,723] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:333) [2020-04-13 14:26:15,723] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:338) [2020-04-13 14:26:15,725] INFO node0 Scavenging every 660000ms (org.eclipse.jetty.server.session:140) Apr 13, 2020 2:26:16 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource will be ignored. Apr 13, 2020 2:26:16 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource will be ignored. Apr 13, 2020 2:26:16 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResource will be ignored. Apr 13, 2020 2:26:16 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource will be ignored. Apr 13, 2020 2:26:16 PM org.glassfish.jersey.internal.Errors logErrors WARNING: The following warnings have been detected: WARNING: The (sub)resource method listLoggers in org.apache.kafka.connect.runtime.rest.resources.LoggingResource contains empty path annotation. WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation. WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation. [2020-04-13 14:26:16,927] INFO Started o.e.j.s.ServletContextHandler@55120f99{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:824) [2020-04-13 14:26:16,927] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:313) [2020-04-13 14:26:16,927] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:56) [2020-04-13 14:26:16,939] INFO AbstractConfig values: (org.apache.kafka.common.config.AbstractConfig:347) [2020-04-13 14:26:16,958] INFO ConnectorConfig values: config.action.reload = restart connector.class = com.ecer.kafka.connect.oracle.OracleSourceConnector 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 = null name = oracle-logminer-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:347) [2020-04-13 14:26:16,959] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = com.ecer.kafka.connect.oracle.OracleSourceConnector 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 = null name = oracle-logminer-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-13 14:26:16,959] INFO Creating connector oracle-logminer-connector of type com.ecer.kafka.connect.oracle.OracleSourceConnector (org.apache.kafka.connect.runtime.Worker:251) [2020-04-13 14:26:16,963] INFO Instantiated connector oracle-logminer-connector with version null of type class com.ecer.kafka.connect.oracle.OracleSourceConnector (org.apache.kafka.connect.runtime.Worker:254) [2020-04-13 14:26:16,964] INFO OracleSourceConnectorConfig values: db.fetch.size = 1 db.hostname = 192.168.227.129 db.name = orcl.test db.name.alias = test db.port = 1521 db.user = test_ogg db.user.password = test_ogg multitenant = false parse.dml.data = true reset.offset = true start.scn = table.blacklist = zyh.* table.whitelist = test_ogg.* topic = cdctest (com.ecer.kafka.connect.oracle.OracleSourceConnectorConfig:347) [2020-04-13 14:26:16,965] INFO Finished creating connector oracle-logminer-connector (org.apache.kafka.connect.runtime.Worker:273) [2020-04-13 14:26:16,966] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = com.ecer.kafka.connect.oracle.OracleSourceConnector 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 = null name = oracle-logminer-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:347) [2020-04-13 14:26:16,966] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = com.ecer.kafka.connect.oracle.OracleSourceConnector 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 = null name = oracle-logminer-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-13 14:26:16,969] INFO Creating task oracle-logminer-connector-0 (org.apache.kafka.connect.runtime.Worker:419) [2020-04-13 14:26:16,972] INFO ConnectorConfig values: config.action.reload = restart connector.class = com.ecer.kafka.connect.oracle.OracleSourceConnector 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 = null name = oracle-logminer-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:347) [2020-04-13 14:26:16,973] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = com.ecer.kafka.connect.oracle.OracleSourceConnector 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 = null name = oracle-logminer-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-13 14:26:16,975] INFO TaskConfig values: task.class = class com.ecer.kafka.connect.oracle.OracleSourceTask (org.apache.kafka.connect.runtime.TaskConfig:347) [2020-04-13 14:26:16,976] INFO Instantiated task oracle-logminer-connector-0 with version null of type com.ecer.kafka.connect.oracle.OracleSourceTask (org.apache.kafka.connect.runtime.Worker:434) [2020-04-13 14:26:16,976] INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true (org.apache.kafka.connect.json.JsonConverterConfig:347) [2020-04-13 14:26:16,976] INFO Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task oracle-logminer-connector-0 using the worker config (org.apache.kafka.connect.runtime.Worker:447) [2020-04-13 14:26:16,977] INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true (org.apache.kafka.connect.json.JsonConverterConfig:347) [2020-04-13 14:26:16,977] INFO Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task oracle-logminer-connector-0 using the worker config (org.apache.kafka.connect.runtime.Worker:453) [2020-04-13 14:26:16,977] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task oracle-logminer-connector-0 using the worker config (org.apache.kafka.connect.runtime.Worker:460) [2020-04-13 14:26:16,983] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:514) [2020-04-13 14:26:16,991] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.dns.lookup = default client.id = connector-producer-oracle-logminer-connector-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 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 2147483647 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.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.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX 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:347) [2020-04-13 14:26:17,022] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-13 14:26:17,022] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-13 14:26:17,022] INFO Kafka startTimeMs: 1586759177022 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-13 14:26:17,036] INFO Created connector oracle-logminer-connector (org.apache.kafka.connect.cli.ConnectStandalone:112) [2020-04-13 14:26:17,037] INFO OracleSourceConnectorConfig values: db.fetch.size = 1 db.hostname = 192.168.227.129 db.name = orcl.test db.name.alias = test db.port = 1521 db.user = test_ogg db.user.password = test_ogg multitenant = false parse.dml.data = true reset.offset = true start.scn = table.blacklist = zyh.* table.whitelist = test_ogg.* topic = cdctest (com.ecer.kafka.connect.oracle.OracleSourceConnectorConfig:347) [2020-04-13 14:26:17,038] INFO Oracle Kafka Connector is starting on test (com.ecer.kafka.connect.oracle.OracleSourceTask:110) [2020-04-13 14:26:17,132] INFO [Producer clientId=connector-producer-oracle-logminer-connector-0] Cluster ID: AMX-KwiHQOWcfhLWJOZFWQ (org.apache.kafka.clients.Metadata:261) [2020-04-13 14:26:17,957] INFO Connected to database version 112010 (com.ecer.kafka.connect.oracle.OracleSourceTask:115) [2020-04-13 14:26:17,957] INFO Starting LogMiner Session (com.ecer.kafka.connect.oracle.OracleSourceTask:118) [2020-04-13 14:26:17,980] INFO Resetting offset with new SCN (com.ecer.kafka.connect.oracle.OracleSourceTask:170) [2020-04-13 14:26:17,982] INFO Getting current scn from database 1642889 (com.ecer.kafka.connect.oracle.OracleSourceTask:185) [2020-04-13 14:26:17,982] INFO Commit SCN : 0 (com.ecer.kafka.connect.oracle.OracleSourceTask:188) [2020-04-13 14:26:17,983] INFO Log Miner will start at new position SCN : 1642889 with fetch size : 1 (com.ecer.kafka.connect.oracle.OracleSourceTask:189) [2020-04-13 14:26:27,035] INFO WorkerSourceTask{id=oracle-logminer-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416) [2020-04-13 14:26:27,036] INFO WorkerSourceTask{id=oracle-logminer-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433) [2020-04-13 14:26:37,037] INFO WorkerSourceTask{id=oracle-logminer-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416) [2020-04-13 14:26:37,038] INFO WorkerSourceTask{id=oracle-logminer-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)