+ shift + export MALLOC_ARENA_MAX=2 + MALLOC_ARENA_MAX=2 + JAVA_OPTS=' -Dvertx.cacheDirBase=/tmp -Djava.security.egd=file:/dev/./urandom' ++ get_gc_opts ++ '[' '' == true ']' ++ echo '' + JAVA_OPTS=' -Dvertx.cacheDirBase=/tmp -Djava.security.egd=file:/dev/./urandom ' + exec /usr/bin/tini -w -e 143 -- java -Dvertx.cacheDirBase=/tmp -Djava.security.egd=file:/dev/./urandom -classpath lib/io.strimzi.cluster-operator-0.18.0-SNAPSHOT.jar:lib/io.prometheus.simpleclient_common-0.7.0.jar:lib/com.github.luben.zstd-jni-1.4.3-1.jar:lib/io.netty.netty-handler-4.1.45.Final.jar:lib/org.keycloak.keycloak-core-7.0.0.jar:lib/io.netty.netty-codec-http-4.1.45.Final.jar:lib/org.bouncycastle.bcpkix-jdk15on-1.60.jar:lib/org.quartz-scheduler.quartz-2.2.1.jar:lib/io.strimzi.operator-common-0.18.0-SNAPSHOT.jar:lib/org.bouncycastle.bcprov-jdk15on-1.60.jar:lib/com.squareup.okio.okio-1.15.0.jar:lib/io.netty.netty-buffer-4.1.45.Final.jar:lib/org.yaml.snakeyaml-1.24.jar:lib/io.fabric8.openshift-client-4.6.4.jar:lib/io.strimzi.api-0.18.0-SNAPSHOT.jar:lib/io.netty.netty-common-4.1.45.Final.jar:lib/org.apache.logging.log4j.log4j-api-2.13.0.jar:lib/org.xerial.snappy.snappy-java-1.1.7.3.jar:lib/org.hdrhistogram.HdrHistogram-2.1.11.jar:lib/io.prometheus.simpleclient-0.7.0.jar:lib/io.strimzi.kafka-oauth-common-0.4.0.jar:lib/org.apache.yetus.audience-annotations-0.5.0.jar:lib/com.fasterxml.jackson.dataformat.jackson-dataformat-yaml-2.10.2.jar:lib/org.keycloak.keycloak-common-7.0.0.jar:lib/io.strimzi.certificate-manager-0.18.0-SNAPSHOT.jar:lib/io.netty.netty-codec-4.1.45.Final.jar:lib/io.micrometer.micrometer-core-1.3.1.jar:lib/io.strimzi.kafka-oauth-server-0.4.0.jar:lib/jakarta.activation.jakarta.activation-api-1.2.1.jar:lib/io.vertx.vertx-core-3.8.5.jar:lib/io.netty.netty-codec-dns-4.1.45.Final.jar:lib/io.fabric8.kubernetes-model-4.6.4.jar:lib/io.netty.netty-codec-socks-4.1.45.Final.jar:lib/com.github.mifmif.generex-1.0.2.jar:lib/io.netty.netty-resolver-4.1.45.Final.jar:lib/org.apache.zookeeper.zookeeper-jute-3.5.6.jar:lib/io.netty.netty-handler-proxy-4.1.45.Final.jar:lib/com.squareup.okhttp3.logging-interceptor-3.12.6.jar:lib/io.netty.netty-transport-native-epoll-4.1.45.Final-linux-x86_64.jar:lib/io.netty.netty-transport-native-unix-common-4.1.45.Final.jar:lib/org.apache.zookeeper.zookeeper-3.5.6.jar:lib/dk.brics.automaton.automaton-1.11-8.jar:lib/io.vertx.vertx-micrometer-metrics-3.8.5.jar:lib/com.fasterxml.jackson.core.jackson-core-2.10.2.jar:lib/io.netty.netty-transport-4.1.45.Final.jar:lib/io.netty.netty-transport-native-epoll-4.1.45.Final.jar:lib/jakarta.xml.bind.jakarta.xml.bind-api-2.3.2.jar:lib/org.apache.logging.log4j.log4j-slf4j-impl-2.13.0.jar:lib/com.fasterxml.jackson.core.jackson-annotations-2.10.2.jar:lib/io.fabric8.zjsonpatch-0.3.0.jar:lib/org.lz4.lz4-java-1.6.0.jar:lib/io.strimzi.crd-annotations-0.18.0-SNAPSHOT.jar:lib/io.fabric8.kubernetes-client-4.6.4.jar:lib/com.fasterxml.jackson.module.jackson-module-jaxb-annotations-2.10.2.jar:lib/com.squareup.okhttp3.okhttp-3.12.6.jar:lib/io.netty.netty-codec-http2-4.1.45.Final.jar:lib/org.apache.logging.log4j.log4j-core-2.13.0.jar:lib/io.fabric8.kubernetes-model-common-4.6.4.jar:lib/com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:lib/io.netty.netty-resolver-dns-4.1.45.Final.jar:lib/io.strimzi.kafka-oauth-client-0.4.0.jar:lib/org.slf4j.slf4j-api-1.7.25.jar:lib/org.latencyutils.LatencyUtils-2.0.3.jar:lib/io.strimzi.config-model-0.18.0-SNAPSHOT.jar:lib/org.apache.kafka.kafka-clients-2.4.0.jar:lib/io.micrometer.micrometer-registry-prometheus-1.3.1.jar io.strimzi.operator.cluster.Main 2020-04-15 00:31:55 DEBUG DnsNameResolver:1205 - [id: 0x4b0a0cbd] RECEIVED: UDP [40426: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:38355, 40426, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN CNAME) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:31:55 DEBUG DnsQueryContext:117 - [id: 0x4b0a0cbd] WRITE: UDP, [44399: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN A) 2020-04-15 00:31:55 DEBUG DnsQueryContext:117 - [id: 0x4b0a0cbd] WRITE: UDP, [50329: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN AAAA) 2020-04-15 00:31:55 DEBUG DnsNameResolver:1205 - [id: 0x4b0a0cbd] RECEIVED: UDP [44399: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:38355, 44399, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN A) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:31:55 DEBUG DnsNameResolver:1205 - [id: 0x4b0a0cbd] RECEIVED: UDP [50329: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:38355, 50329, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN AAAA) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:31:55 DEBUG DnsQueryContext:117 - [id: 0x4b0a0cbd] WRITE: UDP, [33161: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN CNAME) 2020-04-15 00:31:55 DEBUG DnsNameResolver:1205 - [id: 0x4b0a0cbd] RECEIVED: UDP [33161: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:38355, 33161, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN CNAME) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0x81f41569, L:/172.17.0.6:58338 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] WRITE: 194B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 63 6f 6e 6e 65 63 74 6f 72 73 2f |GET /connectors/| |00000010| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |00000020| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |00000030| 72 67 65 74 2e 4d 69 72 72 6f 72 43 68 65 63 6b |rget.MirrorCheck| |00000040| 70 6f 69 6e 74 43 6f 6e 6e 65 63 74 6f 72 2f 73 |pointConnector/s| |00000050| 74 61 74 75 73 20 48 54 54 50 2f 31 2e 31 0d 0a |tatus HTTP/1.1..| |00000060| 41 63 63 65 70 74 3a 20 61 70 70 6c 69 63 61 74 |Accept: applicat| |00000070| 69 6f 6e 2f 6a 73 6f 6e 0d 0a 68 6f 73 74 3a 20 |ion/json..host: | |00000080| 6d 79 2d 63 6c 75 73 74 65 72 2d 6d 69 72 72 6f |my-cluster-mirro| |00000090| 72 6d 61 6b 65 72 32 2d 61 70 69 2e 6d 69 72 72 |rmaker2-api.mirr| |000000a0| 6f 72 6d 61 6b 65 72 32 2d 63 6c 75 73 74 65 72 |ormaker2-cluster| |000000b0| 2d 74 65 73 74 2e 73 76 63 3a 38 30 38 33 0d 0a |-test.svc:8083..| |000000c0| 0d 0a |.. | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0x81f41569, L:/172.17.0.6:58338 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0x81f41569, L:/172.17.0.6:58338 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0xaa66a770, L:/172.17.0.6:58340 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] WRITE: 193B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 63 6f 6e 6e 65 63 74 6f 72 73 2f |GET /connectors/| |00000010| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |00000020| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |00000030| 72 67 65 74 2e 4d 69 72 72 6f 72 48 65 61 72 74 |rget.MirrorHeart| |00000040| 62 65 61 74 43 6f 6e 6e 65 63 74 6f 72 2f 73 74 |beatConnector/st| |00000050| 61 74 75 73 20 48 54 54 50 2f 31 2e 31 0d 0a 41 |atus HTTP/1.1..A| |00000060| 63 63 65 70 74 3a 20 61 70 70 6c 69 63 61 74 69 |ccept: applicati| |00000070| 6f 6e 2f 6a 73 6f 6e 0d 0a 68 6f 73 74 3a 20 6d |on/json..host: m| |00000080| 79 2d 63 6c 75 73 74 65 72 2d 6d 69 72 72 6f 72 |y-cluster-mirror| |00000090| 6d 61 6b 65 72 32 2d 61 70 69 2e 6d 69 72 72 6f |maker2-api.mirro| |000000a0| 72 6d 61 6b 65 72 32 2d 63 6c 75 73 74 65 72 2d |rmaker2-cluster-| |000000b0| 74 65 73 74 2e 73 76 63 3a 38 30 38 33 0d 0a 0d |test.svc:8083...| |000000c0| 0a |. | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0xaa66a770, L:/172.17.0.6:58340 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0xaa66a770, L:/172.17.0.6:58340 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0x96c31d88, L:/172.17.0.6:58342 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] WRITE: 190B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 63 6f 6e 6e 65 63 74 6f 72 73 2f |GET /connectors/| |00000010| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |00000020| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |00000030| 72 67 65 74 2e 4d 69 72 72 6f 72 53 6f 75 72 63 |rget.MirrorSourc| |00000040| 65 43 6f 6e 6e 65 63 74 6f 72 2f 73 74 61 74 75 |eConnector/statu| |00000050| 73 20 48 54 54 50 2f 31 2e 31 0d 0a 41 63 63 65 |s HTTP/1.1..Acce| |00000060| 70 74 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pt: application/| |00000070| 6a 73 6f 6e 0d 0a 68 6f 73 74 3a 20 6d 79 2d 63 |json..host: my-c| |00000080| 6c 75 73 74 65 72 2d 6d 69 72 72 6f 72 6d 61 6b |luster-mirrormak| |00000090| 65 72 32 2d 61 70 69 2e 6d 69 72 72 6f 72 6d 61 |er2-api.mirrorma| |000000a0| 6b 65 72 32 2d 63 6c 75 73 74 65 72 2d 74 65 73 |ker2-cluster-tes| |000000b0| 74 2e 73 76 63 3a 38 30 38 33 0d 0a 0d 0a |t.svc:8083.... | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0x96c31d88, L:/172.17.0.6:58342 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0x96c31d88, L:/172.17.0.6:58342 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0xaa66a770, L:/172.17.0.6:58340 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 361B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 48 54 54 50 2f 31 2e 31 20 32 30 30 20 4f 4b 0d |HTTP/1.1 200 OK.| |00000010| 0a 44 61 74 65 3a 20 57 65 64 2c 20 31 35 20 41 |.Date: Wed, 15 A| |00000020| 70 72 20 32 30 32 30 20 30 30 3a 33 31 3a 35 35 |pr 2020 00:31:55| |00000030| 20 47 4d 54 0d 0a 43 6f 6e 74 65 6e 74 2d 54 79 | GMT..Content-Ty| |00000040| 70 65 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pe: application/| |00000050| 6a 73 6f 6e 0d 0a 43 6f 6e 74 65 6e 74 2d 4c 65 |json..Content-Le| |00000060| 6e 67 74 68 3a 20 32 31 39 0d 0a 53 65 72 76 65 |ngth: 219..Serve| |00000070| 72 3a 20 4a 65 74 74 79 28 39 2e 34 2e 32 30 2e |r: Jetty(9.4.20.| |00000080| 76 32 30 31 39 30 38 31 33 29 0d 0a 0d 0a 7b 22 |v20190813)....{"| |00000090| 6e 61 6d 65 22 3a 22 6d 79 2d 63 6c 75 73 74 65 |name":"my-cluste| |000000a0| 72 2d 73 6f 75 72 63 65 2d 3e 6d 79 2d 63 6c 75 |r-source->my-clu| |000000b0| 73 74 65 72 2d 74 61 72 67 65 74 2e 4d 69 72 72 |ster-target.Mirr| |000000c0| 6f 72 48 65 61 72 74 62 65 61 74 43 6f 6e 6e 65 |orHeartbeatConne| |000000d0| 63 74 6f 72 22 2c 22 63 6f 6e 6e 65 63 74 6f 72 |ctor","connector| |000000e0| 22 3a 7b 22 73 74 61 74 65 22 3a 22 52 55 4e 4e |":{"state":"RUNN| |000000f0| 49 4e 47 22 2c 22 77 6f 72 6b 65 72 5f 69 64 22 |ING","worker_id"| |00000100| 3a 22 31 37 32 2e 31 37 2e 30 2e 31 39 3a 38 30 |:"172.17.0.19:80| |00000110| 38 33 22 7d 2c 22 74 61 73 6b 73 22 3a 5b 7b 22 |83"},"tasks":[{"| |00000120| 69 64 22 3a 30 2c 22 73 74 61 74 65 22 3a 22 52 |id":0,"state":"R| |00000130| 55 4e 4e 49 4e 47 22 2c 22 77 6f 72 6b 65 72 5f |UNNING","worker_| |00000140| 69 64 22 3a 22 31 37 32 2e 31 37 2e 30 2e 31 39 |id":"172.17.0.19| |00000150| 3a 38 30 38 33 22 7d 5d 2c 22 74 79 70 65 22 3a |:8083"}],"type":| |00000160| 22 73 6f 75 72 63 65 22 7d |"source"} | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:31:55 DEBUG KafkaConnectApiImpl:246 - Got 200 response to GET request to /connectors/my-cluster-source->my-cluster-target.MirrorHeartbeatConnector/status: {name=my-cluster-source->my-cluster-target.MirrorHeartbeatConnector, connector={state=RUNNING, worker_id=172.17.0.19:8083}, tasks=[{id=0, state=RUNNING, worker_id=172.17.0.19:8083}], type=source} 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0xaa66a770, L:/172.17.0.6:58340 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0x81f41569, L:/172.17.0.6:58338 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 362B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 48 54 54 50 2f 31 2e 31 20 32 30 30 20 4f 4b 0d |HTTP/1.1 200 OK.| |00000010| 0a 44 61 74 65 3a 20 57 65 64 2c 20 31 35 20 41 |.Date: Wed, 15 A| |00000020| 70 72 20 32 30 32 30 20 30 30 3a 33 31 3a 35 35 |pr 2020 00:31:55| |00000030| 20 47 4d 54 0d 0a 43 6f 6e 74 65 6e 74 2d 54 79 | GMT..Content-Ty| |00000040| 70 65 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pe: application/| |00000050| 6a 73 6f 6e 0d 0a 43 6f 6e 74 65 6e 74 2d 4c 65 |json..Content-Le| |00000060| 6e 67 74 68 3a 20 32 32 30 0d 0a 53 65 72 76 65 |ngth: 220..Serve| |00000070| 72 3a 20 4a 65 74 74 79 28 39 2e 34 2e 32 30 2e |r: Jetty(9.4.20.| |00000080| 76 32 30 31 39 30 38 31 33 29 0d 0a 0d 0a 7b 22 |v20190813)....{"| |00000090| 6e 61 6d 65 22 3a 22 6d 79 2d 63 6c 75 73 74 65 |name":"my-cluste| |000000a0| 72 2d 73 6f 75 72 63 65 2d 3e 6d 79 2d 63 6c 75 |r-source->my-clu| |000000b0| 73 74 65 72 2d 74 61 72 67 65 74 2e 4d 69 72 72 |ster-target.Mirr| |000000c0| 6f 72 43 68 65 63 6b 70 6f 69 6e 74 43 6f 6e 6e |orCheckpointConn| |000000d0| 65 63 74 6f 72 22 2c 22 63 6f 6e 6e 65 63 74 6f |ector","connecto| |000000e0| 72 22 3a 7b 22 73 74 61 74 65 22 3a 22 52 55 4e |r":{"state":"RUN| |000000f0| 4e 49 4e 47 22 2c 22 77 6f 72 6b 65 72 5f 69 64 |NING","worker_id| |00000100| 22 3a 22 31 37 32 2e 31 37 2e 30 2e 31 39 3a 38 |":"172.17.0.19:8| |00000110| 30 38 33 22 7d 2c 22 74 61 73 6b 73 22 3a 5b 7b |083"},"tasks":[{| |00000120| 22 69 64 22 3a 30 2c 22 73 74 61 74 65 22 3a 22 |"id":0,"state":"| |00000130| 52 55 4e 4e 49 4e 47 22 2c 22 77 6f 72 6b 65 72 |RUNNING","worker| |00000140| 5f 69 64 22 3a 22 31 37 32 2e 31 37 2e 30 2e 31 |_id":"172.17.0.1| |00000150| 39 3a 38 30 38 33 22 7d 5d 2c 22 74 79 70 65 22 |9:8083"}],"type"| |00000160| 3a 22 73 6f 75 72 63 65 22 7d |:"source"} | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:31:55 DEBUG KafkaConnectApiImpl:246 - Got 200 response to GET request to /connectors/my-cluster-source->my-cluster-target.MirrorCheckpointConnector/status: {name=my-cluster-source->my-cluster-target.MirrorCheckpointConnector, connector={state=RUNNING, worker_id=172.17.0.19:8083}, tasks=[{id=0, state=RUNNING, worker_id=172.17.0.19:8083}], type=source} 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0x81f41569, L:/172.17.0.6:58338 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0x96c31d88, L:/172.17.0.6:58342 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 358B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 48 54 54 50 2f 31 2e 31 20 32 30 30 20 4f 4b 0d |HTTP/1.1 200 OK.| |00000010| 0a 44 61 74 65 3a 20 57 65 64 2c 20 31 35 20 41 |.Date: Wed, 15 A| |00000020| 70 72 20 32 30 32 30 20 30 30 3a 33 31 3a 35 35 |pr 2020 00:31:55| |00000030| 20 47 4d 54 0d 0a 43 6f 6e 74 65 6e 74 2d 54 79 | GMT..Content-Ty| |00000040| 70 65 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pe: application/| |00000050| 6a 73 6f 6e 0d 0a 43 6f 6e 74 65 6e 74 2d 4c 65 |json..Content-Le| |00000060| 6e 67 74 68 3a 20 32 31 36 0d 0a 53 65 72 76 65 |ngth: 216..Serve| |00000070| 72 3a 20 4a 65 74 74 79 28 39 2e 34 2e 32 30 2e |r: Jetty(9.4.20.| |00000080| 76 32 30 31 39 30 38 31 33 29 0d 0a 0d 0a 7b 22 |v20190813)....{"| |00000090| 6e 61 6d 65 22 3a 22 6d 79 2d 63 6c 75 73 74 65 |name":"my-cluste| |000000a0| 72 2d 73 6f 75 72 63 65 2d 3e 6d 79 2d 63 6c 75 |r-source->my-clu| |000000b0| 73 74 65 72 2d 74 61 72 67 65 74 2e 4d 69 72 72 |ster-target.Mirr| |000000c0| 6f 72 53 6f 75 72 63 65 43 6f 6e 6e 65 63 74 6f |orSourceConnecto| |000000d0| 72 22 2c 22 63 6f 6e 6e 65 63 74 6f 72 22 3a 7b |r","connector":{| |000000e0| 22 73 74 61 74 65 22 3a 22 52 55 4e 4e 49 4e 47 |"state":"RUNNING| |000000f0| 22 2c 22 77 6f 72 6b 65 72 5f 69 64 22 3a 22 31 |","worker_id":"1| |00000100| 37 32 2e 31 37 2e 30 2e 31 39 3a 38 30 38 33 22 |72.17.0.19:8083"| |00000110| 7d 2c 22 74 61 73 6b 73 22 3a 5b 7b 22 69 64 22 |},"tasks":[{"id"| |00000120| 3a 30 2c 22 73 74 61 74 65 22 3a 22 52 55 4e 4e |:0,"state":"RUNN| |00000130| 49 4e 47 22 2c 22 77 6f 72 6b 65 72 5f 69 64 22 |ING","worker_id"| |00000140| 3a 22 31 37 32 2e 31 37 2e 30 2e 31 39 3a 38 30 |:"172.17.0.19:80| |00000150| 38 33 22 7d 5d 2c 22 74 79 70 65 22 3a 22 73 6f |83"}],"type":"so| |00000160| 75 72 63 65 22 7d |urce"} | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:31:55 DEBUG Util:62 - Waiting for ZooKeeperAdmin connection to my-cluster-target-zookeeper-0.my-cluster-target-zookeeper-nodes.mirrormaker2-cluster-test.svc:2181 to get ready 2020-04-15 00:31:55 DEBUG KafkaConnectApiImpl:246 - Got 200 response to GET request to /connectors/my-cluster-source->my-cluster-target.MirrorSourceConnector/status: {name=my-cluster-source->my-cluster-target.MirrorSourceConnector, connector={state=RUNNING, worker_id=172.17.0.19:8083}, tasks=[{id=0, state=RUNNING, worker_id=172.17.0.19:8083}], type=source} 2020-04-15 00:31:55 DEBUG LoggingHandler:145 - [id: 0x96c31d88, L:/172.17.0.6:58342 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:31:55 DEBUG StatusDiff:37 - Ignoring Status diff {"op":"replace","path":"/conditions/0/lastTransitionTime","value":"2020-04-15T00:31:55.586Z"} 2020-04-15 00:31:55 DEBUG StatusDiff:42 - Status differs: {"op":"move","path":"/connectors/0","from":"/connectors/2"} 2020-04-15 00:31:55 DEBUG StatusDiff:43 - Current Status path /connectors/0 has value {"connector":{"state":"RUNNING","worker_id":"172.17.0.19:8083"},"name":"my-cluster-source->my-cluster-target.MirrorCheckpointConnector","tasks":[{"id":0,"state":"RUNNING","worker_id":"172.17.0.19:8083"}],"type":"source"} 2020-04-15 00:31:55 DEBUG StatusDiff:44 - Desired Status path /connectors/0 has value {"name":"my-cluster-source->my-cluster-target.MirrorHeartbeatConnector","connector":{"state":"RUNNING","worker_id":"172.17.0.19:8083"},"tasks":[{"id":0,"state":"RUNNING","worker_id":"172.17.0.19:8083"}],"type":"source"} 2020-04-15 00:31:55 DEBUG AbstractConnectOperator:588 - Reconciliation #0(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Completed status update 2020-04-15 00:31:55 INFO AbstractOperator:317 - Reconciliation #0(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): reconciled 2020-04-15 00:31:55 INFO OperatorWatcher:40 - Reconciliation #3(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2 my-cluster in namespace mirrormaker2-cluster-test was MODIFIED 2020-04-15 00:31:55 DEBUG AbstractOperator:237 - Reconciliation #0(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Lock lock::mirrormaker2-cluster-test::KafkaMirrorMaker2::my-cluster released 2020-04-15 00:31:55 DEBUG AbstractOperator:226 - Reconciliation #3(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Lock lock::mirrormaker2-cluster-test::KafkaMirrorMaker2::my-cluster acquired 2020-04-15 00:31:55 INFO AbstractOperator:173 - Reconciliation #3(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2 my-cluster should be created or updated 2020-04-15 00:31:55 DEBUG KafkaMirrorMaker2AssemblyOperator:144 - Reconciliation #3(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Updating Kafka MirrorMaker 2.0 cluster 2020-04-15 00:31:55 DEBUG ServiceAccountOperator:102 - ServiceAccount mirrormaker2-cluster-test/my-cluster-mirrormaker2 already exists, patching it 2020-04-15 00:31:56 DEBUG NetworkPolicyOperator:102 - NetworkPolicy mirrormaker2-cluster-test/my-cluster-mirrormaker2 already exists, patching it 2020-04-15 00:31:56 DEBUG NetworkPolicyOperator:168 - NetworkPolicy my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test has been patched 2020-04-15 00:31:56 DEBUG ServiceOperator:102 - Service mirrormaker2-cluster-test/my-cluster-mirrormaker2-api already exists, patching it 2020-04-15 00:31:56 DEBUG ServiceOperator:168 - Service my-cluster-mirrormaker2-api in namespace mirrormaker2-cluster-test has been patched 2020-04-15 00:31:56 DEBUG ConfigMapOperator:102 - ConfigMap mirrormaker2-cluster-test/my-cluster-mirrormaker2-config already exists, patching it 2020-04-15 00:31:56 DEBUG ConfigMapOperator:47 - ConfigMap my-cluster-mirrormaker2-config in namespace mirrormaker2-cluster-test has not been patched because resources are equal 2020-04-15 00:31:56 DEBUG PodDisruptionBudgetOperator:102 - PodDisruptionBudget mirrormaker2-cluster-test/my-cluster-mirrormaker2 already exists, patching it 2020-04-15 00:31:56 DEBUG PodDisruptionBudgetOperator:149 - PodDisruptionBudget my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test has been deleted 2020-04-15 00:31:56 DEBUG PodDisruptionBudgetOperator:195 - PodDisruptionBudget my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test has been created 2020-04-15 00:31:56 DEBUG SslHandler:1743 - [id: 0x09c2d805, L:/172.17.0.6:44918 - R:my-cluster-source-zookeeper-0.my-cluster-source-zookeeper-nodes.mirrormaker2-cluster-test.svc/172.17.0.9:2181] HANDSHAKEN: TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA 2020-04-15 00:31:56 DEBUG SslHandler:1743 - [id: 0xaf643d42, L:/172.17.0.6:50890 - R:my-cluster-target-zookeeper-0.my-cluster-target-zookeeper-nodes.mirrormaker2-cluster-test.svc/172.17.0.15:2181] HANDSHAKEN: TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA 2020-04-15 00:31:56 DEBUG DeploymentOperator:102 - Deployment mirrormaker2-cluster-test/my-cluster-mirrormaker2 already exists, patching it 2020-04-15 00:31:56 DEBUG ZookeeperScaler:139 - Received event WatchedEvent state:SyncConnected type:None path:null from ZooKeeperAdmin client connected to my-cluster-target-zookeeper-0.my-cluster-target-zookeeper-nodes.mirrormaker2-cluster-test.svc:2181 2020-04-15 00:31:56 DEBUG ZookeeperScaler:139 - Received event WatchedEvent state:SyncConnected type:None path:null from ZooKeeperAdmin client connected to my-cluster-source-zookeeper-0.my-cluster-source-zookeeper-nodes.mirrormaker2-cluster-test.svc:2181 2020-04-15 00:31:56 DEBUG DeploymentOperator:168 - Deployment my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test has been patched 2020-04-15 00:31:56 DEBUG Util:62 - Waiting for Deployment resource my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test to get ready 2020-04-15 00:31:56 DEBUG Util:84 - Deployment resource my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test is ready 2020-04-15 00:31:56 DEBUG Util:62 - Waiting for Deployment resource my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test to get ready 2020-04-15 00:31:56 DEBUG Util:84 - Deployment resource my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test is ready 2020-04-15 00:31:56 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [51179: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN A) 2020-04-15 00:31:56 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [28692: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) 2020-04-15 00:31:56 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [28692: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 28692, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:31:56 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [51179: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 51179, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN A) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:31:56 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [5062: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN CNAME) 2020-04-15 00:31:56 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [5062: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 5062, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN CNAME) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:31:56 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [2459: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN A) 2020-04-15 00:31:56 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [26927: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN AAAA) 2020-04-15 00:31:56 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [26927: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 26927, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN AAAA) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:31:56 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [2459: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 2459, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN A) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:31:56 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [48586: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN CNAME) 2020-04-15 00:31:56 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [48586: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 48586, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN CNAME) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:31:56 DEBUG LoggingHandler:145 - [id: 0xb29bf9cc, L:/172.17.0.6:58364 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] WRITE: 124B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 63 6f 6e 6e 65 63 74 6f 72 73 20 |GET /connectors | |00000010| 48 54 54 50 2f 31 2e 31 0d 0a 41 63 63 65 70 74 |HTTP/1.1..Accept| |00000020| 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f 6a 73 |: application/js| |00000030| 6f 6e 0d 0a 68 6f 73 74 3a 20 6d 79 2d 63 6c 75 |on..host: my-clu| |00000040| 73 74 65 72 2d 6d 69 72 72 6f 72 6d 61 6b 65 72 |ster-mirrormaker| |00000050| 32 2d 61 70 69 2e 6d 69 72 72 6f 72 6d 61 6b 65 |2-api.mirrormake| |00000060| 72 32 2d 63 6c 75 73 74 65 72 2d 74 65 73 74 2e |r2-cluster-test.| |00000070| 73 76 63 3a 38 30 38 33 0d 0a 0d 0a |svc:8083.... | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:31:56 DEBUG LoggingHandler:145 - [id: 0xb29bf9cc, L:/172.17.0.6:58364 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:31:56 DEBUG LoggingHandler:145 - [id: 0xb29bf9cc, L:/172.17.0.6:58364 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:31:56 DEBUG Util:84 - ZooKeeperAdmin connection to my-cluster-target-zookeeper-0.my-cluster-target-zookeeper-nodes.mirrormaker2-cluster-test.svc:2181 is ready 2020-04-15 00:31:56 DEBUG LoggingHandler:145 - [id: 0xb29bf9cc, L:/172.17.0.6:58364 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 333B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 48 54 54 50 2f 31 2e 31 20 32 30 30 20 4f 4b 0d |HTTP/1.1 200 OK.| |00000010| 0a 44 61 74 65 3a 20 57 65 64 2c 20 31 35 20 41 |.Date: Wed, 15 A| |00000020| 70 72 20 32 30 32 30 20 30 30 3a 33 31 3a 35 36 |pr 2020 00:31:56| |00000030| 20 47 4d 54 0d 0a 43 6f 6e 74 65 6e 74 2d 54 79 | GMT..Content-Ty| |00000040| 70 65 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pe: application/| |00000050| 6a 73 6f 6e 0d 0a 43 6f 6e 74 65 6e 74 2d 4c 65 |json..Content-Le| |00000060| 6e 67 74 68 3a 20 31 39 31 0d 0a 53 65 72 76 65 |ngth: 191..Serve| |00000070| 72 3a 20 4a 65 74 74 79 28 39 2e 34 2e 32 30 2e |r: Jetty(9.4.20.| |00000080| 76 32 30 31 39 30 38 31 33 29 0d 0a 0d 0a 5b 22 |v20190813)....["| |00000090| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |000000a0| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |000000b0| 72 67 65 74 2e 4d 69 72 72 6f 72 48 65 61 72 74 |rget.MirrorHeart| |000000c0| 62 65 61 74 43 6f 6e 6e 65 63 74 6f 72 22 2c 22 |beatConnector","| |000000d0| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |000000e0| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |000000f0| 72 67 65 74 2e 4d 69 72 72 6f 72 53 6f 75 72 63 |rget.MirrorSourc| |00000100| 65 43 6f 6e 6e 65 63 74 6f 72 22 2c 22 6d 79 2d |eConnector","my-| |00000110| 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 65 2d 3e |cluster-source->| |00000120| 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 72 67 65 |my-cluster-targe| |00000130| 74 2e 4d 69 72 72 6f 72 43 68 65 63 6b 70 6f 69 |t.MirrorCheckpoi| |00000140| 6e 74 43 6f 6e 6e 65 63 74 6f 72 22 5d |ntConnector"] | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:31:56 DEBUG KafkaMirrorMaker2AssemblyOperator:206 - Reconciliation #3(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2} cluster: delete MirrorMaker 2.0 connectors: [] 2020-04-15 00:31:56 DEBUG KafkaMirrorMaker2AssemblyOperator:253 - Reconciliation #3(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2} cluster: creating/updating connector my-cluster-source->my-cluster-target.MirrorCheckpointConnector config: {"checkpoints.topic.replication.factor":1,"target.cluster.alias":"my-cluster-target","target.cluster.bootstrap.servers":"my-cluster-target-kafka-bootstrap:9093","target.cluster.ssl.truststore.type":"PKCS12","target.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-target.truststore.p12","target.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","target.cluster.sasl.mechanism":"SCRAM-SHA-512","target.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-target\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}\";","target.cluster.security.protocol":"SASL_SSL","target.cluster.status.storage.replication.factor":1,"target.cluster.offset.storage.replication.factor":1,"target.cluster.config.storage.replication.factor":1,"source.cluster.alias":"my-cluster-source","source.cluster.bootstrap.servers":"my-cluster-source-kafka-bootstrap:9093","source.cluster.ssl.truststore.type":"PKCS12","source.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-source.truststore.p12","source.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","source.cluster.sasl.mechanism":"SCRAM-SHA-512","source.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-source\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}\";","source.cluster.security.protocol":"SASL_SSL","topics":".*","topics.blacklist":"availability.*","groups":".*","connector.class":"org.apache.kafka.connect.mirror.MirrorCheckpointConnector"} 2020-04-15 00:31:56 DEBUG KafkaConnectApiImpl:235 - Making GET request to /connectors/my-cluster-source->my-cluster-target.MirrorCheckpointConnector/config 2020-04-15 00:31:56 DEBUG KafkaMirrorMaker2AssemblyOperator:253 - Reconciliation #3(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2} cluster: creating/updating connector my-cluster-source->my-cluster-target.MirrorSourceConnector config: {"offset-syncs.topic.replication.factor":1,"replication.factor":1,"sync.topic.acls.enabled":"false","target.cluster.alias":"my-cluster-target","target.cluster.bootstrap.servers":"my-cluster-target-kafka-bootstrap:9093","target.cluster.ssl.truststore.type":"PKCS12","target.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-target.truststore.p12","target.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","target.cluster.sasl.mechanism":"SCRAM-SHA-512","target.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-target\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}\";","target.cluster.security.protocol":"SASL_SSL","target.cluster.status.storage.replication.factor":1,"target.cluster.offset.storage.replication.factor":1,"target.cluster.config.storage.replication.factor":1,"source.cluster.alias":"my-cluster-source","source.cluster.bootstrap.servers":"my-cluster-source-kafka-bootstrap:9093","source.cluster.ssl.truststore.type":"PKCS12","source.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-source.truststore.p12","source.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","source.cluster.sasl.mechanism":"SCRAM-SHA-512","source.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-source\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}\";","source.cluster.security.protocol":"SASL_SSL","topics":".*","topics.blacklist":"availability.*","groups":".*","connector.class":"org.apache.kafka.connect.mirror.MirrorSourceConnector"} 2020-04-15 00:31:56 DEBUG KafkaConnectApiImpl:235 - Making GET request to /connectors/my-cluster-source->my-cluster-target.MirrorSourceConnector/config 2020-04-15 00:31:56 DEBUG KafkaMirrorMaker2AssemblyOperator:253 - Reconciliation #3(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2} cluster: creating/updating connector my-cluster-source->my-cluster-target.MirrorHeartbeatConnector config: {"heartbeats.topic.replication.factor":1,"target.cluster.alias":"my-cluster-target","target.cluster.bootstrap.servers":"my-cluster-target-kafka-bootstrap:9093","target.cluster.ssl.truststore.type":"PKCS12","target.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-target.truststore.p12","target.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","target.cluster.sasl.mechanism":"SCRAM-SHA-512","target.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-target\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}\";","target.cluster.security.protocol":"SASL_SSL","target.cluster.status.storage.replication.factor":1,"target.cluster.offset.storage.replication.factor":1,"target.cluster.config.storage.replication.factor":1,"source.cluster.alias":"my-cluster-source","source.cluster.bootstrap.servers":"my-cluster-source-kafka-bootstrap:9093","source.cluster.ssl.truststore.type":"PKCS12","source.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-source.truststore.p12","source.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","source.cluster.sasl.mechanism":"SCRAM-SHA-512","source.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-source\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}\";","source.cluster.security.protocol":"SASL_SSL","topics":".*","topics.blacklist":"availability.*","groups":".*","connector.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatConnector"} 2020-04-15 00:31:56 DEBUG KafkaConnectApiImpl:235 - Making GET request to /connectors/my-cluster-source->my-cluster-target.MirrorHeartbeatConnector/config 2020-04-15 00:31:56 DEBUG LoggingHandler:145 - [id: 0xb29bf9cc, L:/172.17.0.6:58364 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:31:56 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [10538: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN A) 2020-04-15 00:31:56 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [293: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) 2020-04-15 00:31:56 DEBUG ZookeeperScaler:198 - Current Zookeeper configuration is {server.1=127.0.0.1:28880:38880:participant;127.0.0.1:21810} 2020-04-15 00:31:56 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [293: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 293, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:31:56 DEBUG ZookeeperScaler:181 - The Zookeeper server configuration is already up to date 2020-04-15 00:32:25 DEBUG LoggingHandler:145 - [id: 0xaa66a770, L:/172.17.0.6:58340 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:32:25 DEBUG LoggingHandler:145 - [id: 0xaa66a770, L:/172.17.0.6:58340 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:32:25 DEBUG LoggingHandler:145 - [id: 0xaa66a770, L:/172.17.0.6:58340 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:32:25 DEBUG LoggingHandler:145 - [id: 0x81f41569, L:/172.17.0.6:58338 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:32:25 DEBUG LoggingHandler:145 - [id: 0x81f41569, L:/172.17.0.6:58338 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:32:25 DEBUG LoggingHandler:145 - [id: 0x81f41569, L:/172.17.0.6:58338 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:32:25 DEBUG LoggingHandler:145 - [id: 0x96c31d88, L:/172.17.0.6:58342 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:32:25 DEBUG LoggingHandler:145 - [id: 0x96c31d88, L:/172.17.0.6:58342 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:32:25 DEBUG LoggingHandler:145 - [id: 0x96c31d88, L:/172.17.0.6:58342 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:32:25 DEBUG PoolThreadCache:250 - Freed 18 thread-local buffer(s) from thread: epollEventLoopGroup-4-1 2020-04-15 00:32:26 DEBUG PoolThreadCache:250 - Freed 18 thread-local buffer(s) from thread: epollEventLoopGroup-5-1 2020-04-15 00:32:55 DEBUG PoolThreadCache:250 - Freed 18 thread-local buffer(s) from thread: epollEventLoopGroup-7-1 2020-04-15 00:33:25 DEBUG PoolThreadCache:250 - Freed 18 thread-local buffer(s) from thread: epollEventLoopGroup-9-1 2020-04-15 00:33:55 DEBUG PoolThreadCache:250 - Freed 18 thread-local buffer(s) from thread: epollEventLoopGroup-11-1 2020-04-15 00:33:55 DEBUG PoolThreadCache:250 - Freed 18 thread-local buffer(s) from thread: epollEventLoopGroup-10-1 2020-04-15 00:34:55 INFO AbstractOperator:173 - Reconciliation #65(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2 my-cluster should be created or updated 2020-04-15 00:34:55 DEBUG KafkaMirrorMaker2AssemblyOperator:144 - Reconciliation #65(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Updating Kafka MirrorMaker 2.0 cluster 2020-04-15 00:34:55 DEBUG ServiceAccountOperator:102 - ServiceAccount mirrormaker2-cluster-test/my-cluster-mirrormaker2 already exists, patching it 2020-04-15 00:34:55 DEBUG NetworkPolicyOperator:102 - NetworkPolicy mirrormaker2-cluster-test/my-cluster-mirrormaker2 already exists, patching it 2020-04-15 00:34:55 DEBUG NetworkPolicyOperator:168 - NetworkPolicy my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test has been patched 2020-04-15 00:34:55 DEBUG ServiceOperator:102 - Service mirrormaker2-cluster-test/my-cluster-mirrormaker2-api already exists, patching it 2020-04-15 00:34:55 DEBUG ServiceOperator:168 - Service my-cluster-mirrormaker2-api in namespace mirrormaker2-cluster-test has been patched 2020-04-15 00:34:55 DEBUG ConfigMapOperator:102 - ConfigMap mirrormaker2-cluster-test/my-cluster-mirrormaker2-config already exists, patching it 2020-04-15 00:34:55 DEBUG ConfigMapOperator:47 - ConfigMap my-cluster-mirrormaker2-config in namespace mirrormaker2-cluster-test has not been patched because resources are equal 2020-04-15 00:34:55 DEBUG PodDisruptionBudgetOperator:102 - PodDisruptionBudget mirrormaker2-cluster-test/my-cluster-mirrormaker2 already exists, patching it 2020-04-15 00:34:55 DEBUG PodDisruptionBudgetOperator:149 - PodDisruptionBudget my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test has been deleted 2020-04-15 00:34:55 DEBUG PodDisruptionBudgetOperator:195 - PodDisruptionBudget my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test has been created 2020-04-15 00:34:55 DEBUG DeploymentOperator:102 - Deployment mirrormaker2-cluster-test/my-cluster-mirrormaker2 already exists, patching it 2020-04-15 00:34:55 DEBUG DeploymentOperator:168 - Deployment my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test has been patched 2020-04-15 00:34:55 DEBUG Util:62 - Waiting for Deployment resource my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test to get ready 2020-04-15 00:34:55 DEBUG Util:84 - Deployment resource my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test is ready 2020-04-15 00:34:55 DEBUG Util:62 - Waiting for Deployment resource my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test to get ready 2020-04-15 00:34:55 DEBUG Util:84 - Deployment resource my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test is ready 2020-04-15 00:34:55 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [25606: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN A) 2020-04-15 00:34:55 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [61708: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) 2020-04-15 00:34:55 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [61708: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 61708, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:34:55 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [25606: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 25606, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN A) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:34:55 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [41354: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN CNAME) 2020-04-15 00:34:55 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [41354: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 41354, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN CNAME) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:34:55 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [6848: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN A) 2020-04-15 00:34:55 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [60872: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN AAAA) 2020-04-15 00:34:55 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [60872: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 60872, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN AAAA) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:34:55 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [6848: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 6848, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN A) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:34:55 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [11408: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN CNAME) 2020-04-15 00:34:55 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [11408: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 11408, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN CNAME) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0xddfb2eae, L:/172.17.0.6:60590 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] WRITE: 124B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 63 6f 6e 6e 65 63 74 6f 72 73 20 |GET /connectors | |00000010| 48 54 54 50 2f 31 2e 31 0d 0a 41 63 63 65 70 74 |HTTP/1.1..Accept| |00000020| 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f 6a 73 |: application/js| |00000030| 6f 6e 0d 0a 68 6f 73 74 3a 20 6d 79 2d 63 6c 75 |on..host: my-clu| |00000040| 73 74 65 72 2d 6d 69 72 72 6f 72 6d 61 6b 65 72 |ster-mirrormaker| |00000050| 32 2d 61 70 69 2e 6d 69 72 72 6f 72 6d 61 6b 65 |2-api.mirrormake| |00000060| 72 32 2d 63 6c 75 73 74 65 72 2d 74 65 73 74 2e |r2-cluster-test.| |00000070| 73 76 63 3a 38 30 38 33 0d 0a 0d 0a |svc:8083.... | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0xddfb2eae, L:/172.17.0.6:60590 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0xddfb2eae, L:/172.17.0.6:60590 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0xddfb2eae, L:/172.17.0.6:60590 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 333B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 48 54 54 50 2f 31 2e 31 20 32 30 30 20 4f 4b 0d |HTTP/1.1 200 OK.| |00000010| 0a 44 61 74 65 3a 20 57 65 64 2c 20 31 35 20 41 |.Date: Wed, 15 A| |00000020| 70 72 20 32 30 32 30 20 30 30 3a 33 34 3a 35 35 |pr 2020 00:34:55| |00000030| 20 47 4d 54 0d 0a 43 6f 6e 74 65 6e 74 2d 54 79 | GMT..Content-Ty| |00000040| 70 65 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pe: application/| |00000050| 6a 73 6f 6e 0d 0a 43 6f 6e 74 65 6e 74 2d 4c 65 |json..Content-Le| |00000060| 6e 67 74 68 3a 20 31 39 31 0d 0a 53 65 72 76 65 |ngth: 191..Serve| |00000070| 72 3a 20 4a 65 74 74 79 28 39 2e 34 2e 32 30 2e |r: Jetty(9.4.20.| |00000080| 76 32 30 31 39 30 38 31 33 29 0d 0a 0d 0a 5b 22 |v20190813)....["| |00000090| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |000000a0| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |000000b0| 72 67 65 74 2e 4d 69 72 72 6f 72 48 65 61 72 74 |rget.MirrorHeart| |000000c0| 62 65 61 74 43 6f 6e 6e 65 63 74 6f 72 22 2c 22 |beatConnector","| |000000d0| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |000000e0| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |000000f0| 72 67 65 74 2e 4d 69 72 72 6f 72 53 6f 75 72 63 |rget.MirrorSourc| |00000100| 65 43 6f 6e 6e 65 63 74 6f 72 22 2c 22 6d 79 2d |eConnector","my-| |00000110| 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 65 2d 3e |cluster-source->| |00000120| 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 72 67 65 |my-cluster-targe| |00000130| 74 2e 4d 69 72 72 6f 72 43 68 65 63 6b 70 6f 69 |t.MirrorCheckpoi| |00000140| 6e 74 43 6f 6e 6e 65 63 74 6f 72 22 5d |ntConnector"] | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:34:55 DEBUG KafkaMirrorMaker2AssemblyOperator:206 - Reconciliation #65(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2} cluster: delete MirrorMaker 2.0 connectors: [] 2020-04-15 00:34:55 DEBUG KafkaMirrorMaker2AssemblyOperator:253 - Reconciliation #65(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2} cluster: creating/updating connector my-cluster-source->my-cluster-target.MirrorCheckpointConnector config: {"checkpoints.topic.replication.factor":1,"target.cluster.alias":"my-cluster-target","target.cluster.bootstrap.servers":"my-cluster-target-kafka-bootstrap:9093","target.cluster.ssl.truststore.type":"PKCS12","target.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-target.truststore.p12","target.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","target.cluster.sasl.mechanism":"SCRAM-SHA-512","target.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-target\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}\";","target.cluster.security.protocol":"SASL_SSL","target.cluster.status.storage.replication.factor":1,"target.cluster.offset.storage.replication.factor":1,"target.cluster.config.storage.replication.factor":1,"source.cluster.alias":"my-cluster-source","source.cluster.bootstrap.servers":"my-cluster-source-kafka-bootstrap:9093","source.cluster.ssl.truststore.type":"PKCS12","source.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-source.truststore.p12","source.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","source.cluster.sasl.mechanism":"SCRAM-SHA-512","source.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-source\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}\";","source.cluster.security.protocol":"SASL_SSL","topics":".*","topics.blacklist":"availability.*","groups":".*","connector.class":"org.apache.kafka.connect.mirror.MirrorCheckpointConnector"} 2020-04-15 00:34:55 DEBUG KafkaConnectApiImpl:235 - Making GET request to /connectors/my-cluster-source->my-cluster-target.MirrorCheckpointConnector/config 2020-04-15 00:34:55 DEBUG KafkaMirrorMaker2AssemblyOperator:253 - Reconciliation #65(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2} cluster: creating/updating connector my-cluster-source->my-cluster-target.MirrorSourceConnector config: {"offset-syncs.topic.replication.factor":1,"replication.factor":1,"sync.topic.acls.enabled":"false","target.cluster.alias":"my-cluster-target","target.cluster.bootstrap.servers":"my-cluster-target-kafka-bootstrap:9093","target.cluster.ssl.truststore.type":"PKCS12","target.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-target.truststore.p12","target.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","target.cluster.sasl.mechanism":"SCRAM-SHA-512","target.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-target\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}\";","target.cluster.security.protocol":"SASL_SSL","target.cluster.status.storage.replication.factor":1,"target.cluster.offset.storage.replication.factor":1,"target.cluster.config.storage.replication.factor":1,"source.cluster.alias":"my-cluster-source","source.cluster.bootstrap.servers":"my-cluster-source-kafka-bootstrap:9093","source.cluster.ssl.truststore.type":"PKCS12","source.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-source.truststore.p12","source.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","source.cluster.sasl.mechanism":"SCRAM-SHA-512","source.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-source\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}\";","source.cluster.security.protocol":"SASL_SSL","topics":".*","topics.blacklist":"availability.*","groups":".*","connector.class":"org.apache.kafka.connect.mirror.MirrorSourceConnector"} 2020-04-15 00:34:55 DEBUG KafkaConnectApiImpl:235 - Making GET request to /connectors/my-cluster-source->my-cluster-target.MirrorSourceConnector/config 2020-04-15 00:34:55 DEBUG KafkaMirrorMaker2AssemblyOperator:253 - Reconciliation #65(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2} cluster: creating/updating connector my-cluster-source->my-cluster-target.MirrorHeartbeatConnector config: {"heartbeats.topic.replication.factor":1,"target.cluster.alias":"my-cluster-target","target.cluster.bootstrap.servers":"my-cluster-target-kafka-bootstrap:9093","target.cluster.ssl.truststore.type":"PKCS12","target.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-target.truststore.p12","target.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","target.cluster.sasl.mechanism":"SCRAM-SHA-512","target.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-target\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}\";","target.cluster.security.protocol":"SASL_SSL","target.cluster.status.storage.replication.factor":1,"target.cluster.offset.storage.replication.factor":1,"target.cluster.config.storage.replication.factor":1,"source.cluster.alias":"my-cluster-source","source.cluster.bootstrap.servers":"my-cluster-source-kafka-bootstrap:9093","source.cluster.ssl.truststore.type":"PKCS12","source.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-source.truststore.p12","source.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","source.cluster.sasl.mechanism":"SCRAM-SHA-512","source.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-source\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}\";","source.cluster.security.protocol":"SASL_SSL","topics":".*","topics.blacklist":"availability.*","groups":".*","connector.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatConnector"} 2020-04-15 00:34:55 DEBUG KafkaConnectApiImpl:235 - Making GET request to /connectors/my-cluster-source->my-cluster-target.MirrorHeartbeatConnector/config 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0xddfb2eae, L:/172.17.0.6:60590 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:34:55 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [7785: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN A) 2020-04-15 00:34:55 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [31496: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) 2020-04-15 00:34:55 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [31496: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 31496, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:34:55 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [7785: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 7785, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN A) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:34:55 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [8830: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN CNAME) 2020-04-15 00:34:55 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [8830: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 8830, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN CNAME) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:34:55 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [28658: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN A) 2020-04-15 00:34:55 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [3424: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN AAAA) 2020-04-15 00:34:55 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [3424: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 3424, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN AAAA) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:34:55 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [28658: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 28658, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN A) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:34:55 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [15340: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN CNAME) 2020-04-15 00:34:55 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [15340: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 15340, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN CNAME) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0x87553d40, L:/172.17.0.6:60592 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] WRITE: 194B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 63 6f 6e 6e 65 63 74 6f 72 73 2f |GET /connectors/| |00000010| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |00000020| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |00000030| 72 67 65 74 2e 4d 69 72 72 6f 72 43 68 65 63 6b |rget.MirrorCheck| |00000040| 70 6f 69 6e 74 43 6f 6e 6e 65 63 74 6f 72 2f 63 |pointConnector/c| |00000050| 6f 6e 66 69 67 20 48 54 54 50 2f 31 2e 31 0d 0a |onfig HTTP/1.1..| |00000060| 41 63 63 65 70 74 3a 20 61 70 70 6c 69 63 61 74 |Accept: applicat| |00000070| 69 6f 6e 2f 6a 73 6f 6e 0d 0a 68 6f 73 74 3a 20 |ion/json..host: | |00000080| 6d 79 2d 63 6c 75 73 74 65 72 2d 6d 69 72 72 6f |my-cluster-mirro| |00000090| 72 6d 61 6b 65 72 32 2d 61 70 69 2e 6d 69 72 72 |rmaker2-api.mirr| |000000a0| 6f 72 6d 61 6b 65 72 32 2d 63 6c 75 73 74 65 72 |ormaker2-cluster| |000000b0| 2d 74 65 73 74 2e 73 76 63 3a 38 30 38 33 0d 0a |-test.svc:8083..| |000000c0| 0d 0a |.. | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0x87553d40, L:/172.17.0.6:60592 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0x87553d40, L:/172.17.0.6:60592 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0x35db5a32, L:/172.17.0.6:60594 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] WRITE: 190B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 63 6f 6e 6e 65 63 74 6f 72 73 2f |GET /connectors/| |00000010| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |00000020| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |00000030| 72 67 65 74 2e 4d 69 72 72 6f 72 53 6f 75 72 63 |rget.MirrorSourc| |00000040| 65 43 6f 6e 6e 65 63 74 6f 72 2f 63 6f 6e 66 69 |eConnector/confi| |00000050| 67 20 48 54 54 50 2f 31 2e 31 0d 0a 41 63 63 65 |g HTTP/1.1..Acce| |00000060| 70 74 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pt: application/| |00000070| 6a 73 6f 6e 0d 0a 68 6f 73 74 3a 20 6d 79 2d 63 |json..host: my-c| |00000080| 6c 75 73 74 65 72 2d 6d 69 72 72 6f 72 6d 61 6b |luster-mirrormak| |00000090| 65 72 32 2d 61 70 69 2e 6d 69 72 72 6f 72 6d 61 |er2-api.mirrorma| |000000a0| 6b 65 72 32 2d 63 6c 75 73 74 65 72 2d 74 65 73 |ker2-cluster-tes| |000000b0| 74 2e 73 76 63 3a 38 30 38 33 0d 0a 0d 0a |t.svc:8083.... | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0x35db5a32, L:/172.17.0.6:60594 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0x35db5a32, L:/172.17.0.6:60594 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0x3e19d6b5, L:/172.17.0.6:60596 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] WRITE: 193B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 63 6f 6e 6e 65 63 74 6f 72 73 2f |GET /connectors/| |00000010| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |00000020| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |00000030| 72 67 65 74 2e 4d 69 72 72 6f 72 48 65 61 72 74 |rget.MirrorHeart| |00000040| 62 65 61 74 43 6f 6e 6e 65 63 74 6f 72 2f 63 6f |beatConnector/co| |00000050| 6e 66 69 67 20 48 54 54 50 2f 31 2e 31 0d 0a 41 |nfig HTTP/1.1..A| |00000060| 63 63 65 70 74 3a 20 61 70 70 6c 69 63 61 74 69 |ccept: applicati| |00000070| 6f 6e 2f 6a 73 6f 6e 0d 0a 68 6f 73 74 3a 20 6d |on/json..host: m| |00000080| 79 2d 63 6c 75 73 74 65 72 2d 6d 69 72 72 6f 72 |y-cluster-mirror| |00000090| 6d 61 6b 65 72 32 2d 61 70 69 2e 6d 69 72 72 6f |maker2-api.mirro| |000000a0| 72 6d 61 6b 65 72 32 2d 63 6c 75 73 74 65 72 2d |rmaker2-cluster-| |000000b0| 74 65 73 74 2e 73 76 63 3a 38 30 38 33 0d 0a 0d |test.svc:8083...| |000000c0| 0a |. | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0x3e19d6b5, L:/172.17.0.6:60596 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0x3e19d6b5, L:/172.17.0.6:60596 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0x35db5a32, L:/172.17.0.6:60594 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 1024B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 48 54 54 50 2f 31 2e 31 20 32 30 30 20 4f 4b 0d |HTTP/1.1 200 OK.| |00000010| 0a 44 61 74 65 3a 20 57 65 64 2c 20 31 35 20 41 |.Date: Wed, 15 A| |00000020| 70 72 20 32 30 32 30 20 30 30 3a 33 34 3a 35 35 |pr 2020 00:34:55| |00000030| 20 47 4d 54 0d 0a 43 6f 6e 74 65 6e 74 2d 54 79 | GMT..Content-Ty| |00000040| 70 65 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pe: application/| |00000050| 6a 73 6f 6e 0d 0a 43 6f 6e 74 65 6e 74 2d 4c 65 |json..Content-Le| |00000060| 6e 67 74 68 3a 20 31 38 38 39 0d 0a 53 65 72 76 |ngth: 1889..Serv| |00000070| 65 72 3a 20 4a 65 74 74 79 28 39 2e 34 2e 32 30 |er: Jetty(9.4.20| |00000080| 2e 76 32 30 31 39 30 38 31 33 29 0d 0a 0d 0a 7b |.v20190813)....{| |00000090| 22 63 6f 6e 6e 65 63 74 6f 72 2e 63 6c 61 73 73 |"connector.class| |000000a0| 22 3a 22 6f 72 67 2e 61 70 61 63 68 65 2e 6b 61 |":"org.apache.ka| |000000b0| 66 6b 61 2e 63 6f 6e 6e 65 63 74 2e 6d 69 72 72 |fka.connect.mirr| |000000c0| 6f 72 2e 4d 69 72 72 6f 72 53 6f 75 72 63 65 43 |or.MirrorSourceC| |000000d0| 6f 6e 6e 65 63 74 6f 72 22 2c 22 72 65 70 6c 69 |onnector","repli| |000000e0| 63 61 74 69 6f 6e 2e 66 61 63 74 6f 72 22 3a 22 |cation.factor":"| |000000f0| 31 22 2c 22 73 6f 75 72 63 65 2e 63 6c 75 73 74 |1","source.clust| |00000100| 65 72 2e 73 73 6c 2e 74 72 75 73 74 73 74 6f 72 |er.ssl.truststor| |00000110| 65 2e 6c 6f 63 61 74 69 6f 6e 22 3a 22 2f 74 6d |e.location":"/tm| |00000120| 70 2f 6b 61 66 6b 61 2f 63 6c 75 73 74 65 72 73 |p/kafka/clusters| |00000130| 2f 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 |/my-cluster-sour| |00000140| 63 65 2e 74 72 75 73 74 73 74 6f 72 65 2e 70 31 |ce.truststore.p1| |00000150| 32 22 2c 22 74 61 72 67 65 74 2e 63 6c 75 73 74 |2","target.clust| |00000160| 65 72 2e 73 61 73 6c 2e 6a 61 61 73 2e 63 6f 6e |er.sasl.jaas.con| |00000170| 66 69 67 22 3a 22 6f 72 67 2e 61 70 61 63 68 65 |fig":"org.apache| |00000180| 2e 6b 61 66 6b 61 2e 63 6f 6d 6d 6f 6e 2e 73 65 |.kafka.common.se| |00000190| 63 75 72 69 74 79 2e 73 63 72 61 6d 2e 53 63 72 |curity.scram.Scr| |000001a0| 61 6d 4c 6f 67 69 6e 4d 6f 64 75 6c 65 20 72 65 |amLoginModule re| |000001b0| 71 75 69 72 65 64 20 75 73 65 72 6e 61 6d 65 3d |quired username=| |000001c0| 5c 22 6d 79 2d 75 73 65 72 2d 74 61 72 67 65 74 |\"my-user-target| |000001d0| 5c 22 20 70 61 73 73 77 6f 72 64 3d 5c 22 24 7b |\" password=\"${| |000001e0| 66 69 6c 65 3a 2f 74 6d 70 2f 73 74 72 69 6d 7a |file:/tmp/strimz| |000001f0| 69 2d 6d 69 72 72 6f 72 6d 61 6b 65 72 32 2d 63 |i-mirrormaker2-c| |00000200| 6f 6e 6e 65 63 74 6f 72 2e 70 72 6f 70 65 72 74 |onnector.propert| |00000210| 69 65 73 3a 6d 79 2d 63 6c 75 73 74 65 72 2d 74 |ies:my-cluster-t| |00000220| 61 72 67 65 74 2e 73 61 73 6c 2e 70 61 73 73 77 |arget.sasl.passw| |00000230| 6f 72 64 7d 5c 22 3b 22 2c 22 74 6f 70 69 63 73 |ord}\";","topics| |00000240| 2e 62 6c 61 63 6b 6c 69 73 74 22 3a 22 61 76 61 |.blacklist":"ava| |00000250| 69 6c 61 62 69 6c 69 74 79 2e 2a 22 2c 22 73 79 |ilability.*","sy| |00000260| 6e 63 2e 74 6f 70 69 63 2e 61 63 6c 73 2e 65 6e |nc.topic.acls.en| |00000270| 61 62 6c 65 64 22 3a 22 66 61 6c 73 65 22 2c 22 |abled":"false","| |00000280| 73 6f 75 72 63 65 2e 63 6c 75 73 74 65 72 2e 73 |source.cluster.s| |00000290| 73 6c 2e 74 72 75 73 74 73 74 6f 72 65 2e 74 79 |sl.truststore.ty| |000002a0| 70 65 22 3a 22 50 4b 43 53 31 32 22 2c 22 73 6f |pe":"PKCS12","so| |000002b0| 75 72 63 65 2e 63 6c 75 73 74 65 72 2e 61 6c 69 |urce.cluster.ali| |000002c0| 61 73 22 3a 22 6d 79 2d 63 6c 75 73 74 65 72 2d |as":"my-cluster-| |000002d0| 73 6f 75 72 63 65 22 2c 22 74 61 72 67 65 74 2e |source","target.| |000002e0| 63 6c 75 73 74 65 72 2e 73 73 6c 2e 74 72 75 73 |cluster.ssl.trus| |000002f0| 74 73 74 6f 72 65 2e 6c 6f 63 61 74 69 6f 6e 22 |tstore.location"| |00000300| 3a 22 2f 74 6d 70 2f 6b 61 66 6b 61 2f 63 6c 75 |:"/tmp/kafka/clu| |00000310| 73 74 65 72 73 2f 6d 79 2d 63 6c 75 73 74 65 72 |sters/my-cluster| |00000320| 2d 74 61 72 67 65 74 2e 74 72 75 73 74 73 74 6f |-target.truststo| |00000330| 72 65 2e 70 31 32 22 2c 22 74 61 72 67 65 74 2e |re.p12","target.| |00000340| 63 6c 75 73 74 65 72 2e 6f 66 66 73 65 74 2e 73 |cluster.offset.s| |00000350| 74 6f 72 61 67 65 2e 72 65 70 6c 69 63 61 74 69 |torage.replicati| |00000360| 6f 6e 2e 66 61 63 74 6f 72 22 3a 22 31 22 2c 22 |on.factor":"1","| |00000370| 74 61 72 67 65 74 2e 63 6c 75 73 74 65 72 2e 73 |target.cluster.s| |00000380| 73 6c 2e 74 72 75 73 74 73 74 6f 72 65 2e 74 79 |sl.truststore.ty| |00000390| 70 65 22 3a 22 50 4b 43 53 31 32 22 2c 22 74 61 |pe":"PKCS12","ta| |000003a0| 72 67 65 74 2e 63 6c 75 73 74 65 72 2e 73 65 63 |rget.cluster.sec| |000003b0| 75 72 69 74 79 2e 70 72 6f 74 6f 63 6f 6c 22 3a |urity.protocol":| |000003c0| 22 53 41 53 4c 5f 53 53 4c 22 2c 22 74 61 72 67 |"SASL_SSL","targ| |000003d0| 65 74 2e 63 6c 75 73 74 65 72 2e 73 74 61 74 75 |et.cluster.statu| |000003e0| 73 2e 73 74 6f 72 61 67 65 2e 72 65 70 6c 69 63 |s.storage.replic| |000003f0| 61 74 69 6f 6e 2e 66 61 63 74 6f 72 22 3a 22 31 |ation.factor":"1| +--------+-------------------------------------------------+----------------+ 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0x35db5a32, L:/172.17.0.6:60594 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 1008B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 22 2c 22 6f 66 66 73 65 74 2d 73 79 6e 63 73 2e |","offset-syncs.| |00000010| 74 6f 70 69 63 2e 72 65 70 6c 69 63 61 74 69 6f |topic.replicatio| |00000020| 6e 2e 66 61 63 74 6f 72 22 3a 22 31 22 2c 22 74 |n.factor":"1","t| |00000030| 61 72 67 65 74 2e 63 6c 75 73 74 65 72 2e 73 61 |arget.cluster.sa| |00000040| 73 6c 2e 6d 65 63 68 61 6e 69 73 6d 22 3a 22 53 |sl.mechanism":"S| |00000050| 43 52 41 4d 2d 53 48 41 2d 35 31 32 22 2c 22 74 |CRAM-SHA-512","t| |00000060| 6f 70 69 63 73 22 3a 22 2e 2a 22 2c 22 74 61 72 |opics":".*","tar| |00000070| 67 65 74 2e 63 6c 75 73 74 65 72 2e 63 6f 6e 66 |get.cluster.conf| |00000080| 69 67 2e 73 74 6f 72 61 67 65 2e 72 65 70 6c 69 |ig.storage.repli| |00000090| 63 61 74 69 6f 6e 2e 66 61 63 74 6f 72 22 3a 22 |cation.factor":"| |000000a0| 31 22 2c 22 67 72 6f 75 70 73 22 3a 22 2e 2a 22 |1","groups":".*"| |000000b0| 2c 22 74 61 72 67 65 74 2e 63 6c 75 73 74 65 72 |,"target.cluster| |000000c0| 2e 73 73 6c 2e 74 72 75 73 74 73 74 6f 72 65 2e |.ssl.truststore.| |000000d0| 70 61 73 73 77 6f 72 64 22 3a 22 24 7b 66 69 6c |password":"${fil| |000000e0| 65 3a 2f 74 6d 70 2f 73 74 72 69 6d 7a 69 2d 6d |e:/tmp/strimzi-m| |000000f0| 69 72 72 6f 72 6d 61 6b 65 72 32 2d 63 6f 6e 6e |irrormaker2-conn| |00000100| 65 63 74 6f 72 2e 70 72 6f 70 65 72 74 69 65 73 |ector.properties| |00000110| 3a 73 73 6c 2e 74 72 75 73 74 73 74 6f 72 65 2e |:ssl.truststore.| |00000120| 70 61 73 73 77 6f 72 64 7d 22 2c 22 73 6f 75 72 |password}","sour| |00000130| 63 65 2e 63 6c 75 73 74 65 72 2e 73 61 73 6c 2e |ce.cluster.sasl.| |00000140| 6a 61 61 73 2e 63 6f 6e 66 69 67 22 3a 22 6f 72 |jaas.config":"or| |00000150| 67 2e 61 70 61 63 68 65 2e 6b 61 66 6b 61 2e 63 |g.apache.kafka.c| |00000160| 6f 6d 6d 6f 6e 2e 73 65 63 75 72 69 74 79 2e 73 |ommon.security.s| |00000170| 63 72 61 6d 2e 53 63 72 61 6d 4c 6f 67 69 6e 4d |cram.ScramLoginM| |00000180| 6f 64 75 6c 65 20 72 65 71 75 69 72 65 64 20 75 |odule required u| |00000190| 73 65 72 6e 61 6d 65 3d 5c 22 6d 79 2d 75 73 65 |sername=\"my-use| |000001a0| 72 2d 73 6f 75 72 63 65 5c 22 20 70 61 73 73 77 |r-source\" passw| |000001b0| 6f 72 64 3d 5c 22 24 7b 66 69 6c 65 3a 2f 74 6d |ord=\"${file:/tm| |000001c0| 70 2f 73 74 72 69 6d 7a 69 2d 6d 69 72 72 6f 72 |p/strimzi-mirror| |000001d0| 6d 61 6b 65 72 32 2d 63 6f 6e 6e 65 63 74 6f 72 |maker2-connector| |000001e0| 2e 70 72 6f 70 65 72 74 69 65 73 3a 6d 79 2d 63 |.properties:my-c| |000001f0| 6c 75 73 74 65 72 2d 73 6f 75 72 63 65 2e 73 61 |luster-source.sa| |00000200| 73 6c 2e 70 61 73 73 77 6f 72 64 7d 5c 22 3b 22 |sl.password}\";"| |00000210| 2c 22 73 6f 75 72 63 65 2e 63 6c 75 73 74 65 72 |,"source.cluster| |00000220| 2e 62 6f 6f 74 73 74 72 61 70 2e 73 65 72 76 65 |.bootstrap.serve| |00000230| 72 73 22 3a 22 6d 79 2d 63 6c 75 73 74 65 72 2d |rs":"my-cluster-| |00000240| 73 6f 75 72 63 65 2d 6b 61 66 6b 61 2d 62 6f 6f |source-kafka-boo| |00000250| 74 73 74 72 61 70 3a 39 30 39 33 22 2c 22 73 6f |tstrap:9093","so| |00000260| 75 72 63 65 2e 63 6c 75 73 74 65 72 2e 73 61 73 |urce.cluster.sas| |00000270| 6c 2e 6d 65 63 68 61 6e 69 73 6d 22 3a 22 53 43 |l.mechanism":"SC| |00000280| 52 41 4d 2d 53 48 41 2d 35 31 32 22 2c 22 74 61 |RAM-SHA-512","ta| |00000290| 72 67 65 74 2e 63 6c 75 73 74 65 72 2e 61 6c 69 |rget.cluster.ali| |000002a0| 61 73 22 3a 22 6d 79 2d 63 6c 75 73 74 65 72 2d |as":"my-cluster-| |000002b0| 74 61 72 67 65 74 22 2c 22 6e 61 6d 65 22 3a 22 |target","name":"| |000002c0| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |000002d0| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |000002e0| 72 67 65 74 2e 4d 69 72 72 6f 72 53 6f 75 72 63 |rget.MirrorSourc| |000002f0| 65 43 6f 6e 6e 65 63 74 6f 72 22 2c 22 74 61 72 |eConnector","tar| |00000300| 67 65 74 2e 63 6c 75 73 74 65 72 2e 62 6f 6f 74 |get.cluster.boot| |00000310| 73 74 72 61 70 2e 73 65 72 76 65 72 73 22 3a 22 |strap.servers":"| |00000320| 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 72 67 65 |my-cluster-targe| |00000330| 74 2d 6b 61 66 6b 61 2d 62 6f 6f 74 73 74 72 61 |t-kafka-bootstra| |00000340| 70 3a 39 30 39 33 22 2c 22 73 6f 75 72 63 65 2e |p:9093","source.| |00000350| 63 6c 75 73 74 65 72 2e 73 73 6c 2e 74 72 75 73 |cluster.ssl.trus| |00000360| 74 73 74 6f 72 65 2e 70 61 73 73 77 6f 72 64 22 |tstore.password"| |00000370| 3a 22 24 7b 66 69 6c 65 3a 2f 74 6d 70 2f 73 74 |:"${file:/tmp/st| |00000380| 72 69 6d 7a 69 2d 6d 69 72 72 6f 72 6d 61 6b 65 |rimzi-mirrormake| |00000390| 72 32 2d 63 6f 6e 6e 65 63 74 6f 72 2e 70 72 6f |r2-connector.pro| |000003a0| 70 65 72 74 69 65 73 3a 73 73 6c 2e 74 72 75 73 |perties:ssl.trus| |000003b0| 74 73 74 6f 72 65 2e 70 61 73 73 77 6f 72 64 7d |tstore.password}| |000003c0| 22 2c 22 73 6f 75 72 63 65 2e 63 6c 75 73 74 65 |","source.cluste| |000003d0| 72 2e 73 65 63 75 72 69 74 79 2e 70 72 6f 74 6f |r.security.proto| |000003e0| 63 6f 6c 22 3a 22 53 41 53 4c 5f 53 53 4c 22 7d |col":"SASL_SSL"}| +--------+-------------------------------------------------+----------------+ 2020-04-15 00:34:55 DEBUG KafkaConnectApiImpl:246 - Got 200 response to GET request to /connectors/my-cluster-source->my-cluster-target.MirrorSourceConnector/config: {connector.class=org.apache.kafka.connect.mirror.MirrorSourceConnector, replication.factor=1, source.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-source.truststore.p12, target.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-target" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}";, topics.blacklist=availability.*, sync.topic.acls.enabled=false, source.cluster.ssl.truststore.type=PKCS12, source.cluster.alias=my-cluster-source, target.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-target.truststore.p12, target.cluster.offset.storage.replication.factor=1, target.cluster.ssl.truststore.type=PKCS12, target.cluster.security.protocol=SASL_SSL, target.cluster.status.storage.replication.factor=1, offset-syncs.topic.replication.factor=1, target.cluster.sasl.mechanism=SCRAM-SHA-512, topics=.*, target.cluster.config.storage.replication.factor=1, groups=.*, target.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, source.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-source" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}";, source.cluster.bootstrap.servers=my-cluster-source-kafka-bootstrap:9093, source.cluster.sasl.mechanism=SCRAM-SHA-512, target.cluster.alias=my-cluster-target, name=my-cluster-source->my-cluster-target.MirrorSourceConnector, target.cluster.bootstrap.servers=my-cluster-target-kafka-bootstrap:9093, source.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, source.cluster.security.protocol=SASL_SSL} 2020-04-15 00:34:55 DEBUG AbstractConnectOperator:457 - Reconciliation #65(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Desired: {connector.class=org.apache.kafka.connect.mirror.MirrorSourceConnector, groups=.*, name=my-cluster-source->my-cluster-target.MirrorSourceConnector, offset-syncs.topic.replication.factor=1, replication.factor=1, source.cluster.alias=my-cluster-source, source.cluster.bootstrap.servers=my-cluster-source-kafka-bootstrap:9093, source.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-source" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}";, source.cluster.sasl.mechanism=SCRAM-SHA-512, source.cluster.security.protocol=SASL_SSL, source.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-source.truststore.p12, source.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, source.cluster.ssl.truststore.type=PKCS12, sync.topic.acls.enabled=false, target.cluster.alias=my-cluster-target, target.cluster.bootstrap.servers=my-cluster-target-kafka-bootstrap:9093, target.cluster.config.storage.replication.factor=1, target.cluster.offset.storage.replication.factor=1, target.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-target" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}";, target.cluster.sasl.mechanism=SCRAM-SHA-512, target.cluster.security.protocol=SASL_SSL, target.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-target.truststore.p12, target.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, target.cluster.ssl.truststore.type=PKCS12, target.cluster.status.storage.replication.factor=1, topics=.*, topics.blacklist=availability.*} 2020-04-15 00:34:55 DEBUG AbstractConnectOperator:458 - Reconciliation #65(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Actual: {connector.class=org.apache.kafka.connect.mirror.MirrorSourceConnector, groups=.*, name=my-cluster-source->my-cluster-target.MirrorSourceConnector, offset-syncs.topic.replication.factor=1, replication.factor=1, source.cluster.alias=my-cluster-source, source.cluster.bootstrap.servers=my-cluster-source-kafka-bootstrap:9093, source.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-source" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}";, source.cluster.sasl.mechanism=SCRAM-SHA-512, source.cluster.security.protocol=SASL_SSL, source.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-source.truststore.p12, source.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, source.cluster.ssl.truststore.type=PKCS12, sync.topic.acls.enabled=false, target.cluster.alias=my-cluster-target, target.cluster.bootstrap.servers=my-cluster-target-kafka-bootstrap:9093, target.cluster.config.storage.replication.factor=1, target.cluster.offset.storage.replication.factor=1, target.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-target" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}";, target.cluster.sasl.mechanism=SCRAM-SHA-512, target.cluster.security.protocol=SASL_SSL, target.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-target.truststore.p12, target.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, target.cluster.ssl.truststore.type=PKCS12, target.cluster.status.storage.replication.factor=1, topics=.*, topics.blacklist=availability.*} 2020-04-15 00:34:55 DEBUG AbstractConnectOperator:421 - Reconciliation #65(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Connector my-cluster-source->my-cluster-target.MirrorSourceConnector exists and has desired config, {offset-syncs.topic.replication.factor=1, replication.factor=1, sync.topic.acls.enabled=false, target.cluster.alias=my-cluster-target, target.cluster.bootstrap.servers=my-cluster-target-kafka-bootstrap:9093, target.cluster.ssl.truststore.type=PKCS12, target.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-target.truststore.p12, target.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, target.cluster.sasl.mechanism=SCRAM-SHA-512, target.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-target" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}";, target.cluster.security.protocol=SASL_SSL, target.cluster.status.storage.replication.factor=1, target.cluster.offset.storage.replication.factor=1, target.cluster.config.storage.replication.factor=1, source.cluster.alias=my-cluster-source, source.cluster.bootstrap.servers=my-cluster-source-kafka-bootstrap:9093, source.cluster.ssl.truststore.type=PKCS12, source.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-source.truststore.p12, source.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, source.cluster.sasl.mechanism=SCRAM-SHA-512, source.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-source" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}";, source.cluster.security.protocol=SASL_SSL, topics=.*, topics.blacklist=availability.*, groups=.*}=={connector.class=org.apache.kafka.connect.mirror.MirrorSourceConnector, replication.factor=1, source.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-source.truststore.p12, target.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-target" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}";, topics.blacklist=availability.*, sync.topic.acls.enabled=false, source.cluster.ssl.truststore.type=PKCS12, source.cluster.alias=my-cluster-source, target.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-target.truststore.p12, target.cluster.offset.storage.replication.factor=1, target.cluster.ssl.truststore.type=PKCS12, target.cluster.security.protocol=SASL_SSL, target.cluster.status.storage.replication.factor=1, offset-syncs.topic.replication.factor=1, target.cluster.sasl.mechanism=SCRAM-SHA-512, topics=.*, target.cluster.config.storage.replication.factor=1, groups=.*, target.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, source.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-source" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}";, source.cluster.bootstrap.servers=my-cluster-source-kafka-bootstrap:9093, source.cluster.sasl.mechanism=SCRAM-SHA-512, target.cluster.alias=my-cluster-target, name=my-cluster-source->my-cluster-target.MirrorSourceConnector, target.cluster.bootstrap.servers=my-cluster-target-kafka-bootstrap:9093, source.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, source.cluster.security.protocol=SASL_SSL} 2020-04-15 00:34:55 DEBUG KafkaConnectApiImpl:235 - Making GET request to /connectors/my-cluster-source->my-cluster-target.MirrorSourceConnector/status 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0x35db5a32, L:/172.17.0.6:60594 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:34:55 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [20032: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN A) 2020-04-15 00:34:55 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [37075: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) 2020-04-15 00:34:55 DEBUG LoggingHandler:145 - [id: 0x3e19d6b5, L:/172.17.0.6:60596 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 1024B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 48 54 54 50 2f 31 2e 31 20 32 30 30 20 4f 4b 0d |HTTP/1.1 200 OK.| |00000010| 0a 44 61 74 65 3a 20 57 65 64 2c 20 31 35 20 41 |.Date: Wed, 15 A| |00000020| 70 72 20 32 30 32 30 20 30 30 3a 33 34 3a 35 35 |pr 2020 00:34:55| |00000030| 20 47 4d 54 0d 0a 43 6f 6e 74 65 6e 74 2d 54 79 | GMT..Content-Ty| |00000040| 70 65 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pe: application/| |00000050| 6a 73 6f 6e 0d 0a 43 6f 6e 74 65 6e 74 2d 4c 65 |json..Content-Le| |00000060| 6e 67 74 68 3a 20 31 38 33 34 0d 0a 53 65 72 76 |ngth: 1834..Serv| |00000070| 65 72 3a 20 4a 65 74 74 79 28 39 2e 34 2e 32 30 |er: Jetty(9.4.20| |00000080| 2e 76 32 30 31 39 30 38 31 33 29 0d 0a 0d 0a 7b |.v20190813)....{| |00000090| 22 63 6f 6e 6e 65 63 74 6f 72 2e 63 6c 61 73 73 |"connector.class| |000000a0| 22 3a 22 6f 72 67 2e 61 70 61 63 68 65 2e 6b 61 |":"org.apache.ka| |000000b0| 66 6b 61 2e 63 6f 6e 6e 65 63 74 2e 6d 69 72 72 |fka.connect.mirr| |000000c0| 6f 72 2e 4d 69 72 72 6f 72 48 65 61 72 74 62 65 |or.MirrorHeartbe| |000000d0| 61 74 43 6f 6e 6e 65 63 74 6f 72 22 2c 22 73 6f |atConnector","so| |000000e0| 75 72 63 65 2e 63 6c 75 73 74 65 72 2e 73 73 6c |urce.cluster.ssl| |000000f0| 2e 74 72 75 73 74 73 74 6f 72 65 2e 6c 6f 63 61 |.truststore.loca| |00000030| 72 67 65 74 2e 4d 69 72 72 6f 72 53 6f 75 72 63 |rget.MirrorSourc| |00000040| 65 43 6f 6e 6e 65 63 74 6f 72 2f 73 74 61 74 75 |eConnector/statu| |00000050| 73 20 48 54 54 50 2f 31 2e 31 0d 0a 41 63 63 65 |s HTTP/1.1..Acce| |00000060| 70 74 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pt: application/| |00000070| 6a 73 6f 6e 0d 0a 68 6f 73 74 3a 20 6d 79 2d 63 |json..host: my-c| |00000080| 6c 75 73 74 65 72 2d 6d 69 72 72 6f 72 6d 61 6b |luster-mirrormak| |00000090| 65 72 32 2d 61 70 69 2e 6d 69 72 72 6f 72 6d 61 |er2-api.mirrorma| |000000a0| 6b 65 72 32 2d 63 6c 75 73 74 65 72 2d 74 65 73 |ker2-cluster-tes| |000000b0| 74 2e 73 76 63 3a 38 30 38 33 0d 0a 0d 0a |t.svc:8083.... | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0xef69f8d1, L:/172.17.0.6:32842 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0xef69f8d1, L:/172.17.0.6:32842 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x544c57e4, L:/172.17.0.6:32844 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] WRITE: 194B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 63 6f 6e 6e 65 63 74 6f 72 73 2f |GET /connectors/| |00000010| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |00000020| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |00000030| 72 67 65 74 2e 4d 69 72 72 6f 72 43 68 65 63 6b |rget.MirrorCheck| |00000040| 70 6f 69 6e 74 43 6f 6e 6e 65 63 74 6f 72 2f 73 |pointConnector/s| |00000050| 74 61 74 75 73 20 48 54 54 50 2f 31 2e 31 0d 0a |tatus HTTP/1.1..| |00000060| 41 63 63 65 70 74 3a 20 61 70 70 6c 69 63 61 74 |Accept: applicat| |00000070| 69 6f 6e 2f 6a 73 6f 6e 0d 0a 68 6f 73 74 3a 20 |ion/json..host: | |00000080| 6d 79 2d 63 6c 75 73 74 65 72 2d 6d 69 72 72 6f |my-cluster-mirro| |00000090| 72 6d 61 6b 65 72 32 2d 61 70 69 2e 6d 69 72 72 |rmaker2-api.mirr| |000000a0| 6f 72 6d 61 6b 65 72 32 2d 63 6c 75 73 74 65 72 |ormaker2-cluster| |000000b0| 2d 74 65 73 74 2e 73 76 63 3a 38 30 38 33 0d 0a |-test.svc:8083..| |000000c0| 0d 0a |.. | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x544c57e4, L:/172.17.0.6:32844 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x544c57e4, L:/172.17.0.6:32844 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x59aa4226, L:/172.17.0.6:32846 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] WRITE: 193B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 63 6f 6e 6e 65 63 74 6f 72 73 2f |GET /connectors/| |00000010| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |00000020| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |00000030| 72 67 65 74 2e 4d 69 72 72 6f 72 48 65 61 72 74 |rget.MirrorHeart| |00000040| 62 65 61 74 43 6f 6e 6e 65 63 74 6f 72 2f 73 74 |beatConnector/st| |00000050| 61 74 75 73 20 48 54 54 50 2f 31 2e 31 0d 0a 41 |atus HTTP/1.1..A| |00000060| 63 63 65 70 74 3a 20 61 70 70 6c 69 63 61 74 69 |ccept: applicati| |00000070| 6f 6e 2f 6a 73 6f 6e 0d 0a 68 6f 73 74 3a 20 6d |on/json..host: m| |00000080| 79 2d 63 6c 75 73 74 65 72 2d 6d 69 72 72 6f 72 |y-cluster-mirror| |00000090| 6d 61 6b 65 72 32 2d 61 70 69 2e 6d 69 72 72 6f |maker2-api.mirro| |000000a0| 72 6d 61 6b 65 72 32 2d 63 6c 75 73 74 65 72 2d |rmaker2-cluster-| |000000b0| 74 65 73 74 2e 73 76 63 3a 38 30 38 33 0d 0a 0d |test.svc:8083...| |000000c0| 0a |. | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x59aa4226, L:/172.17.0.6:32846 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x59aa4226, L:/172.17.0.6:32846 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0xef69f8d1, L:/172.17.0.6:32842 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 358B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 48 54 54 50 2f 31 2e 31 20 32 30 30 20 4f 4b 0d |HTTP/1.1 200 OK.| |00000010| 0a 44 61 74 65 3a 20 57 65 64 2c 20 31 35 20 41 |.Date: Wed, 15 A| |00000020| 70 72 20 32 30 32 30 20 30 30 3a 33 35 3a 32 35 |pr 2020 00:35:25| |00000030| 20 47 4d 54 0d 0a 43 6f 6e 74 65 6e 74 2d 54 79 | GMT..Content-Ty| |00000040| 70 65 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pe: application/| |00000050| 6a 73 6f 6e 0d 0a 43 6f 6e 74 65 6e 74 2d 4c 65 |json..Content-Le| |00000060| 6e 67 74 68 3a 20 32 31 36 0d 0a 53 65 72 76 65 |ngth: 216..Serve| |00000070| 72 3a 20 4a 65 74 74 79 28 39 2e 34 2e 32 30 2e |r: Jetty(9.4.20.| |00000080| 76 32 30 31 39 30 38 31 33 29 0d 0a 0d 0a 7b 22 |v20190813)....{"| |00000090| 6e 61 6d 65 22 3a 22 6d 79 2d 63 6c 75 73 74 65 |name":"my-cluste| |000000a0| 72 2d 73 6f 75 72 63 65 2d 3e 6d 79 2d 63 6c 75 |r-source->my-clu| |000000b0| 73 74 65 72 2d 74 61 72 67 65 74 2e 4d 69 72 72 |ster-target.Mirr| |000000c0| 6f 72 53 6f 75 72 63 65 43 6f 6e 6e 65 63 74 6f |orSourceConnecto| |000000d0| 72 22 2c 22 63 6f 6e 6e 65 63 74 6f 72 22 3a 7b |r","connector":{| |000000e0| 22 73 74 61 74 65 22 3a 22 52 55 4e 4e 49 4e 47 |"state":"RUNNING| |000000f0| 22 2c 22 77 6f 72 6b 65 72 5f 69 64 22 3a 22 31 |","worker_id":"1| |00000100| 37 32 2e 31 37 2e 30 2e 31 39 3a 38 30 38 33 22 |72.17.0.19:8083"| |00000110| 7d 2c 22 74 61 73 6b 73 22 3a 5b 7b 22 69 64 22 |},"tasks":[{"id"| |00000120| 3a 30 2c 22 73 74 61 74 65 22 3a 22 52 55 4e 4e |:0,"state":"RUNN| |00000130| 49 4e 47 22 2c 22 77 6f 72 6b 65 72 5f 69 64 22 |ING","worker_id"| |00000140| 3a 22 31 37 32 2e 31 37 2e 30 2e 31 39 3a 38 30 |:"172.17.0.19:80| |00000150| 38 33 22 7d 5d 2c 22 74 79 70 65 22 3a 22 73 6f |83"}],"type":"so| |00000160| 75 72 63 65 22 7d |urce"} | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:35:25 DEBUG KafkaConnectApiImpl:246 - Got 200 response to GET request to /connectors/my-cluster-source->my-cluster-target.MirrorSourceConnector/status: {name=my-cluster-source->my-cluster-target.MirrorSourceConnector, connector={state=RUNNING, worker_id=172.17.0.19:8083}, tasks=[{id=0, state=RUNNING, worker_id=172.17.0.19:8083}], type=source} 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0xef69f8d1, L:/172.17.0.6:32842 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x544c57e4, L:/172.17.0.6:32844 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 362B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 48 54 54 50 2f 31 2e 31 20 32 30 30 20 4f 4b 0d |HTTP/1.1 200 OK.| |00000010| 0a 44 61 74 65 3a 20 57 65 64 2c 20 31 35 20 41 |.Date: Wed, 15 A| |00000020| 70 72 20 32 30 32 30 20 30 30 3a 33 35 3a 32 35 |pr 2020 00:35:25| |00000030| 20 47 4d 54 0d 0a 43 6f 6e 74 65 6e 74 2d 54 79 | GMT..Content-Ty| |00000040| 70 65 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pe: application/| |00000050| 6a 73 6f 6e 0d 0a 43 6f 6e 74 65 6e 74 2d 4c 65 |json..Content-Le| |00000060| 6e 67 74 68 3a 20 32 32 30 0d 0a 53 65 72 76 65 |ngth: 220..Serve| |00000070| 72 3a 20 4a 65 74 74 79 28 39 2e 34 2e 32 30 2e |r: Jetty(9.4.20.| |00000080| 76 32 30 31 39 30 38 31 33 29 0d 0a 0d 0a 7b 22 |v20190813)....{"| |00000090| 6e 61 6d 65 22 3a 22 6d 79 2d 63 6c 75 73 74 65 |name":"my-cluste| |000000a0| 72 2d 73 6f 75 72 63 65 2d 3e 6d 79 2d 63 6c 75 |r-source->my-clu| |000000b0| 73 74 65 72 2d 74 61 72 67 65 74 2e 4d 69 72 72 |ster-target.Mirr| |000000c0| 6f 72 43 68 65 63 6b 70 6f 69 6e 74 43 6f 6e 6e |orCheckpointConn| |000000d0| 65 63 74 6f 72 22 2c 22 63 6f 6e 6e 65 63 74 6f |ector","connecto| |000000e0| 72 22 3a 7b 22 73 74 61 74 65 22 3a 22 52 55 4e |r":{"state":"RUN| |000000f0| 4e 49 4e 47 22 2c 22 77 6f 72 6b 65 72 5f 69 64 |NING","worker_id| |00000100| 22 3a 22 31 37 32 2e 31 37 2e 30 2e 31 39 3a 38 |":"172.17.0.19:8| |00000110| 30 38 33 22 7d 2c 22 74 61 73 6b 73 22 3a 5b 7b |083"},"tasks":[{| |00000120| 22 69 64 22 3a 30 2c 22 73 74 61 74 65 22 3a 22 |"id":0,"state":"| |00000130| 52 55 4e 4e 49 4e 47 22 2c 22 77 6f 72 6b 65 72 |RUNNING","worker| |00000140| 5f 69 64 22 3a 22 31 37 32 2e 31 37 2e 30 2e 31 |_id":"172.17.0.1| |00000150| 39 3a 38 30 38 33 22 7d 5d 2c 22 74 79 70 65 22 |9:8083"}],"type"| |00000160| 3a 22 73 6f 75 72 63 65 22 7d |:"source"} | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:35:25 DEBUG KafkaConnectApiImpl:246 - Got 200 response to GET request to /connectors/my-cluster-source->my-cluster-target.MirrorCheckpointConnector/status: {name=my-cluster-source->my-cluster-target.MirrorCheckpointConnector, connector={state=RUNNING, worker_id=172.17.0.19:8083}, tasks=[{id=0, state=RUNNING, worker_id=172.17.0.19:8083}], type=source} 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x544c57e4, L:/172.17.0.6:32844 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x59aa4226, L:/172.17.0.6:32846 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 361B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 48 54 54 50 2f 31 2e 31 20 32 30 30 20 4f 4b 0d |HTTP/1.1 200 OK.| |00000010| 0a 44 61 74 65 3a 20 57 65 64 2c 20 31 35 20 41 |.Date: Wed, 15 A| |00000020| 70 72 20 32 30 32 30 20 30 30 3a 33 35 3a 32 35 |pr 2020 00:35:25| |00000030| 20 47 4d 54 0d 0a 43 6f 6e 74 65 6e 74 2d 54 79 | GMT..Content-Ty| |00000040| 70 65 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pe: application/| |00000050| 6a 73 6f 6e 0d 0a 43 6f 6e 74 65 6e 74 2d 4c 65 |json..Content-Le| |00000060| 6e 67 74 68 3a 20 32 31 39 0d 0a 53 65 72 76 65 |ngth: 219..Serve| |00000070| 72 3a 20 4a 65 74 74 79 28 39 2e 34 2e 32 30 2e |r: Jetty(9.4.20.| |00000080| 76 32 30 31 39 30 38 31 33 29 0d 0a 0d 0a 7b 22 |v20190813)....{"| |00000090| 6e 61 6d 65 22 3a 22 6d 79 2d 63 6c 75 73 74 65 |name":"my-cluste| |000000a0| 72 2d 73 6f 75 72 63 65 2d 3e 6d 79 2d 63 6c 75 |r-source->my-clu| |000000b0| 73 74 65 72 2d 74 61 72 67 65 74 2e 4d 69 72 72 |ster-target.Mirr| |000000c0| 6f 72 48 65 61 72 74 62 65 61 74 43 6f 6e 6e 65 |orHeartbeatConne| |000000d0| 63 74 6f 72 22 2c 22 63 6f 6e 6e 65 63 74 6f 72 |ctor","connector| |000000e0| 22 3a 7b 22 73 74 61 74 65 22 3a 22 52 55 4e 4e |":{"state":"RUNN| |000000f0| 49 4e 47 22 2c 22 77 6f 72 6b 65 72 5f 69 64 22 |ING","worker_id"| |00000100| 3a 22 31 37 32 2e 31 37 2e 30 2e 31 39 3a 38 30 |:"172.17.0.19:80| |00000110| 38 33 22 7d 2c 22 74 61 73 6b 73 22 3a 5b 7b 22 |83"},"tasks":[{"| |00000120| 69 64 22 3a 30 2c 22 73 74 61 74 65 22 3a 22 52 |id":0,"state":"R| |00000130| 55 4e 4e 49 4e 47 22 2c 22 77 6f 72 6b 65 72 5f |UNNING","worker_| |00000140| 69 64 22 3a 22 31 37 32 2e 31 37 2e 30 2e 31 39 |id":"172.17.0.19| |00000150| 3a 38 30 38 33 22 7d 5d 2c 22 74 79 70 65 22 3a |:8083"}],"type":| |00000160| 22 73 6f 75 72 63 65 22 7d |"source"} | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:35:25 DEBUG KafkaConnectApiImpl:246 - Got 200 response to GET request to /connectors/my-cluster-source->my-cluster-target.MirrorHeartbeatConnector/status: {name=my-cluster-source->my-cluster-target.MirrorHeartbeatConnector, connector={state=RUNNING, worker_id=172.17.0.19:8083}, tasks=[{id=0, state=RUNNING, worker_id=172.17.0.19:8083}], type=source} 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x59aa4226, L:/172.17.0.6:32846 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:25 DEBUG StatusDiff:37 - Ignoring Status diff {"op":"replace","path":"/conditions/0/lastTransitionTime","value":"2020-04-15T00:35:25.529Z"} 2020-04-15 00:35:25 DEBUG StatusDiff:42 - Status differs: {"op":"move","path":"/connectors/0","from":"/connectors/1"} 2020-04-15 00:35:25 DEBUG StatusDiff:43 - Current Status path /connectors/0 has value {"connector":{"state":"RUNNING","worker_id":"172.17.0.19:8083"},"name":"my-cluster-source->my-cluster-target.MirrorCheckpointConnector","tasks":[{"id":0,"state":"RUNNING","worker_id":"172.17.0.19:8083"}],"type":"source"} 2020-04-15 00:35:25 DEBUG StatusDiff:44 - Desired Status path /connectors/0 has value {"name":"my-cluster-source->my-cluster-target.MirrorSourceConnector","connector":{"state":"RUNNING","worker_id":"172.17.0.19:8083"},"tasks":[{"id":0,"state":"RUNNING","worker_id":"172.17.0.19:8083"}],"type":"source"} 2020-04-15 00:35:25 INFO OperatorWatcher:40 - Reconciliation #84(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2 my-cluster in namespace mirrormaker2-cluster-test was MODIFIED 2020-04-15 00:35:25 DEBUG AbstractConnectOperator:588 - Reconciliation #83(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Completed status update 2020-04-15 00:35:25 INFO AbstractOperator:317 - Reconciliation #83(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): reconciled 2020-04-15 00:35:25 DEBUG AbstractOperator:237 - Reconciliation #83(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Lock lock::mirrormaker2-cluster-test::KafkaMirrorMaker2::my-cluster released 2020-04-15 00:35:25 DEBUG AbstractOperator:226 - Reconciliation #84(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Lock lock::mirrormaker2-cluster-test::KafkaMirrorMaker2::my-cluster acquired 2020-04-15 00:35:25 INFO AbstractOperator:173 - Reconciliation #84(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2 my-cluster should be created or updated 2020-04-15 00:35:25 DEBUG KafkaMirrorMaker2AssemblyOperator:144 - Reconciliation #84(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Updating Kafka MirrorMaker 2.0 cluster 2020-04-15 00:35:25 DEBUG ServiceAccountOperator:102 - ServiceAccount mirrormaker2-cluster-test/my-cluster-mirrormaker2 already exists, patching it 2020-04-15 00:35:25 DEBUG NetworkPolicyOperator:102 - NetworkPolicy mirrormaker2-cluster-test/my-cluster-mirrormaker2 already exists, patching it 2020-04-15 00:35:25 DEBUG NetworkPolicyOperator:168 - NetworkPolicy my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test has been patched 2020-04-15 00:35:25 DEBUG ServiceOperator:102 - Service mirrormaker2-cluster-test/my-cluster-mirrormaker2-api already exists, patching it 2020-04-15 00:35:25 DEBUG ServiceOperator:168 - Service my-cluster-mirrormaker2-api in namespace mirrormaker2-cluster-test has been patched 2020-04-15 00:35:25 DEBUG ConfigMapOperator:102 - ConfigMap mirrormaker2-cluster-test/my-cluster-mirrormaker2-config already exists, patching it 2020-04-15 00:35:25 DEBUG ConfigMapOperator:47 - ConfigMap my-cluster-mirrormaker2-config in namespace mirrormaker2-cluster-test has not been patched because resources are equal 2020-04-15 00:35:25 DEBUG PodDisruptionBudgetOperator:102 - PodDisruptionBudget mirrormaker2-cluster-test/my-cluster-mirrormaker2 already exists, patching it 2020-04-15 00:35:25 DEBUG PodDisruptionBudgetOperator:149 - PodDisruptionBudget my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test has been deleted 2020-04-15 00:35:25 DEBUG PodDisruptionBudgetOperator:195 - PodDisruptionBudget my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test has been created 2020-04-15 00:35:25 DEBUG DeploymentOperator:102 - Deployment mirrormaker2-cluster-test/my-cluster-mirrormaker2 already exists, patching it 2020-04-15 00:35:25 DEBUG DeploymentOperator:168 - Deployment my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test has been patched 2020-04-15 00:35:25 DEBUG Util:62 - Waiting for Deployment resource my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test to get ready 2020-04-15 00:35:25 DEBUG Util:84 - Deployment resource my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test is ready 2020-04-15 00:35:25 DEBUG Util:62 - Waiting for Deployment resource my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test to get ready 2020-04-15 00:35:25 DEBUG Util:84 - Deployment resource my-cluster-mirrormaker2 in namespace mirrormaker2-cluster-test is ready 2020-04-15 00:35:25 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [30820: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN A) 2020-04-15 00:35:25 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [39866: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) 2020-04-15 00:35:25 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [39866: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 39866, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:35:25 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [30820: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 30820, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN A) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:35:25 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [59939: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN CNAME) 2020-04-15 00:35:25 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [59939: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 59939, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN CNAME) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:35:25 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [9688: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN A) 2020-04-15 00:35:25 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [1336: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN AAAA) 2020-04-15 00:35:25 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [1336: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 1336, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN AAAA) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:35:25 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [9688: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 9688, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN A) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:35:25 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [41378: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN CNAME) 2020-04-15 00:35:25 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [41378: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 41378, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN CNAME) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x9c6bdb2f, L:/172.17.0.6:32850 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] WRITE: 124B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 63 6f 6e 6e 65 63 74 6f 72 73 20 |GET /connectors | |00000010| 48 54 54 50 2f 31 2e 31 0d 0a 41 63 63 65 70 74 |HTTP/1.1..Accept| |00000020| 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f 6a 73 |: application/js| |00000030| 6f 6e 0d 0a 68 6f 73 74 3a 20 6d 79 2d 63 6c 75 |on..host: my-clu| |00000040| 73 74 65 72 2d 6d 69 72 72 6f 72 6d 61 6b 65 72 |ster-mirrormaker| |00000050| 32 2d 61 70 69 2e 6d 69 72 72 6f 72 6d 61 6b 65 |2-api.mirrormake| |00000060| 72 32 2d 63 6c 75 73 74 65 72 2d 74 65 73 74 2e |r2-cluster-test.| |00000070| 73 76 63 3a 38 30 38 33 0d 0a 0d 0a |svc:8083.... | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x9c6bdb2f, L:/172.17.0.6:32850 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x9c6bdb2f, L:/172.17.0.6:32850 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x9c6bdb2f, L:/172.17.0.6:32850 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 333B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 48 54 54 50 2f 31 2e 31 20 32 30 30 20 4f 4b 0d |HTTP/1.1 200 OK.| |00000010| 0a 44 61 74 65 3a 20 57 65 64 2c 20 31 35 20 41 |.Date: Wed, 15 A| |00000020| 70 72 20 32 30 32 30 20 30 30 3a 33 35 3a 32 35 |pr 2020 00:35:25| |00000030| 20 47 4d 54 0d 0a 43 6f 6e 74 65 6e 74 2d 54 79 | GMT..Content-Ty| |00000040| 70 65 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pe: application/| |00000050| 6a 73 6f 6e 0d 0a 43 6f 6e 74 65 6e 74 2d 4c 65 |json..Content-Le| |00000060| 6e 67 74 68 3a 20 31 39 31 0d 0a 53 65 72 76 65 |ngth: 191..Serve| |00000070| 72 3a 20 4a 65 74 74 79 28 39 2e 34 2e 32 30 2e |r: Jetty(9.4.20.| |00000080| 76 32 30 31 39 30 38 31 33 29 0d 0a 0d 0a 5b 22 |v20190813)....["| |00000090| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |000000a0| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |000000b0| 72 67 65 74 2e 4d 69 72 72 6f 72 48 65 61 72 74 |rget.MirrorHeart| |000000c0| 62 65 61 74 43 6f 6e 6e 65 63 74 6f 72 22 2c 22 |beatConnector","| |000000d0| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |000000e0| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |000000f0| 72 67 65 74 2e 4d 69 72 72 6f 72 53 6f 75 72 63 |rget.MirrorSourc| |00000100| 65 43 6f 6e 6e 65 63 74 6f 72 22 2c 22 6d 79 2d |eConnector","my-| |00000110| 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 65 2d 3e |cluster-source->| |00000120| 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 72 67 65 |my-cluster-targe| |00000130| 74 2e 4d 69 72 72 6f 72 43 68 65 63 6b 70 6f 69 |t.MirrorCheckpoi| |00000140| 6e 74 43 6f 6e 6e 65 63 74 6f 72 22 5d |ntConnector"] | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:35:25 DEBUG KafkaMirrorMaker2AssemblyOperator:206 - Reconciliation #84(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2} cluster: delete MirrorMaker 2.0 connectors: [] 2020-04-15 00:35:25 DEBUG KafkaMirrorMaker2AssemblyOperator:253 - Reconciliation #84(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2} cluster: creating/updating connector my-cluster-source->my-cluster-target.MirrorCheckpointConnector config: {"checkpoints.topic.replication.factor":1,"target.cluster.alias":"my-cluster-target","target.cluster.bootstrap.servers":"my-cluster-target-kafka-bootstrap:9093","target.cluster.ssl.truststore.type":"PKCS12","target.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-target.truststore.p12","target.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","target.cluster.sasl.mechanism":"SCRAM-SHA-512","target.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-target\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}\";","target.cluster.security.protocol":"SASL_SSL","target.cluster.status.storage.replication.factor":1,"target.cluster.offset.storage.replication.factor":1,"target.cluster.config.storage.replication.factor":1,"source.cluster.alias":"my-cluster-source","source.cluster.bootstrap.servers":"my-cluster-source-kafka-bootstrap:9093","source.cluster.ssl.truststore.type":"PKCS12","source.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-source.truststore.p12","source.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","source.cluster.sasl.mechanism":"SCRAM-SHA-512","source.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-source\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}\";","source.cluster.security.protocol":"SASL_SSL","topics":".*","topics.blacklist":"availability.*","groups":".*","connector.class":"org.apache.kafka.connect.mirror.MirrorCheckpointConnector"} 2020-04-15 00:35:25 DEBUG KafkaConnectApiImpl:235 - Making GET request to /connectors/my-cluster-source->my-cluster-target.MirrorCheckpointConnector/config 2020-04-15 00:35:25 DEBUG KafkaMirrorMaker2AssemblyOperator:253 - Reconciliation #84(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2} cluster: creating/updating connector my-cluster-source->my-cluster-target.MirrorSourceConnector config: {"offset-syncs.topic.replication.factor":1,"replication.factor":1,"sync.topic.acls.enabled":"false","target.cluster.alias":"my-cluster-target","target.cluster.bootstrap.servers":"my-cluster-target-kafka-bootstrap:9093","target.cluster.ssl.truststore.type":"PKCS12","target.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-target.truststore.p12","target.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","target.cluster.sasl.mechanism":"SCRAM-SHA-512","target.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-target\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}\";","target.cluster.security.protocol":"SASL_SSL","target.cluster.status.storage.replication.factor":1,"target.cluster.offset.storage.replication.factor":1,"target.cluster.config.storage.replication.factor":1,"source.cluster.alias":"my-cluster-source","source.cluster.bootstrap.servers":"my-cluster-source-kafka-bootstrap:9093","source.cluster.ssl.truststore.type":"PKCS12","source.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-source.truststore.p12","source.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","source.cluster.sasl.mechanism":"SCRAM-SHA-512","source.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-source\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}\";","source.cluster.security.protocol":"SASL_SSL","topics":".*","topics.blacklist":"availability.*","groups":".*","connector.class":"org.apache.kafka.connect.mirror.MirrorSourceConnector"} 2020-04-15 00:35:25 DEBUG KafkaConnectApiImpl:235 - Making GET request to /connectors/my-cluster-source->my-cluster-target.MirrorSourceConnector/config 2020-04-15 00:35:25 DEBUG KafkaMirrorMaker2AssemblyOperator:253 - Reconciliation #84(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): KafkaMirrorMaker2} cluster: creating/updating connector my-cluster-source->my-cluster-target.MirrorHeartbeatConnector config: {"heartbeats.topic.replication.factor":1,"target.cluster.alias":"my-cluster-target","target.cluster.bootstrap.servers":"my-cluster-target-kafka-bootstrap:9093","target.cluster.ssl.truststore.type":"PKCS12","target.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-target.truststore.p12","target.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","target.cluster.sasl.mechanism":"SCRAM-SHA-512","target.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-target\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}\";","target.cluster.security.protocol":"SASL_SSL","target.cluster.status.storage.replication.factor":1,"target.cluster.offset.storage.replication.factor":1,"target.cluster.config.storage.replication.factor":1,"source.cluster.alias":"my-cluster-source","source.cluster.bootstrap.servers":"my-cluster-source-kafka-bootstrap:9093","source.cluster.ssl.truststore.type":"PKCS12","source.cluster.ssl.truststore.location":"/tmp/kafka/clusters/my-cluster-source.truststore.p12","source.cluster.ssl.truststore.password":"${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}","source.cluster.sasl.mechanism":"SCRAM-SHA-512","source.cluster.sasl.jaas.config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"my-user-source\" password=\"${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}\";","source.cluster.security.protocol":"SASL_SSL","topics":".*","topics.blacklist":"availability.*","groups":".*","connector.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatConnector"} 2020-04-15 00:35:25 DEBUG KafkaConnectApiImpl:235 - Making GET request to /connectors/my-cluster-source->my-cluster-target.MirrorHeartbeatConnector/config 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x9c6bdb2f, L:/172.17.0.6:32850 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:25 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [43121: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN A) 2020-04-15 00:35:25 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [42577: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) 2020-04-15 00:35:25 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [42577: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 42577, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:35:25 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [43121: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 43121, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN A) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:35:25 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [41012: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN CNAME) 2020-04-15 00:35:25 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [41012: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 41012, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN CNAME) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:35:25 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [29959: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN A) 2020-04-15 00:35:25 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [26184: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN AAAA) 2020-04-15 00:35:25 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [29959: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 29959, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN A) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:35:25 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [26184: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 26184, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN AAAA) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:35:25 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [26390: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN CNAME) 2020-04-15 00:35:25 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [26390: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 26390, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.svc.cluster.local. IN CNAME) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x66e14715, L:/172.17.0.6:32852 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] WRITE: 194B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 63 6f 6e 6e 65 63 74 6f 72 73 2f |GET /connectors/| |00000010| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |00000020| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |00000030| 72 67 65 74 2e 4d 69 72 72 6f 72 43 68 65 63 6b |rget.MirrorCheck| |00000040| 70 6f 69 6e 74 43 6f 6e 6e 65 63 74 6f 72 2f 63 |pointConnector/c| |00000050| 6f 6e 66 69 67 20 48 54 54 50 2f 31 2e 31 0d 0a |onfig HTTP/1.1..| |00000060| 41 63 63 65 70 74 3a 20 61 70 70 6c 69 63 61 74 |Accept: applicat| |00000070| 69 6f 6e 2f 6a 73 6f 6e 0d 0a 68 6f 73 74 3a 20 |ion/json..host: | |00000080| 6d 79 2d 63 6c 75 73 74 65 72 2d 6d 69 72 72 6f |my-cluster-mirro| |00000090| 72 6d 61 6b 65 72 32 2d 61 70 69 2e 6d 69 72 72 |rmaker2-api.mirr| |000000a0| 6f 72 6d 61 6b 65 72 32 2d 63 6c 75 73 74 65 72 |ormaker2-cluster| |000000b0| 2d 74 65 73 74 2e 73 76 63 3a 38 30 38 33 0d 0a |-test.svc:8083..| |000000c0| 0d 0a |.. | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x66e14715, L:/172.17.0.6:32852 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x66e14715, L:/172.17.0.6:32852 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x4dd2f1b0, L:/172.17.0.6:32854 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] WRITE: 190B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 63 6f 6e 6e 65 63 74 6f 72 73 2f |GET /connectors/| |00000010| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |00000020| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |00000030| 72 67 65 74 2e 4d 69 72 72 6f 72 53 6f 75 72 63 |rget.MirrorSourc| |00000040| 65 43 6f 6e 6e 65 63 74 6f 72 2f 63 6f 6e 66 69 |eConnector/confi| |00000050| 67 20 48 54 54 50 2f 31 2e 31 0d 0a 41 63 63 65 |g HTTP/1.1..Acce| |00000060| 70 74 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pt: application/| |00000070| 6a 73 6f 6e 0d 0a 68 6f 73 74 3a 20 6d 79 2d 63 |json..host: my-c| |00000080| 6c 75 73 74 65 72 2d 6d 69 72 72 6f 72 6d 61 6b |luster-mirrormak| |00000090| 65 72 32 2d 61 70 69 2e 6d 69 72 72 6f 72 6d 61 |er2-api.mirrorma| |000000a0| 6b 65 72 32 2d 63 6c 75 73 74 65 72 2d 74 65 73 |ker2-cluster-tes| |000000b0| 74 2e 73 76 63 3a 38 30 38 33 0d 0a 0d 0a |t.svc:8083.... | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x4dd2f1b0, L:/172.17.0.6:32854 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x4dd2f1b0, L:/172.17.0.6:32854 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0xe70ef961, L:/172.17.0.6:32856 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] WRITE: 193B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 63 6f 6e 6e 65 63 74 6f 72 73 2f |GET /connectors/| |00000010| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |00000020| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |00000030| 72 67 65 74 2e 4d 69 72 72 6f 72 48 65 61 72 74 |rget.MirrorHeart| |00000040| 62 65 61 74 43 6f 6e 6e 65 63 74 6f 72 2f 63 6f |beatConnector/co| |00000050| 6e 66 69 67 20 48 54 54 50 2f 31 2e 31 0d 0a 41 |nfig HTTP/1.1..A| |00000060| 63 63 65 70 74 3a 20 61 70 70 6c 69 63 61 74 69 |ccept: applicati| |00000070| 6f 6e 2f 6a 73 6f 6e 0d 0a 68 6f 73 74 3a 20 6d |on/json..host: m| |00000080| 79 2d 63 6c 75 73 74 65 72 2d 6d 69 72 72 6f 72 |y-cluster-mirror| |00000090| 6d 61 6b 65 72 32 2d 61 70 69 2e 6d 69 72 72 6f |maker2-api.mirro| |000000a0| 72 6d 61 6b 65 72 32 2d 63 6c 75 73 74 65 72 2d |rmaker2-cluster-| |000000b0| 74 65 73 74 2e 73 76 63 3a 38 30 38 33 0d 0a 0d |test.svc:8083...| |000000c0| 0a |. | +--------+-------------------------------------------------+----------------+ 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0xe70ef961, L:/172.17.0.6:32856 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] FLUSH 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0xe70ef961, L:/172.17.0.6:32856 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] ACTIVE 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x4dd2f1b0, L:/172.17.0.6:32854 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 1024B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 48 54 54 50 2f 31 2e 31 20 32 30 30 20 4f 4b 0d |HTTP/1.1 200 OK.| |00000010| 0a 44 61 74 65 3a 20 57 65 64 2c 20 31 35 20 41 |.Date: Wed, 15 A| |00000020| 70 72 20 32 30 32 30 20 30 30 3a 33 35 3a 32 35 |pr 2020 00:35:25| |00000030| 20 47 4d 54 0d 0a 43 6f 6e 74 65 6e 74 2d 54 79 | GMT..Content-Ty| |00000040| 70 65 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pe: application/| |00000050| 6a 73 6f 6e 0d 0a 43 6f 6e 74 65 6e 74 2d 4c 65 |json..Content-Le| |00000060| 6e 67 74 68 3a 20 31 38 38 39 0d 0a 53 65 72 76 |ngth: 1889..Serv| |00000070| 65 72 3a 20 4a 65 74 74 79 28 39 2e 34 2e 32 30 |er: Jetty(9.4.20| |00000080| 2e 76 32 30 31 39 30 38 31 33 29 0d 0a 0d 0a 7b |.v20190813)....{| |00000090| 22 63 6f 6e 6e 65 63 74 6f 72 2e 63 6c 61 73 73 |"connector.class| |000000a0| 22 3a 22 6f 72 67 2e 61 70 61 63 68 65 2e 6b 61 |":"org.apache.ka| |000000b0| 66 6b 61 2e 63 6f 6e 6e 65 63 74 2e 6d 69 72 72 |fka.connect.mirr| |000000c0| 6f 72 2e 4d 69 72 72 6f 72 53 6f 75 72 63 65 43 |or.MirrorSourceC| |000000d0| 6f 6e 6e 65 63 74 6f 72 22 2c 22 72 65 70 6c 69 |onnector","repli| |000000e0| 63 61 74 69 6f 6e 2e 66 61 63 74 6f 72 22 3a 22 |cation.factor":"| |000000f0| 31 22 2c 22 73 6f 75 72 63 65 2e 63 6c 75 73 74 |1","source.clust| |00000100| 65 72 2e 73 73 6c 2e 74 72 75 73 74 73 74 6f 72 |er.ssl.truststor| |00000110| 65 2e 6c 6f 63 61 74 69 6f 6e 22 3a 22 2f 74 6d |e.location":"/tm| |00000120| 70 2f 6b 61 66 6b 61 2f 63 6c 75 73 74 65 72 73 |p/kafka/clusters| |00000130| 2f 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 |/my-cluster-sour| |00000140| 63 65 2e 74 72 75 73 74 73 74 6f 72 65 2e 70 31 |ce.truststore.p1| |00000150| 32 22 2c 22 74 61 72 67 65 74 2e 63 6c 75 73 74 |2","target.clust| |00000160| 65 72 2e 73 61 73 6c 2e 6a 61 61 73 2e 63 6f 6e |er.sasl.jaas.con| |00000170| 66 69 67 22 3a 22 6f 72 67 2e 61 70 61 63 68 65 |fig":"org.apache| |00000180| 2e 6b 61 66 6b 61 2e 63 6f 6d 6d 6f 6e 2e 73 65 |.kafka.common.se| |00000190| 63 75 72 69 74 79 2e 73 63 72 61 6d 2e 53 63 72 |curity.scram.Scr| |000001a0| 61 6d 4c 6f 67 69 6e 4d 6f 64 75 6c 65 20 72 65 |amLoginModule re| |000001b0| 71 75 69 72 65 64 20 75 73 65 72 6e 61 6d 65 3d |quired username=| |000001c0| 5c 22 6d 79 2d 75 73 65 72 2d 74 61 72 67 65 74 |\"my-user-target| |000001d0| 5c 22 20 70 61 73 73 77 6f 72 64 3d 5c 22 24 7b |\" password=\"${| |000001e0| 66 69 6c 65 3a 2f 74 6d 70 2f 73 74 72 69 6d 7a |file:/tmp/strimz| |000001f0| 69 2d 6d 69 72 72 6f 72 6d 61 6b 65 72 32 2d 63 |i-mirrormaker2-c| |00000200| 6f 6e 6e 65 63 74 6f 72 2e 70 72 6f 70 65 72 74 |onnector.propert| |00000210| 69 65 73 3a 6d 79 2d 63 6c 75 73 74 65 72 2d 74 |ies:my-cluster-t| |00000220| 61 72 67 65 74 2e 73 61 73 6c 2e 70 61 73 73 77 |arget.sasl.passw| |00000230| 6f 72 64 7d 5c 22 3b 22 2c 22 74 6f 70 69 63 73 |ord}\";","topics| |00000240| 2e 62 6c 61 63 6b 6c 69 73 74 22 3a 22 61 76 61 |.blacklist":"ava| |00000250| 69 6c 61 62 69 6c 69 74 79 2e 2a 22 2c 22 73 79 |ilability.*","sy| |00000260| 6e 63 2e 74 6f 70 69 63 2e 61 63 6c 73 2e 65 6e |nc.topic.acls.en| |00000270| 61 62 6c 65 64 22 3a 22 66 61 6c 73 65 22 2c 22 |abled":"false","| |00000280| 73 6f 75 72 63 65 2e 63 6c 75 73 74 65 72 2e 73 |source.cluster.s| |00000290| 73 6c 2e 74 72 75 73 74 73 74 6f 72 65 2e 74 79 |sl.truststore.ty| |000002a0| 70 65 22 3a 22 50 4b 43 53 31 32 22 2c 22 73 6f |pe":"PKCS12","so| |000002b0| 75 72 63 65 2e 63 6c 75 73 74 65 72 2e 61 6c 69 |urce.cluster.ali| |000002c0| 61 73 22 3a 22 6d 79 2d 63 6c 75 73 74 65 72 2d |as":"my-cluster-| |000002d0| 73 6f 75 72 63 65 22 2c 22 74 61 72 67 65 74 2e |source","target.| |000002e0| 63 6c 75 73 74 65 72 2e 73 73 6c 2e 74 72 75 73 |cluster.ssl.trus| |000002f0| 74 73 74 6f 72 65 2e 6c 6f 63 61 74 69 6f 6e 22 |tstore.location"| |00000300| 3a 22 2f 74 6d 70 2f 6b 61 66 6b 61 2f 63 6c 75 |:"/tmp/kafka/clu| |00000310| 73 74 65 72 73 2f 6d 79 2d 63 6c 75 73 74 65 72 |sters/my-cluster| |00000320| 2d 74 61 72 67 65 74 2e 74 72 75 73 74 73 74 6f |-target.truststo| |00000330| 72 65 2e 70 31 32 22 2c 22 74 61 72 67 65 74 2e |re.p12","target.| |00000340| 63 6c 75 73 74 65 72 2e 6f 66 66 73 65 74 2e 73 |cluster.offset.s| |00000350| 74 6f 72 61 67 65 2e 72 65 70 6c 69 63 61 74 69 |torage.replicati| |00000360| 6f 6e 2e 66 61 63 74 6f 72 22 3a 22 31 22 2c 22 |on.factor":"1","| |00000370| 74 61 72 67 65 74 2e 63 6c 75 73 74 65 72 2e 73 |target.cluster.s| |00000380| 73 6c 2e 74 72 75 73 74 73 74 6f 72 65 2e 74 79 |sl.truststore.ty| |00000390| 70 65 22 3a 22 50 4b 43 53 31 32 22 2c 22 74 61 |pe":"PKCS12","ta| |000003a0| 72 67 65 74 2e 63 6c 75 73 74 65 72 2e 73 65 63 |rget.cluster.sec| |000003b0| 75 72 69 74 79 2e 70 72 6f 74 6f 63 6f 6c 22 3a |urity.protocol":| |000003c0| 22 53 41 53 4c 5f 53 53 4c 22 2c 22 74 61 72 67 |"SASL_SSL","targ| |000003d0| 65 74 2e 63 6c 75 73 74 65 72 2e 73 74 61 74 75 |et.cluster.statu| |000003e0| 73 2e 73 74 6f 72 61 67 65 2e 72 65 70 6c 69 63 |s.storage.replic| |000003f0| 61 74 69 6f 6e 2e 66 61 63 74 6f 72 22 3a 22 31 |ation.factor":"1| +--------+-------------------------------------------------+----------------+ 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x4dd2f1b0, L:/172.17.0.6:32854 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 1008B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 22 2c 22 6f 66 66 73 65 74 2d 73 79 6e 63 73 2e |","offset-syncs.| |00000010| 74 6f 70 69 63 2e 72 65 70 6c 69 63 61 74 69 6f |topic.replicatio| |00000020| 6e 2e 66 61 63 74 6f 72 22 3a 22 31 22 2c 22 74 |n.factor":"1","t| |00000030| 61 72 67 65 74 2e 63 6c 75 73 74 65 72 2e 73 61 |arget.cluster.sa| |00000040| 73 6c 2e 6d 65 63 68 61 6e 69 73 6d 22 3a 22 53 |sl.mechanism":"S| |00000050| 43 52 41 4d 2d 53 48 41 2d 35 31 32 22 2c 22 74 |CRAM-SHA-512","t| |00000060| 6f 70 69 63 73 22 3a 22 2e 2a 22 2c 22 74 61 72 |opics":".*","tar| |00000070| 67 65 74 2e 63 6c 75 73 74 65 72 2e 63 6f 6e 66 |get.cluster.conf| |00000080| 69 67 2e 73 74 6f 72 61 67 65 2e 72 65 70 6c 69 |ig.storage.repli| |00000090| 63 61 74 69 6f 6e 2e 66 61 63 74 6f 72 22 3a 22 |cation.factor":"| |000000a0| 31 22 2c 22 67 72 6f 75 70 73 22 3a 22 2e 2a 22 |1","groups":".*"| |000000b0| 2c 22 74 61 72 67 65 74 2e 63 6c 75 73 74 65 72 |,"target.cluster| |000000c0| 2e 73 73 6c 2e 74 72 75 73 74 73 74 6f 72 65 2e |.ssl.truststore.| |000000d0| 70 61 73 73 77 6f 72 64 22 3a 22 24 7b 66 69 6c |password":"${fil| |000000e0| 65 3a 2f 74 6d 70 2f 73 74 72 69 6d 7a 69 2d 6d |e:/tmp/strimzi-m| |000000f0| 69 72 72 6f 72 6d 61 6b 65 72 32 2d 63 6f 6e 6e |irrormaker2-conn| |00000100| 65 63 74 6f 72 2e 70 72 6f 70 65 72 74 69 65 73 |ector.properties| |00000110| 3a 73 73 6c 2e 74 72 75 73 74 73 74 6f 72 65 2e |:ssl.truststore.| |00000120| 70 61 73 73 77 6f 72 64 7d 22 2c 22 73 6f 75 72 |password}","sour| |00000130| 63 65 2e 63 6c 75 73 74 65 72 2e 73 61 73 6c 2e |ce.cluster.sasl.| |00000140| 6a 61 61 73 2e 63 6f 6e 66 69 67 22 3a 22 6f 72 |jaas.config":"or| |00000150| 67 2e 61 70 61 63 68 65 2e 6b 61 66 6b 61 2e 63 |g.apache.kafka.c| |00000160| 6f 6d 6d 6f 6e 2e 73 65 63 75 72 69 74 79 2e 73 |ommon.security.s| |00000170| 63 72 61 6d 2e 53 63 72 61 6d 4c 6f 67 69 6e 4d |cram.ScramLoginM| |00000180| 6f 64 75 6c 65 20 72 65 71 75 69 72 65 64 20 75 |odule required u| |00000190| 73 65 72 6e 61 6d 65 3d 5c 22 6d 79 2d 75 73 65 |sername=\"my-use| |000001a0| 72 2d 73 6f 75 72 63 65 5c 22 20 70 61 73 73 77 |r-source\" passw| |000001b0| 6f 72 64 3d 5c 22 24 7b 66 69 6c 65 3a 2f 74 6d |ord=\"${file:/tm| |000001c0| 70 2f 73 74 72 69 6d 7a 69 2d 6d 69 72 72 6f 72 |p/strimzi-mirror| |000001d0| 6d 61 6b 65 72 32 2d 63 6f 6e 6e 65 63 74 6f 72 |maker2-connector| |000001e0| 2e 70 72 6f 70 65 72 74 69 65 73 3a 6d 79 2d 63 |.properties:my-c| |000001f0| 6c 75 73 74 65 72 2d 73 6f 75 72 63 65 2e 73 61 |luster-source.sa| |00000200| 73 6c 2e 70 61 73 73 77 6f 72 64 7d 5c 22 3b 22 |sl.password}\";"| |00000210| 2c 22 73 6f 75 72 63 65 2e 63 6c 75 73 74 65 72 |,"source.cluster| |00000220| 2e 62 6f 6f 74 73 74 72 61 70 2e 73 65 72 76 65 |.bootstrap.serve| |00000230| 72 73 22 3a 22 6d 79 2d 63 6c 75 73 74 65 72 2d |rs":"my-cluster-| |00000240| 73 6f 75 72 63 65 2d 6b 61 66 6b 61 2d 62 6f 6f |source-kafka-boo| |00000250| 74 73 74 72 61 70 3a 39 30 39 33 22 2c 22 73 6f |tstrap:9093","so| |00000260| 75 72 63 65 2e 63 6c 75 73 74 65 72 2e 73 61 73 |urce.cluster.sas| |00000270| 6c 2e 6d 65 63 68 61 6e 69 73 6d 22 3a 22 53 43 |l.mechanism":"SC| |00000280| 52 41 4d 2d 53 48 41 2d 35 31 32 22 2c 22 74 61 |RAM-SHA-512","ta| |00000290| 72 67 65 74 2e 63 6c 75 73 74 65 72 2e 61 6c 69 |rget.cluster.ali| |000002a0| 61 73 22 3a 22 6d 79 2d 63 6c 75 73 74 65 72 2d |as":"my-cluster-| |000002b0| 74 61 72 67 65 74 22 2c 22 6e 61 6d 65 22 3a 22 |target","name":"| |000002c0| 6d 79 2d 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 |my-cluster-sourc| |000002d0| 65 2d 3e 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 |e->my-cluster-ta| |000002e0| 72 67 65 74 2e 4d 69 72 72 6f 72 53 6f 75 72 63 |rget.MirrorSourc| |000002f0| 65 43 6f 6e 6e 65 63 74 6f 72 22 2c 22 74 61 72 |eConnector","tar| |00000300| 67 65 74 2e 63 6c 75 73 74 65 72 2e 62 6f 6f 74 |get.cluster.boot| |00000310| 73 74 72 61 70 2e 73 65 72 76 65 72 73 22 3a 22 |strap.servers":"| |00000320| 6d 79 2d 63 6c 75 73 74 65 72 2d 74 61 72 67 65 |my-cluster-targe| |00000330| 74 2d 6b 61 66 6b 61 2d 62 6f 6f 74 73 74 72 61 |t-kafka-bootstra| |00000340| 70 3a 39 30 39 33 22 2c 22 73 6f 75 72 63 65 2e |p:9093","source.| |00000350| 63 6c 75 73 74 65 72 2e 73 73 6c 2e 74 72 75 73 |cluster.ssl.trus| |00000360| 74 73 74 6f 72 65 2e 70 61 73 73 77 6f 72 64 22 |tstore.password"| |00000370| 3a 22 24 7b 66 69 6c 65 3a 2f 74 6d 70 2f 73 74 |:"${file:/tmp/st| |00000380| 72 69 6d 7a 69 2d 6d 69 72 72 6f 72 6d 61 6b 65 |rimzi-mirrormake| |00000390| 72 32 2d 63 6f 6e 6e 65 63 74 6f 72 2e 70 72 6f |r2-connector.pro| |000003a0| 70 65 72 74 69 65 73 3a 73 73 6c 2e 74 72 75 73 |perties:ssl.trus| |000003b0| 74 73 74 6f 72 65 2e 70 61 73 73 77 6f 72 64 7d |tstore.password}| |000003c0| 22 2c 22 73 6f 75 72 63 65 2e 63 6c 75 73 74 65 |","source.cluste| |000003d0| 72 2e 73 65 63 75 72 69 74 79 2e 70 72 6f 74 6f |r.security.proto| |000003e0| 63 6f 6c 22 3a 22 53 41 53 4c 5f 53 53 4c 22 7d |col":"SASL_SSL"}| +--------+-------------------------------------------------+----------------+ 2020-04-15 00:35:25 DEBUG KafkaConnectApiImpl:246 - Got 200 response to GET request to /connectors/my-cluster-source->my-cluster-target.MirrorSourceConnector/config: {connector.class=org.apache.kafka.connect.mirror.MirrorSourceConnector, replication.factor=1, source.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-source.truststore.p12, target.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-target" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}";, topics.blacklist=availability.*, sync.topic.acls.enabled=false, source.cluster.ssl.truststore.type=PKCS12, source.cluster.alias=my-cluster-source, target.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-target.truststore.p12, target.cluster.offset.storage.replication.factor=1, target.cluster.ssl.truststore.type=PKCS12, target.cluster.security.protocol=SASL_SSL, target.cluster.status.storage.replication.factor=1, offset-syncs.topic.replication.factor=1, target.cluster.sasl.mechanism=SCRAM-SHA-512, topics=.*, target.cluster.config.storage.replication.factor=1, groups=.*, target.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, source.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-source" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}";, source.cluster.bootstrap.servers=my-cluster-source-kafka-bootstrap:9093, source.cluster.sasl.mechanism=SCRAM-SHA-512, target.cluster.alias=my-cluster-target, name=my-cluster-source->my-cluster-target.MirrorSourceConnector, target.cluster.bootstrap.servers=my-cluster-target-kafka-bootstrap:9093, source.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, source.cluster.security.protocol=SASL_SSL} 2020-04-15 00:35:25 DEBUG AbstractConnectOperator:457 - Reconciliation #84(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Desired: {connector.class=org.apache.kafka.connect.mirror.MirrorSourceConnector, groups=.*, name=my-cluster-source->my-cluster-target.MirrorSourceConnector, offset-syncs.topic.replication.factor=1, replication.factor=1, source.cluster.alias=my-cluster-source, source.cluster.bootstrap.servers=my-cluster-source-kafka-bootstrap:9093, source.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-source" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}";, source.cluster.sasl.mechanism=SCRAM-SHA-512, source.cluster.security.protocol=SASL_SSL, source.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-source.truststore.p12, source.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, source.cluster.ssl.truststore.type=PKCS12, sync.topic.acls.enabled=false, target.cluster.alias=my-cluster-target, target.cluster.bootstrap.servers=my-cluster-target-kafka-bootstrap:9093, target.cluster.config.storage.replication.factor=1, target.cluster.offset.storage.replication.factor=1, target.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-target" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}";, target.cluster.sasl.mechanism=SCRAM-SHA-512, target.cluster.security.protocol=SASL_SSL, target.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-target.truststore.p12, target.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, target.cluster.ssl.truststore.type=PKCS12, target.cluster.status.storage.replication.factor=1, topics=.*, topics.blacklist=availability.*} 2020-04-15 00:35:25 DEBUG AbstractConnectOperator:458 - Reconciliation #84(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Actual: {connector.class=org.apache.kafka.connect.mirror.MirrorSourceConnector, groups=.*, name=my-cluster-source->my-cluster-target.MirrorSourceConnector, offset-syncs.topic.replication.factor=1, replication.factor=1, source.cluster.alias=my-cluster-source, source.cluster.bootstrap.servers=my-cluster-source-kafka-bootstrap:9093, source.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-source" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}";, source.cluster.sasl.mechanism=SCRAM-SHA-512, source.cluster.security.protocol=SASL_SSL, source.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-source.truststore.p12, source.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, source.cluster.ssl.truststore.type=PKCS12, sync.topic.acls.enabled=false, target.cluster.alias=my-cluster-target, target.cluster.bootstrap.servers=my-cluster-target-kafka-bootstrap:9093, target.cluster.config.storage.replication.factor=1, target.cluster.offset.storage.replication.factor=1, target.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-target" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}";, target.cluster.sasl.mechanism=SCRAM-SHA-512, target.cluster.security.protocol=SASL_SSL, target.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-target.truststore.p12, target.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, target.cluster.ssl.truststore.type=PKCS12, target.cluster.status.storage.replication.factor=1, topics=.*, topics.blacklist=availability.*} 2020-04-15 00:35:25 DEBUG AbstractConnectOperator:421 - Reconciliation #84(watch) KafkaMirrorMaker2(mirrormaker2-cluster-test/my-cluster): Connector my-cluster-source->my-cluster-target.MirrorSourceConnector exists and has desired config, {offset-syncs.topic.replication.factor=1, replication.factor=1, sync.topic.acls.enabled=false, target.cluster.alias=my-cluster-target, target.cluster.bootstrap.servers=my-cluster-target-kafka-bootstrap:9093, target.cluster.ssl.truststore.type=PKCS12, target.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-target.truststore.p12, target.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, target.cluster.sasl.mechanism=SCRAM-SHA-512, target.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-target" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}";, target.cluster.security.protocol=SASL_SSL, target.cluster.status.storage.replication.factor=1, target.cluster.offset.storage.replication.factor=1, target.cluster.config.storage.replication.factor=1, source.cluster.alias=my-cluster-source, source.cluster.bootstrap.servers=my-cluster-source-kafka-bootstrap:9093, source.cluster.ssl.truststore.type=PKCS12, source.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-source.truststore.p12, source.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, source.cluster.sasl.mechanism=SCRAM-SHA-512, source.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-source" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}";, source.cluster.security.protocol=SASL_SSL, topics=.*, topics.blacklist=availability.*, groups=.*}=={connector.class=org.apache.kafka.connect.mirror.MirrorSourceConnector, replication.factor=1, source.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-source.truststore.p12, target.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-target" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-target.sasl.password}";, topics.blacklist=availability.*, sync.topic.acls.enabled=false, source.cluster.ssl.truststore.type=PKCS12, source.cluster.alias=my-cluster-source, target.cluster.ssl.truststore.location=/tmp/kafka/clusters/my-cluster-target.truststore.p12, target.cluster.offset.storage.replication.factor=1, target.cluster.ssl.truststore.type=PKCS12, target.cluster.security.protocol=SASL_SSL, target.cluster.status.storage.replication.factor=1, offset-syncs.topic.replication.factor=1, target.cluster.sasl.mechanism=SCRAM-SHA-512, topics=.*, target.cluster.config.storage.replication.factor=1, groups=.*, target.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, source.cluster.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="my-user-source" password="${file:/tmp/strimzi-mirrormaker2-connector.properties:my-cluster-source.sasl.password}";, source.cluster.bootstrap.servers=my-cluster-source-kafka-bootstrap:9093, source.cluster.sasl.mechanism=SCRAM-SHA-512, target.cluster.alias=my-cluster-target, name=my-cluster-source->my-cluster-target.MirrorSourceConnector, target.cluster.bootstrap.servers=my-cluster-target-kafka-bootstrap:9093, source.cluster.ssl.truststore.password=${file:/tmp/strimzi-mirrormaker2-connector.properties:ssl.truststore.password}, source.cluster.security.protocol=SASL_SSL} 2020-04-15 00:35:25 DEBUG KafkaConnectApiImpl:235 - Making GET request to /connectors/my-cluster-source->my-cluster-target.MirrorSourceConnector/status 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0x4dd2f1b0, L:/172.17.0.6:32854 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:25 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [37488: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN A) 2020-04-15 00:35:25 DEBUG DnsQueryContext:117 - [id: 0x8aa21bf0] WRITE: UDP, [63187: /172.30.0.2:53], DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) 2020-04-15 00:35:25 DEBUG DnsNameResolver:1205 - [id: 0x8aa21bf0] RECEIVED: UDP [63187: /172.30.0.2:53], DatagramDnsResponse(from: /172.30.0.2:53, to: /0:0:0:0:0:0:0:0:35177, 63187, QUERY(0), NXDomain(3), RD) DefaultDnsQuestion(my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.mirrormaker2-cluster-test.svc.cluster.local. IN AAAA) DefaultDnsRawRecord(cluster.local. 60 IN SOA 68B) 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0xe70ef961, L:/172.17.0.6:32856 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 1024B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 48 54 54 50 2f 31 2e 31 20 32 30 30 20 4f 4b 0d |HTTP/1.1 200 OK.| |00000010| 0a 44 61 74 65 3a 20 57 65 64 2c 20 31 35 20 41 |.Date: Wed, 15 A| |00000020| 70 72 20 32 30 32 30 20 30 30 3a 33 35 3a 32 35 |pr 2020 00:35:25| |00000030| 20 47 4d 54 0d 0a 43 6f 6e 74 65 6e 74 2d 54 79 | GMT..Content-Ty| |00000040| 70 65 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f |pe: application/| |00000050| 6a 73 6f 6e 0d 0a 43 6f 6e 74 65 6e 74 2d 4c 65 |json..Content-Le| |00000060| 6e 67 74 68 3a 20 31 38 33 34 0d 0a 53 65 72 76 |ngth: 1834..Serv| |00000070| 65 72 3a 20 4a 65 74 74 79 28 39 2e 34 2e 32 30 |er: Jetty(9.4.20| |00000080| 2e 76 32 30 31 39 30 38 31 33 29 0d 0a 0d 0a 7b |.v20190813)....{| |00000090| 22 63 6f 6e 6e 65 63 74 6f 72 2e 63 6c 61 73 73 |"connector.class| |000000a0| 22 3a 22 6f 72 67 2e 61 70 61 63 68 65 2e 6b 61 |":"org.apache.ka| |000000b0| 66 6b 61 2e 63 6f 6e 6e 65 63 74 2e 6d 69 72 72 |fka.connect.mirr| |000000c0| 6f 72 2e 4d 69 72 72 6f 72 48 65 61 72 74 62 65 |or.MirrorHeartbe| |000000d0| 61 74 43 6f 6e 6e 65 63 74 6f 72 22 2c 22 73 6f |atConnector","so| |000000e0| 75 72 63 65 2e 63 6c 75 73 74 65 72 2e 73 73 6c |urce.cluster.ssl| |000000f0| 2e 74 72 75 73 74 73 74 6f 72 65 2e 6c 6f 63 61 |.truststore.loca| |00000100| 74 69 6f 6e 22 3a 22 2f 74 6d 70 2f 6b 61 66 6b |tion":"/tmp/kafk| |00000110| 61 2f 63 6c 75 73 74 65 72 73 2f 6d 79 2d 63 6c |a/clusters/my-cl| |00000120| 75 73 74 65 72 2d 73 6f 75 72 63 65 2e 74 72 75 |uster-source.tru| |00000130| 73 74 73 74 6f 72 65 2e 70 31 32 22 2c 22 74 61 |ststore.p12","ta| |00000140| 72 67 65 74 2e 63 6c 75 73 74 65 72 2e 73 61 73 |rget.cluster.sas| |00000150| 6c 2e 6a 61 61 73 2e 63 6f 6e 66 69 67 22 3a 22 |l.jaas.config":"| |00000160| 6f 72 67 2e 61 70 61 63 68 65 2e 6b 61 66 6b 61 |org.apache.kafka| |00000170| 2e 63 6f 6d 6d 6f 6e 2e 73 65 63 75 72 69 74 79 |.common.security| |00000180| 2e 73 63 72 61 6d 2e 53 63 72 61 6d 4c 6f 67 69 |.scram.ScramLogi| |00000190| 6e 4d 6f 64 75 6c 65 20 72 65 71 75 69 72 65 64 |nModule required| |000001a0| 20 75 73 65 72 6e 61 6d 65 3d 5c 22 6d 79 2d 75 | username=\"my-u| |000001b0| 73 65 72 2d 74 61 72 67 65 74 5c 22 20 70 61 73 |ser-target\" pas| |000001c0| 73 77 6f 72 64 3d 5c 22 24 7b 66 69 6c 65 3a 2f |sword=\"${file:/| |000001d0| 74 6d 70 2f 73 74 72 69 6d 7a 69 2d 6d 69 72 72 |tmp/strimzi-mirr| |000001e0| 6f 72 6d 61 6b 65 72 32 2d 63 6f 6e 6e 65 63 74 |ormaker2-connect| |000001f0| 6f 72 2e 70 72 6f 70 65 72 74 69 65 73 3a 6d 79 |or.properties:my| |00000200| 2d 63 6c 75 73 74 65 72 2d 74 61 72 67 65 74 2e |-cluster-target.| |00000210| 73 61 73 6c 2e 70 61 73 73 77 6f 72 64 7d 5c 22 |sasl.password}\"| |00000220| 3b 22 2c 22 74 6f 70 69 63 73 2e 62 6c 61 63 6b |;","topics.black| |00000230| 6c 69 73 74 22 3a 22 61 76 61 69 6c 61 62 69 6c |list":"availabil| |00000240| 69 74 79 2e 2a 22 2c 22 73 6f 75 72 63 65 2e 63 |ity.*","source.c| |00000250| 6c 75 73 74 65 72 2e 73 73 6c 2e 74 72 75 73 74 |luster.ssl.trust| |00000260| 73 74 6f 72 65 2e 74 79 70 65 22 3a 22 50 4b 43 |store.type":"PKC| |00000270| 53 31 32 22 2c 22 73 6f 75 72 63 65 2e 63 6c 75 |S12","source.clu| |00000280| 73 74 65 72 2e 61 6c 69 61 73 22 3a 22 6d 79 2d |ster.alias":"my-| |00000290| 63 6c 75 73 74 65 72 2d 73 6f 75 72 63 65 22 2c |cluster-source",| |000002a0| 22 74 61 72 67 65 74 2e 63 6c 75 73 74 65 72 2e |"target.cluster.| |000002b0| 73 73 6c 2e 74 72 75 73 74 73 74 6f 72 65 2e 6c |ssl.truststore.l| |000002c0| 6f 63 61 74 69 6f 6e 22 3a 22 2f 74 6d 70 2f 6b |ocation":"/tmp/k| |000002d0| 61 66 6b 61 2f 63 6c 75 73 74 65 72 73 2f 6d 79 |afka/clusters/my| |000002e0| 2d 63 6c 75 73 74 65 72 2d 74 61 72 67 65 74 2e |-cluster-target.| |000002f0| 74 72 75 73 74 73 74 6f 72 65 2e 70 31 32 22 2c |truststore.p12",| |00000300| 22 74 61 72 67 65 74 2e 63 6c 75 73 74 65 72 2e |"target.cluster.| |00000310| 6f 66 66 73 65 74 2e 73 74 6f 72 61 67 65 2e 72 |offset.storage.r| |00000320| 65 70 6c 69 63 61 74 69 6f 6e 2e 66 61 63 74 6f |eplication.facto| |00000330| 72 22 3a 22 31 22 2c 22 74 61 72 67 65 74 2e 63 |r":"1","target.c| |00000340| 6c 75 73 74 65 72 2e 73 73 6c 2e 74 72 75 73 74 |luster.ssl.trust| |00000350| 73 74 6f 72 65 2e 74 79 70 65 22 3a 22 50 4b 43 |store.type":"PKC| |00000360| 53 31 32 22 2c 22 74 61 72 67 65 74 2e 63 6c 75 |S12","target.clu| |00000370| 73 74 65 72 2e 73 65 63 75 72 69 74 79 2e 70 72 |ster.security.pr| |00000380| 6f 74 6f 63 6f 6c 22 3a 22 53 41 53 4c 5f 53 53 |otocol":"SASL_SS| |00000390| 4c 22 2c 22 74 61 72 67 65 74 2e 63 6c 75 73 74 |L","target.clust| |000003a0| 65 72 2e 73 74 61 74 75 73 2e 73 74 6f 72 61 67 |er.status.storag| |000003b0| 65 2e 72 65 70 6c 69 63 61 74 69 6f 6e 2e 66 61 |e.replication.fa| |000003c0| 63 74 6f 72 22 3a 22 31 22 2c 22 74 61 72 67 65 |ctor":"1","targe| |000003d0| 74 2e 63 6c 75 73 74 65 72 2e 73 61 73 6c 2e 6d |t.cluster.sasl.m| |000003e0| 65 63 68 61 6e 69 73 6d 22 3a 22 53 43 52 41 4d |echanism":"SCRAM| |000003f0| 2d 53 48 41 2d 35 31 32 22 2c 22 74 6f 70 69 63 |-SHA-512","topic| +--------+-------------------------------------------------+----------------+ 2020-04-15 00:35:25 DEBUG LoggingHandler:145 - [id: 0xe70ef961, L:/172.17.0.6:32856 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ: 953B +-------------------------------------------------+ | 0 1 2 3 4 5 6 7 8 9 a b c d e f | +--------+-------------------------------------------------+----------------+ |00000000| 73 22 3a 22 2e 2a 22 2c 22 68 65 61 72 74 62 65 |s":".*","heartbe| |00000010| 61 74 73 2e 74 6f 70 69 63 2e 72 65 70 6c 69 63 |ats.topic.replic| |00000020| 61 74 69 6f 6e 2e 66 61 63 74 6f 72 22 3a 22 31 |ation.factor":"1| |00000030| 22 2c 22 74 61 72 67 65 74 2e 63 6c 75 73 74 65 |","target.cluste| |00000040| 72 2e 63 6f 6e 66 69 67 2e 73 74 6f 72 61 67 65 |r.config.storage| |00000050| 2e 72 65 70 6c 69 63 61 74 69 6f 6e 2e 66 61 63 |.replication.fac| |00000060| 74 6f 72 22 3a 22 31 22 2c 22 67 72 6f 75 70 73 |tor":"1","groups| |00000070| 22 3a 22 2e 2a 22 2c 22 74 61 72 67 65 74 2e 63 |":".*","target.c| |00000080| 6c 75 73 74 65 72 2e 73 73 6c 2e 74 72 75 73 74 |luster.ssl.trust| |00000090| 73 74 6f 72 65 2e 70 61 73 73 77 6f 72 64 22 3a |store.password":| |000000a0| 22 24 7b 66 69 6c 65 3a 2f 74 6d 70 2f 73 74 72 |"${file:/tmp/str| |000000b0| 69 6d 7a 69 2d 6d 69 72 72 6f 72 6d 61 6b 65 72 |imzi-mirrormaker| |000000c0| 32 2d 63 6f 6e 6e 65 63 74 6f 72 2e 70 72 6f 70 |2-connector.prop| |000000d0| 65 72 74 69 65 73 3a 73 73 6c 2e 74 72 75 73 74 |erties:ssl.trust| |000000e0| 73 74 6f 72 65 2e 70 61 73 73 77 6f 72 64 7d 22 |store.password}"| |000000f0| 2c 22 73 6f 75 72 63 65 2e 63 6c 75 73 74 65 72 |,"source.cluster| |00000100| 2e 73 61 73 6c 2e 6a 61 61 73 2e 63 6f 6e 66 69 |.sasl.jaas.confi| |00000110| 67 22 3a 22 6f 72 67 2e 61 70 61 63 68 65 2e 6b |g":"org.apache.k| |00000120| 61 66 6b 61 2e 63 6f 6d 6d 6f 6e 2e 73 65 63 75 |afka.common.secu| |00000130| 72 69 74 79 2e 73 63 72 61 6d 2e 53 63 72 61 6d |rity.scram.Scram| |00000140| 4c 6f 67 69 6e 4d 6f 64 75 6c 65 20 72 65 71 75 |LoginModule requ| |00000150| 69 72 65 64 20 75 73 65 72 6e 61 6d 65 3d 5c 22 |ired username=\"| |00000160| 6d 79 2d 75 73 65 72 2d 73 6f 75 72 63 65 5c 22 |my-user-source\"| |00000170| 20 70 61 73 73 77 6f 72 64 3d 5c 22 24 7b 66 69 | password=\"${fi| |00000180| 6c 65 3a 2f 74 6d 70 2f 73 74 72 69 6d 7a 69 2d |le:/tmp/strimzi-| |00000190| 6d 69 72 72 6f 72 6d 61 6b 65 72 32 2d 63 6f 6e |mirrormaker2-con| |000001a0| 6e 65 63 74 6f 72 2e 70 72 6f 70 65 72 74 69 65 |nector.propertie| 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x9c6bdb2f, L:/172.17.0.6:32850 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x9c6bdb2f, L:/172.17.0.6:32850 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x9c6bdb2f, L:/172.17.0.6:32850 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x4dd2f1b0, L:/172.17.0.6:32854 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x4dd2f1b0, L:/172.17.0.6:32854 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x4dd2f1b0, L:/172.17.0.6:32854 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x66e14715, L:/172.17.0.6:32852 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x66e14715, L:/172.17.0.6:32852 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x66e14715, L:/172.17.0.6:32852 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0xe70ef961, L:/172.17.0.6:32856 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0xe70ef961, L:/172.17.0.6:32856 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0xe70ef961, L:/172.17.0.6:32856 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x95f4e36c, L:/172.17.0.6:32858 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x95f4e36c, L:/172.17.0.6:32858 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x95f4e36c, L:/172.17.0.6:32858 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0xabe75a90, L:/172.17.0.6:32860 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0xabe75a90, L:/172.17.0.6:32860 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0xabe75a90, L:/172.17.0.6:32860 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x6521c9b3, L:/172.17.0.6:32862 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x6521c9b3, L:/172.17.0.6:32862 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x6521c9b3, L:/172.17.0.6:32862 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x151408fc, L:/172.17.0.6:32864 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x151408fc, L:/172.17.0.6:32864 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x151408fc, L:/172.17.0.6:32864 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x2a496fef, L:/172.17.0.6:32866 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x2a496fef, L:/172.17.0.6:32866 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x2a496fef, L:/172.17.0.6:32866 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0xe75694c3, L:/172.17.0.6:32868 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0xe75694c3, L:/172.17.0.6:32868 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0xe75694c3, L:/172.17.0.6:32868 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x3769a0d5, L:/172.17.0.6:32870 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x3769a0d5, L:/172.17.0.6:32870 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x3769a0d5, L:/172.17.0.6:32870 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x47de6603, L:/172.17.0.6:32872 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x47de6603, L:/172.17.0.6:32872 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x47de6603, L:/172.17.0.6:32872 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0xb65dbaff, L:/172.17.0.6:32876 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0xb65dbaff, L:/172.17.0.6:32876 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0xb65dbaff, L:/172.17.0.6:32876 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x09cb742a, L:/172.17.0.6:32874 - R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] READ COMPLETE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x09cb742a, L:/172.17.0.6:32874 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] INACTIVE 2020-04-15 00:35:55 DEBUG LoggingHandler:145 - [id: 0x09cb742a, L:/172.17.0.6:32874 ! R:my-cluster-mirrormaker2-api.mirrormaker2-cluster-test.svc.cluster.local/172.30.235.227:8083] UNREGISTERED