[2020-04-07 07:25:15,371] INFO Kafka MirrorMaker initializing ... (org.apache.kafka.connect.mirror.MirrorMaker:287) [2020-04-07 07:25:15,393] INFO MirrorMakerConfig values: clusters = [m1-source, m1-backup] config.providers = [] sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.connect.mirror.MirrorMakerConfig:347) [2020-04-07 07:25:17,520] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-04-07 07:25:17,521] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,521] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,521] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,521] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,521] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,521] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,522] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,522] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,522] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,522] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,522] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,522] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,522] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,523] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,523] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,523] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,523] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,523] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,523] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,523] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,523] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,524] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,524] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,524] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,524] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,524] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,524] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,524] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,524] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,524] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,524] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,524] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,524] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,524] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,525] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,525] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,525] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,525] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,525] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,525] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,525] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,525] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,525] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,525] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,525] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,525] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:17,526] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,526] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,527] INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,527] INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,527] INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,527] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,527] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,527] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,527] INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,528] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,528] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,528] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,528] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,528] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,528] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,528] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,528] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,529] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,529] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,529] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,529] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,529] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,529] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,529] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,529] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,530] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,530] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:17,530] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,530] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:17,530] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:17,531] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:17,531] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:17,531] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,531] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,531] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:17,531] INFO Targeting clusters [m1-source, m1-backup] (org.apache.kafka.connect.mirror.MirrorMaker:129) [2020-04-07 07:25:17,533] INFO creating herder for m1-source->m1-backup (org.apache.kafka.connect.mirror.MirrorMaker:228) [2020-04-07 07:25:18,581] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-04-07 07:25:18,581] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,581] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,582] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,583] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,583] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,583] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,583] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,586] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,586] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,586] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,586] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,586] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,586] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,587] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,587] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,587] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,587] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,587] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,587] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,587] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,587] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,587] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,587] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,587] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,587] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,587] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,587] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,588] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,588] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,588] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,588] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,588] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:18,588] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,588] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,588] INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,588] INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,588] INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,589] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,589] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,589] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,589] INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,589] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,589] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,589] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,589] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,589] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,589] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,589] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,589] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,590] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,590] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,590] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,590] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,590] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,590] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,590] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,590] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,590] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,590] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:18,590] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,591] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:18,591] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:18,591] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:18,591] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:18,591] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,591] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,591] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:18,614] INFO DistributedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null bootstrap.servers = [172.17.165.52:9999] client.dns.lookup = default client.id = config.providers = [] config.storage.replication.factor = 3 config.storage.topic = mm2-configs.m1-source.internal connect.protocol = sessioned connections.max.idle.ms = 540000 connector.client.config.override.policy = None group.id = m1-source-mm2 header.converter = class org.apache.kafka.connect.converters.ByteArrayConverter heartbeat.interval.ms = 3000 inter.worker.key.generation.algorithm = HmacSHA256 inter.worker.key.size = null inter.worker.key.ttl.ms = 3600000 inter.worker.signature.algorithm = HmacSHA256 inter.worker.verification.algorithms = [HmacSHA256] internal.key.converter = class org.apache.kafka.connect.json.JsonConverter internal.value.converter = class org.apache.kafka.connect.json.JsonConverter key.converter = class org.apache.kafka.connect.converters.ByteArrayConverter listeners = null metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 60000 offset.flush.timeout.ms = 5000 offset.storage.partitions = 25 offset.storage.replication.factor = 3 offset.storage.topic = mm2-offsets.m1-source.internal plugin.path = null rebalance.timeout.ms = 60000 receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 40000 rest.advertised.host.name = null rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] rest.host.name = null rest.port = 8083 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI scheduled.rebalance.max.delay.ms = 300000 security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS status.storage.partitions = 5 status.storage.replication.factor = 3 status.storage.topic = mm2-status.m1-source.internal task.shutdown.graceful.timeout.ms = 5000 value.converter = class org.apache.kafka.connect.converters.ByteArrayConverter worker.sync.timeout.ms = 3000 worker.unsync.backoff.ms = 300000 (org.apache.kafka.connect.runtime.distributed.DistributedConfig:347) [2020-04-07 07:25:18,615] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43) [2020-04-07 07:25:18,617] INFO AdminClientConfig values: bootstrap.servers = [172.17.165.52:9999] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-04-07 07:25:18,653] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:18,653] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:18,653] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:18,653] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:18,653] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:18,653] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:18,653] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:18,653] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:18,653] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:18,653] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:18,653] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:18,654] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:18,654] INFO Kafka startTimeMs: 1586233518653 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:18,883] INFO Kafka cluster ID: hZ1nvm4RTMqkKmR8dbzX5w (org.apache.kafka.connect.util.ConnectUtils:59) [2020-04-07 07:25:18,900] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:18,900] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:18,900] INFO Kafka startTimeMs: 1586233518899 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:18,998] INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:347) [2020-04-07 07:25:18,999] INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:347) [2020-04-07 07:25:19,030] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:19,031] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:19,031] INFO Kafka startTimeMs: 1586233519030 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:19,032] INFO creating herder for m1-backup->m1-source (org.apache.kafka.connect.mirror.MirrorMaker:228) [2020-04-07 07:25:19,835] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,835] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,836] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,837] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,837] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,837] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,837] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,837] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,837] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,837] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,837] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,837] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,837] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,837] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,837] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-04-07 07:25:19,837] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,837] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,837] INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,837] INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,838] INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,838] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,838] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,838] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,838] INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,838] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,838] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,838] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,838] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,838] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,838] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,838] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,838] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,838] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,839] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,839] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,839] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,839] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,839] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,839] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,839] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,839] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,839] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:19,839] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,839] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:19,839] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:19,839] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:19,839] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-04-07 07:25:19,840] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,840] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,840] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-04-07 07:25:19,840] INFO DistributedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null bootstrap.servers = [172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090] client.dns.lookup = default client.id = config.providers = [] config.storage.replication.factor = 3 config.storage.topic = mm2-configs.m1-backup.internal connect.protocol = sessioned connections.max.idle.ms = 540000 connector.client.config.override.policy = None group.id = m1-backup-mm2 header.converter = class org.apache.kafka.connect.converters.ByteArrayConverter heartbeat.interval.ms = 3000 inter.worker.key.generation.algorithm = HmacSHA256 inter.worker.key.size = null inter.worker.key.ttl.ms = 3600000 inter.worker.signature.algorithm = HmacSHA256 inter.worker.verification.algorithms = [HmacSHA256] internal.key.converter = class org.apache.kafka.connect.json.JsonConverter internal.value.converter = class org.apache.kafka.connect.json.JsonConverter key.converter = class org.apache.kafka.connect.converters.ByteArrayConverter listeners = null metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 60000 offset.flush.timeout.ms = 5000 offset.storage.partitions = 25 offset.storage.replication.factor = 3 offset.storage.topic = mm2-offsets.m1-backup.internal plugin.path = null rebalance.timeout.ms = 60000 receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 40000 rest.advertised.host.name = null rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] rest.host.name = null rest.port = 8083 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI scheduled.rebalance.max.delay.ms = 300000 security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS status.storage.partitions = 5 status.storage.replication.factor = 3 status.storage.topic = mm2-status.m1-backup.internal task.shutdown.graceful.timeout.ms = 5000 value.converter = class org.apache.kafka.connect.converters.ByteArrayConverter worker.sync.timeout.ms = 3000 worker.unsync.backoff.ms = 300000 (org.apache.kafka.connect.runtime.distributed.DistributedConfig:347) [2020-04-07 07:25:19,841] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43) [2020-04-07 07:25:19,841] INFO AdminClientConfig values: bootstrap.servers = [172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-04-07 07:25:19,843] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,843] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,843] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,843] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,844] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,844] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,844] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,844] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,844] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,844] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,844] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:19,844] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:19,844] INFO Kafka startTimeMs: 1586233519844 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:19,850] INFO Kafka cluster ID: TmO4uHX0QJKoWtbcEQ20Xg (org.apache.kafka.connect.util.ConnectUtils:59) [2020-04-07 07:25:19,853] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:19,853] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:19,853] INFO Kafka startTimeMs: 1586233519853 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:19,854] INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:347) [2020-04-07 07:25:19,854] INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:347) [2020-04-07 07:25:19,857] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:19,858] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:19,858] INFO Kafka startTimeMs: 1586233519857 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:19,858] INFO Kafka MirrorMaker starting with 2 herders. (org.apache.kafka.connect.mirror.MirrorMaker:161) [2020-04-07 07:25:19,860] INFO [Worker clientId=connect-1, groupId=m1-source-mm2] Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder:275) [2020-04-07 07:25:19,861] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:184) [2020-04-07 07:25:19,861] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:108) [2020-04-07 07:25:19,861] INFO Starting KafkaBasedLog with topic mm2-offsets.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:126) [2020-04-07 07:25:19,860] INFO Configuring connectors... (org.apache.kafka.connect.mirror.MirrorMaker:175) [2020-04-07 07:25:19,861] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder:275) [2020-04-07 07:25:19,861] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:184) [2020-04-07 07:25:19,861] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:108) [2020-04-07 07:25:19,861] INFO Starting KafkaBasedLog with topic mm2-offsets.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:126) [2020-04-07 07:25:19,862] INFO AdminClientConfig values: bootstrap.servers = [172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-04-07 07:25:19,864] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,864] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,864] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,864] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,864] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,864] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,864] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,864] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,864] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,864] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,865] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:19,865] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:19,865] INFO Kafka startTimeMs: 1586233519864 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:19,873] INFO Kafka MirrorMaker started (org.apache.kafka.connect.mirror.MirrorMaker:177) [2020-04-07 07:25:19,873] INFO AdminClientConfig values: bootstrap.servers = [172.17.165.52:9999] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-04-07 07:25:19,884] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,884] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,884] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,884] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,885] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,885] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,885] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,885] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,885] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,885] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:19,885] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:19,885] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:19,885] INFO Kafka startTimeMs: 1586233519885 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:19,919] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:347) [2020-04-07 07:25:19,941] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,941] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,941] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,941] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,941] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,941] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,941] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,941] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,941] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,941] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,941] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:19,941] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:19,941] INFO Kafka startTimeMs: 1586233519941 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:19,952] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = m1-backup-mm2 group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig:347) [2020-04-07 07:25:19,968] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [172.17.165.52:9999] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:347) [2020-04-07 07:25:19,978] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,979] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,979] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,979] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,979] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,979] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,979] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,979] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,979] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,979] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:19,979] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:19,979] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:19,979] INFO Kafka startTimeMs: 1586233519979 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:19,985] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,980] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [172.17.165.52:9999] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = m1-source-mm2 group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig:347) [2020-04-07 07:25:19,991] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,992] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,992] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,992] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,992] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,992] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,992] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,992] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,992] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:19,992] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:19,992] INFO Kafka startTimeMs: 1586233519992 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:19,993] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,994] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,995] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,995] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,995] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,995] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,995] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,995] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,995] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:19,995] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:19,995] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:19,995] INFO Kafka startTimeMs: 1586233519995 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:20,009] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Subscribed to partition(s): mm2-offsets.m1-backup.internal-0, mm2-offsets.m1-backup.internal-5, mm2-offsets.m1-backup.internal-10, mm2-offsets.m1-backup.internal-20, mm2-offsets.m1-backup.internal-15, mm2-offsets.m1-backup.internal-9, mm2-offsets.m1-backup.internal-11, mm2-offsets.m1-backup.internal-4, mm2-offsets.m1-backup.internal-16, mm2-offsets.m1-backup.internal-17, mm2-offsets.m1-backup.internal-3, mm2-offsets.m1-backup.internal-24, mm2-offsets.m1-backup.internal-23, mm2-offsets.m1-backup.internal-13, mm2-offsets.m1-backup.internal-18, mm2-offsets.m1-backup.internal-22, mm2-offsets.m1-backup.internal-2, mm2-offsets.m1-backup.internal-8, mm2-offsets.m1-backup.internal-12, mm2-offsets.m1-backup.internal-19, mm2-offsets.m1-backup.internal-14, mm2-offsets.m1-backup.internal-1, mm2-offsets.m1-backup.internal-6, mm2-offsets.m1-backup.internal-7, mm2-offsets.m1-backup.internal-21 (org.apache.kafka.clients.consumer.KafkaConsumer:1123) [2020-04-07 07:25:20,011] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-5 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-10 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-20 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-15 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-9 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-11 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-16 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-17 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-24 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-23 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-13 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-18 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-22 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,012] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-8 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,013] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-12 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,013] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-19 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,013] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-14 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,013] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,013] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-6 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,013] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-7 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,013] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-backup.internal-21 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,022] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Cluster ID: TmO4uHX0QJKoWtbcEQ20Xg (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:20,026] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Subscribed to partition(s): mm2-offsets.m1-source.internal-0, mm2-offsets.m1-source.internal-5, mm2-offsets.m1-source.internal-10, mm2-offsets.m1-source.internal-20, mm2-offsets.m1-source.internal-15, mm2-offsets.m1-source.internal-9, mm2-offsets.m1-source.internal-11, mm2-offsets.m1-source.internal-16, mm2-offsets.m1-source.internal-4, mm2-offsets.m1-source.internal-17, mm2-offsets.m1-source.internal-3, mm2-offsets.m1-source.internal-24, mm2-offsets.m1-source.internal-23, mm2-offsets.m1-source.internal-13, mm2-offsets.m1-source.internal-18, mm2-offsets.m1-source.internal-22, mm2-offsets.m1-source.internal-8, mm2-offsets.m1-source.internal-2, mm2-offsets.m1-source.internal-12, mm2-offsets.m1-source.internal-19, mm2-offsets.m1-source.internal-14, mm2-offsets.m1-source.internal-1, mm2-offsets.m1-source.internal-6, mm2-offsets.m1-source.internal-7, mm2-offsets.m1-source.internal-21 (org.apache.kafka.clients.consumer.KafkaConsumer:1123) [2020-04-07 07:25:20,026] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,026] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-5 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,026] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-10 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,026] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-20 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,026] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-15 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,026] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-9 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,026] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-11 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,026] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-16 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,026] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-17 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-24 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-23 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-13 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-18 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-22 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-8 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-12 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-19 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-14 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-6 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-7 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,027] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-offsets.m1-source.internal-21 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,029] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Cluster ID: hZ1nvm4RTMqkKmR8dbzX5w (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:20,041] INFO [Producer clientId=producer-1] Cluster ID: TmO4uHX0QJKoWtbcEQ20Xg (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:20,051] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-17 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,051] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,051] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-2 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,051] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-21 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,052] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-19 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,052] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-23 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,052] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-12 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,052] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-10 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,052] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-16 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,052] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-14 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,052] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-4 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,052] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-2 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,052] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-8 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,052] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-6 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,052] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-1 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,053] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-20 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,053] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-18 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,053] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-24 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,053] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-22 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,053] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-13 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,053] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-11 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,053] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-17 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,053] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-15 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,053] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-5 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,053] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-3 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,053] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-9 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,053] INFO [Consumer clientId=consumer-m1-source-mm2-2, groupId=m1-source-mm2] Resetting offset for partition mm2-offsets.m1-source.internal-7 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,054] INFO Finished reading KafkaBasedLog for topic mm2-offsets.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:159) [2020-04-07 07:25:20,054] INFO Started KafkaBasedLog for topic mm2-offsets.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:161) [2020-04-07 07:25:20,054] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:110) [2020-04-07 07:25:20,052] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-11 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,055] INFO Worker started (org.apache.kafka.connect.runtime.Worker:191) [2020-04-07 07:25:20,055] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-14 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,056] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-23 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,056] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-8 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,056] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-20 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,056] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-5 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,056] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-16 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,056] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-1 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,056] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-13 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,056] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-7 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,056] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-10 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,057] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-19 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,057] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-4 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,057] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-22 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,057] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-15 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,057] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,057] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-18 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,057] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-12 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,057] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-24 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,057] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-9 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,057] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-3 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,074] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-21 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,074] INFO [Consumer clientId=consumer-m1-backup-mm2-1, groupId=m1-backup-mm2] Resetting offset for partition mm2-offsets.m1-backup.internal-6 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,056] INFO Starting KafkaBasedLog with topic mm2-status.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:126) [2020-04-07 07:25:20,077] INFO AdminClientConfig values: bootstrap.servers = [172.17.165.52:9999] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-04-07 07:25:20,084] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,085] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,085] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,085] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,085] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,085] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,085] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,085] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,085] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,085] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,085] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:20,085] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:20,085] INFO Kafka startTimeMs: 1586233520085 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:20,085] INFO [Producer clientId=producer-2] Cluster ID: hZ1nvm4RTMqkKmR8dbzX5w (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:20,111] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [172.17.165.52:9999] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 0 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:347) [2020-04-07 07:25:20,119] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,120] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,120] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,120] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,120] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,120] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,120] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,120] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,120] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,120] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,120] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:20,120] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:20,120] INFO Kafka startTimeMs: 1586233520120 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:20,121] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [172.17.165.52:9999] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = m1-source-mm2 group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig:347) [2020-04-07 07:25:20,123] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,123] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,123] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,123] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,123] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,123] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,123] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,123] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,123] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,123] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:20,123] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:20,123] INFO Kafka startTimeMs: 1586233520123 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:20,170] INFO [Consumer clientId=consumer-m1-source-mm2-3, groupId=m1-source-mm2] Subscribed to partition(s): mm2-status.m1-source.internal-0, mm2-status.m1-source.internal-1, mm2-status.m1-source.internal-4, mm2-status.m1-source.internal-2, mm2-status.m1-source.internal-3 (org.apache.kafka.clients.consumer.KafkaConsumer:1123) [2020-04-07 07:25:20,170] INFO [Consumer clientId=consumer-m1-source-mm2-3, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-status.m1-source.internal-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,170] INFO [Consumer clientId=consumer-m1-source-mm2-3, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-status.m1-source.internal-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,170] INFO [Consumer clientId=consumer-m1-source-mm2-3, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-status.m1-source.internal-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,170] INFO [Consumer clientId=consumer-m1-source-mm2-3, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-status.m1-source.internal-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,170] INFO [Consumer clientId=consumer-m1-source-mm2-3, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-status.m1-source.internal-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,182] INFO [Consumer clientId=consumer-m1-source-mm2-3, groupId=m1-source-mm2] Cluster ID: hZ1nvm4RTMqkKmR8dbzX5w (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:20,188] INFO Finished reading KafkaBasedLog for topic mm2-offsets.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:159) [2020-04-07 07:25:20,190] INFO Started KafkaBasedLog for topic mm2-offsets.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:161) [2020-04-07 07:25:20,190] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:110) [2020-04-07 07:25:20,190] INFO Worker started (org.apache.kafka.connect.runtime.Worker:191) [2020-04-07 07:25:20,190] INFO Starting KafkaBasedLog with topic mm2-status.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:126) [2020-04-07 07:25:20,190] INFO AdminClientConfig values: bootstrap.servers = [172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-04-07 07:25:20,191] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,191] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,191] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,191] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,191] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,191] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,191] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,192] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,192] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,192] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,192] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:20,192] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:20,192] INFO Kafka startTimeMs: 1586233520192 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:20,192] INFO [Consumer clientId=consumer-m1-source-mm2-3, groupId=m1-source-mm2] Resetting offset for partition mm2-status.m1-source.internal-4 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,196] INFO [Consumer clientId=consumer-m1-source-mm2-3, groupId=m1-source-mm2] Resetting offset for partition mm2-status.m1-source.internal-2 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,196] INFO [Consumer clientId=consumer-m1-source-mm2-3, groupId=m1-source-mm2] Resetting offset for partition mm2-status.m1-source.internal-3 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,197] INFO [Consumer clientId=consumer-m1-source-mm2-3, groupId=m1-source-mm2] Resetting offset for partition mm2-status.m1-source.internal-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,197] INFO [Consumer clientId=consumer-m1-source-mm2-3, groupId=m1-source-mm2] Resetting offset for partition mm2-status.m1-source.internal-1 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,199] INFO Finished reading KafkaBasedLog for topic mm2-status.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:159) [2020-04-07 07:25:20,199] INFO Started KafkaBasedLog for topic mm2-status.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:161) [2020-04-07 07:25:20,200] INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:262) [2020-04-07 07:25:20,200] INFO Starting KafkaBasedLog with topic mm2-configs.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:126) [2020-04-07 07:25:20,201] INFO AdminClientConfig values: bootstrap.servers = [172.17.165.52:9999] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-04-07 07:25:20,201] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,201] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,202] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,202] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,202] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,202] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,202] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,202] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,202] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,202] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,202] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:20,202] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:20,202] INFO Kafka startTimeMs: 1586233520202 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:20,231] INFO [Producer clientId=producer-3] Cluster ID: hZ1nvm4RTMqkKmR8dbzX5w (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:20,231] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 0 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:347) [2020-04-07 07:25:20,235] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [172.17.165.52:9999] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:347) [2020-04-07 07:25:20,241] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,242] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,242] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,242] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,242] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,242] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,242] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,242] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,242] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,242] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,242] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:20,242] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:20,242] INFO Kafka startTimeMs: 1586233520242 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:20,244] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,244] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,244] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,244] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,244] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,245] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,245] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,245] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,245] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,245] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,245] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:20,245] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:20,245] INFO Kafka startTimeMs: 1586233520245 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:20,245] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [172.17.165.52:9999] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = m1-source-mm2 group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig:347) [2020-04-07 07:25:20,247] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,247] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,247] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,247] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,247] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,247] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,247] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,247] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,247] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,247] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:20,247] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:20,247] INFO Kafka startTimeMs: 1586233520247 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:20,244] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = m1-backup-mm2 group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig:347) [2020-04-07 07:25:20,250] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,250] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,250] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,250] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,250] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,250] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,250] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,250] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,250] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,250] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:20,250] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:20,250] INFO Kafka startTimeMs: 1586233520250 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:20,254] INFO [Consumer clientId=consumer-m1-backup-mm2-5, groupId=m1-backup-mm2] Subscribed to partition(s): mm2-status.m1-backup.internal-0, mm2-status.m1-backup.internal-1, mm2-status.m1-backup.internal-4, mm2-status.m1-backup.internal-2, mm2-status.m1-backup.internal-3 (org.apache.kafka.clients.consumer.KafkaConsumer:1123) [2020-04-07 07:25:20,254] INFO [Consumer clientId=consumer-m1-backup-mm2-5, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-status.m1-backup.internal-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,254] INFO [Consumer clientId=consumer-m1-backup-mm2-5, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-status.m1-backup.internal-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,254] INFO [Consumer clientId=consumer-m1-backup-mm2-5, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-status.m1-backup.internal-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,254] INFO [Consumer clientId=consumer-m1-backup-mm2-5, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-status.m1-backup.internal-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,254] INFO [Consumer clientId=consumer-m1-backup-mm2-5, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-status.m1-backup.internal-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,254] INFO [Consumer clientId=consumer-m1-source-mm2-4, groupId=m1-source-mm2] Subscribed to partition(s): mm2-configs.m1-source.internal-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1123) [2020-04-07 07:25:20,255] INFO [Consumer clientId=consumer-m1-source-mm2-4, groupId=m1-source-mm2] Seeking to EARLIEST offset of partition mm2-configs.m1-source.internal-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,256] INFO [Consumer clientId=consumer-m1-backup-mm2-5, groupId=m1-backup-mm2] Cluster ID: TmO4uHX0QJKoWtbcEQ20Xg (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:20,260] INFO [Consumer clientId=consumer-m1-backup-mm2-5, groupId=m1-backup-mm2] Resetting offset for partition mm2-status.m1-backup.internal-4 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,260] INFO [Consumer clientId=consumer-m1-backup-mm2-5, groupId=m1-backup-mm2] Resetting offset for partition mm2-status.m1-backup.internal-1 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,261] INFO [Consumer clientId=consumer-m1-backup-mm2-5, groupId=m1-backup-mm2] Resetting offset for partition mm2-status.m1-backup.internal-3 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,261] INFO [Consumer clientId=consumer-m1-backup-mm2-5, groupId=m1-backup-mm2] Resetting offset for partition mm2-status.m1-backup.internal-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,261] INFO [Consumer clientId=consumer-m1-backup-mm2-5, groupId=m1-backup-mm2] Resetting offset for partition mm2-status.m1-backup.internal-2 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,277] INFO [Consumer clientId=consumer-m1-source-mm2-4, groupId=m1-source-mm2] Cluster ID: hZ1nvm4RTMqkKmR8dbzX5w (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:20,297] INFO [Consumer clientId=consumer-m1-source-mm2-4, groupId=m1-source-mm2] Resetting offset for partition mm2-configs.m1-source.internal-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,307] INFO Finished reading KafkaBasedLog for topic mm2-configs.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:159) [2020-04-07 07:25:20,307] INFO Started KafkaBasedLog for topic mm2-configs.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:161) [2020-04-07 07:25:20,307] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:267) [2020-04-07 07:25:20,307] INFO [Worker clientId=connect-1, groupId=m1-source-mm2] Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:279) [2020-04-07 07:25:20,315] INFO [Worker clientId=connect-1, groupId=m1-source-mm2] Cluster ID: hZ1nvm4RTMqkKmR8dbzX5w (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:20,354] INFO [Producer clientId=producer-4] Cluster ID: TmO4uHX0QJKoWtbcEQ20Xg (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:20,355] INFO [Producer clientId=producer-5] Cluster ID: hZ1nvm4RTMqkKmR8dbzX5w (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:20,391] INFO Finished reading KafkaBasedLog for topic mm2-status.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:159) [2020-04-07 07:25:20,392] INFO Started KafkaBasedLog for topic mm2-status.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:161) [2020-04-07 07:25:20,392] INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:262) [2020-04-07 07:25:20,392] INFO Starting KafkaBasedLog with topic mm2-configs.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:126) [2020-04-07 07:25:20,392] INFO AdminClientConfig values: bootstrap.servers = [172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-04-07 07:25:20,393] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,393] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,393] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,393] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,393] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,394] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,394] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,394] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,394] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,394] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-04-07 07:25:20,394] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:20,394] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:20,394] INFO Kafka startTimeMs: 1586233520394 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:20,410] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:347) [2020-04-07 07:25:20,419] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,419] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,419] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,419] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,419] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,419] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,419] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,419] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,419] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,419] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-04-07 07:25:20,419] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:20,419] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:20,419] INFO Kafka startTimeMs: 1586233520419 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:20,419] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = m1-backup-mm2 group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig:347) [2020-04-07 07:25:20,423] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,423] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,423] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,423] WARN The configuration 'header.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,423] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,423] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,423] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,423] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,423] WARN The configuration 'admin.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-04-07 07:25:20,423] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:20,423] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:20,423] INFO Kafka startTimeMs: 1586233520423 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:20,439] INFO [Consumer clientId=consumer-m1-backup-mm2-6, groupId=m1-backup-mm2] Subscribed to partition(s): mm2-configs.m1-backup.internal-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1123) [2020-04-07 07:25:20,439] INFO [Consumer clientId=consumer-m1-backup-mm2-6, groupId=m1-backup-mm2] Seeking to EARLIEST offset of partition mm2-configs.m1-backup.internal-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:568) [2020-04-07 07:25:20,442] INFO [Consumer clientId=consumer-m1-backup-mm2-6, groupId=m1-backup-mm2] Cluster ID: TmO4uHX0QJKoWtbcEQ20Xg (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:20,449] INFO [Consumer clientId=consumer-m1-backup-mm2-6, groupId=m1-backup-mm2] Resetting offset for partition mm2-configs.m1-backup.internal-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:385) [2020-04-07 07:25:20,483] INFO Finished reading KafkaBasedLog for topic mm2-configs.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:159) [2020-04-07 07:25:20,483] INFO Started KafkaBasedLog for topic mm2-configs.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:161) [2020-04-07 07:25:20,483] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:267) [2020-04-07 07:25:20,483] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:279) [2020-04-07 07:25:20,490] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Cluster ID: TmO4uHX0QJKoWtbcEQ20Xg (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:20,490] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Discovered group coordinator 172.17.165.49:9090 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:756) [2020-04-07 07:25:20,491] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:222) [2020-04-07 07:25:20,491] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:533) [2020-04-07 07:25:20,497] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:533) [2020-04-07 07:25:20,514] INFO [Producer clientId=producer-6] Cluster ID: TmO4uHX0QJKoWtbcEQ20Xg (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:20,619] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Successfully joined group with generation 7 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:484) [2020-04-07 07:25:20,619] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Joined group at generation 7 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-2-14e4f598-dd1c-49c9-b414-5ff8afac2463', leaderUrl='NOTUSED/m1-backup', offset=522, connectorIds=[MirrorSourceConnector, MirrorHeartbeatConnector, MirrorCheckpointConnector], taskIds=[MirrorHeartbeatConnector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1540) [2020-04-07 07:25:20,620] WARN [Worker clientId=connect-2, groupId=m1-backup-mm2] Catching up to assignment's config offset. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1013) [2020-04-07 07:25:20,620] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Current config state offset -1 is behind group assignment 522, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1074) [2020-04-07 07:25:20,984] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Finished reading to end of log and updated config snapshot, new config log offset: 522 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1078) [2020-04-07 07:25:20,984] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Starting connectors and tasks using config offset 522 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1104) [2020-04-07 07:25:20,985] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Starting connector MirrorSourceConnector (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1179) [2020-04-07 07:25:20,988] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Starting connector MirrorCheckpointConnector (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1179) [2020-04-07 07:25:20,986] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Starting connector MirrorHeartbeatConnector (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1179) [2020-04-07 07:25:20,991] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Starting task MirrorHeartbeatConnector-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1139) [2020-04-07 07:25:20,992] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorSourceConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:347) [2020-04-07 07:25:20,992] INFO Creating task MirrorHeartbeatConnector-0 (org.apache.kafka.connect.runtime.Worker:419) [2020-04-07 07:25:20,992] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorSourceConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-07 07:25:20,993] INFO Creating connector MirrorSourceConnector of type org.apache.kafka.connect.mirror.MirrorSourceConnector (org.apache.kafka.connect.runtime.Worker:251) [2020-04-07 07:25:20,992] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:347) [2020-04-07 07:25:21,004] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:21,005] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:347) [2020-04-07 07:25:20,992] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorCheckpointConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:347) [2020-04-07 07:25:20,998] INFO Instantiated connector MirrorSourceConnector with version 1 of type class org.apache.kafka.connect.mirror.MirrorSourceConnector (org.apache.kafka.connect.runtime.Worker:254) [2020-04-07 07:25:21,006] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorCheckpointConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-07 07:25:21,006] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-07 07:25:21,005] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-07 07:25:21,007] INFO TaskConfig values: task.class = class org.apache.kafka.connect.mirror.MirrorHeartbeatTask (org.apache.kafka.connect.runtime.TaskConfig:347) [2020-04-07 07:25:21,006] INFO Creating connector MirrorCheckpointConnector of type org.apache.kafka.connect.mirror.MirrorCheckpointConnector (org.apache.kafka.connect.runtime.Worker:251) [2020-04-07 07:25:21,008] INFO Instantiated task MirrorHeartbeatConnector-0 with version 1 of type org.apache.kafka.connect.mirror.MirrorHeartbeatTask (org.apache.kafka.connect.runtime.Worker:434) [2020-04-07 07:25:21,008] INFO Set up the key converter class org.apache.kafka.connect.converters.ByteArrayConverter for task MirrorHeartbeatConnector-0 using the worker config (org.apache.kafka.connect.runtime.Worker:447) [2020-04-07 07:25:21,008] INFO Set up the value converter class org.apache.kafka.connect.converters.ByteArrayConverter for task MirrorHeartbeatConnector-0 using the worker config (org.apache.kafka.connect.runtime.Worker:453) [2020-04-07 07:25:21,008] INFO Set up the header converter class org.apache.kafka.connect.converters.ByteArrayConverter for task MirrorHeartbeatConnector-0 using the worker config (org.apache.kafka.connect.runtime.Worker:460) [2020-04-07 07:25:21,011] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:514) [2020-04-07 07:25:21,014] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090] buffer.memory = 33554432 client.dns.lookup = default client.id = connector-producer-MirrorHeartbeatConnector-0 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 9223372036854775807 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 2147483647 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:347) [2020-04-07 07:25:21,006] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:21,015] INFO MirrorConnectorConfig values: admin.timeout.ms = 60000 checkpoints.topic.replication.factor = 3 config.action.reload = restart config.properties.blacklist = [follower\.replication\.throttled\.replicas, leader\.replication\.throttled\.replicas, message\.timestamp\.difference\.max\.ms, message\.timestamp\.type, unclean\.leader\.election\.enable, min\.insync\.replicas] config.property.filter.class = class org.apache.kafka.connect.mirror.DefaultConfigPropertyFilter connector.class = org.apache.kafka.connect.mirror.MirrorSourceConnector consumer.poll.timeout.ms = 1000 emit.checkpoints.enabled = true emit.checkpoints.interval.seconds = 60 emit.heartbeats.enabled = true emit.heartbeats.interval.seconds = 1 enabled = false errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none group.filter.class = class org.apache.kafka.connect.mirror.DefaultGroupFilter groups = [.*] groups.blacklist = [console-consumer-.*, connect-.*, __.*] header.converter = null heartbeats.topic.replication.factor = 3 key.converter = null metric.reporters = null name = mm2-backupFlow offset-syncs.topic.replication.factor = 3 offset.lag.max = 100 refresh.groups.enabled = true refresh.groups.interval.seconds = 600 refresh.topics.enabled = true refresh.topics.interval.seconds = 600 replication.factor = 2 replication.policy.class = class org.apache.kafka.connect.mirror.DefaultReplicationPolicy replication.policy.separator = . sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT source.cluster.alias = m1-source ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS sync.topic.acls.enabled = true sync.topic.acls.interval.seconds = 600 sync.topic.configs.enabled = true sync.topic.configs.interval.seconds = 600 target.cluster.alias = m1-backup tasks.max = 1 topic.filter.class = class org.apache.kafka.connect.mirror.DefaultTopicFilter topics = [.*] topics.blacklist = [.*[\-\.]internal, .*\.replica, __.*] transforms = [] value.converter = null (org.apache.kafka.connect.mirror.MirrorConnectorConfig:347) [2020-04-07 07:25:21,008] INFO Instantiated connector MirrorCheckpointConnector with version 1 of type class org.apache.kafka.connect.mirror.MirrorCheckpointConnector (org.apache.kafka.connect.runtime.Worker:254) [2020-04-07 07:25:21,026] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:21,007] INFO Creating connector MirrorHeartbeatConnector of type org.apache.kafka.connect.mirror.MirrorHeartbeatConnector (org.apache.kafka.connect.runtime.Worker:251) [2020-04-07 07:25:21,026] INFO Instantiated connector MirrorHeartbeatConnector with version 1 of type class org.apache.kafka.connect.mirror.MirrorHeartbeatConnector (org.apache.kafka.connect.runtime.Worker:254) [2020-04-07 07:25:21,026] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:21,031] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:21,032] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:21,032] INFO Kafka startTimeMs: 1586233521031 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:21,026] INFO MirrorConnectorConfig values: admin.timeout.ms = 60000 checkpoints.topic.replication.factor = 3 config.action.reload = restart config.properties.blacklist = [follower\.replication\.throttled\.replicas, leader\.replication\.throttled\.replicas, message\.timestamp\.difference\.max\.ms, message\.timestamp\.type, unclean\.leader\.election\.enable, min\.insync\.replicas] config.property.filter.class = class org.apache.kafka.connect.mirror.DefaultConfigPropertyFilter connector.class = org.apache.kafka.connect.mirror.MirrorCheckpointConnector consumer.poll.timeout.ms = 1000 emit.checkpoints.enabled = true emit.checkpoints.interval.seconds = 60 emit.heartbeats.enabled = true emit.heartbeats.interval.seconds = 1 enabled = false errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none group.filter.class = class org.apache.kafka.connect.mirror.DefaultGroupFilter groups = [.*] groups.blacklist = [console-consumer-.*, connect-.*, __.*] header.converter = null heartbeats.topic.replication.factor = 3 key.converter = null metric.reporters = null name = mm2-backupFlow offset-syncs.topic.replication.factor = 3 offset.lag.max = 100 refresh.groups.enabled = true refresh.groups.interval.seconds = 600 refresh.topics.enabled = true refresh.topics.interval.seconds = 600 replication.factor = 2 replication.policy.class = class org.apache.kafka.connect.mirror.DefaultReplicationPolicy replication.policy.separator = . sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT source.cluster.alias = m1-source ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS sync.topic.acls.enabled = true sync.topic.acls.interval.seconds = 600 sync.topic.configs.enabled = true sync.topic.configs.interval.seconds = 600 target.cluster.alias = m1-backup tasks.max = 1 topic.filter.class = class org.apache.kafka.connect.mirror.DefaultTopicFilter topics = [.*] topics.blacklist = [.*[\-\.]internal, .*\.replica, __.*] transforms = [] value.converter = null (org.apache.kafka.connect.mirror.MirrorConnectorConfig:347) [2020-04-07 07:25:21,027] INFO MirrorConnectorConfig values: admin.timeout.ms = 60000 checkpoints.topic.replication.factor = 3 config.action.reload = restart config.properties.blacklist = [follower\.replication\.throttled\.replicas, leader\.replication\.throttled\.replicas, message\.timestamp\.difference\.max\.ms, message\.timestamp\.type, unclean\.leader\.election\.enable, min\.insync\.replicas] config.property.filter.class = class org.apache.kafka.connect.mirror.DefaultConfigPropertyFilter connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector consumer.poll.timeout.ms = 1000 emit.checkpoints.enabled = true emit.checkpoints.interval.seconds = 60 emit.heartbeats.enabled = true emit.heartbeats.interval.seconds = 1 enabled = false errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none group.filter.class = class org.apache.kafka.connect.mirror.DefaultGroupFilter groups = [.*] groups.blacklist = [console-consumer-.*, connect-.*, __.*] header.converter = null heartbeats.topic.replication.factor = 3 key.converter = null metric.reporters = null name = mm2-backupFlow offset-syncs.topic.replication.factor = 3 offset.lag.max = 100 refresh.groups.enabled = true refresh.groups.interval.seconds = 600 refresh.topics.enabled = true refresh.topics.interval.seconds = 600 replication.factor = 2 replication.policy.class = class org.apache.kafka.connect.mirror.DefaultReplicationPolicy replication.policy.separator = . sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT source.cluster.alias = m1-source ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS sync.topic.acls.enabled = true sync.topic.acls.interval.seconds = 600 sync.topic.configs.enabled = true sync.topic.configs.interval.seconds = 600 target.cluster.alias = m1-backup tasks.max = 1 topic.filter.class = class org.apache.kafka.connect.mirror.DefaultTopicFilter topics = [.*] topics.blacklist = [.*[\-\.]internal, .*\.replica, __.*] transforms = [] value.converter = null (org.apache.kafka.connect.mirror.MirrorConnectorConfig:347) [2020-04-07 07:25:21,060] INFO Finished creating connector MirrorSourceConnector (org.apache.kafka.connect.runtime.Worker:273) [2020-04-07 07:25:21,061] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:21,061] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorSourceConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:347) [2020-04-07 07:25:21,061] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorSourceConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-07 07:25:21,061] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:21,062] INFO Finished creating connector MirrorCheckpointConnector (org.apache.kafka.connect.runtime.Worker:273) [2020-04-07 07:25:21,062] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:21,062] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorCheckpointConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:347) [2020-04-07 07:25:21,063] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorCheckpointConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-07 07:25:21,063] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:21,070] INFO MirrorTaskConfig values: admin.timeout.ms = 60000 checkpoints.topic.replication.factor = 3 config.action.reload = restart config.properties.blacklist = [follower\.replication\.throttled\.replicas, leader\.replication\.throttled\.replicas, message\.timestamp\.difference\.max\.ms, message\.timestamp\.type, unclean\.leader\.election\.enable, min\.insync\.replicas] config.property.filter.class = class org.apache.kafka.connect.mirror.DefaultConfigPropertyFilter connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector consumer.poll.timeout.ms = 1000 emit.checkpoints.enabled = true emit.checkpoints.interval.seconds = 60 emit.heartbeats.enabled = true emit.heartbeats.interval.seconds = 1 enabled = false errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none group.filter.class = class org.apache.kafka.connect.mirror.DefaultGroupFilter groups = [.*] groups.blacklist = [console-consumer-.*, connect-.*, __.*] header.converter = null heartbeats.topic.replication.factor = 3 key.converter = null metric.reporters = null name = mm2-backupFlow offset-syncs.topic.replication.factor = 3 offset.lag.max = 100 refresh.groups.enabled = true refresh.groups.interval.seconds = 600 refresh.topics.enabled = true refresh.topics.interval.seconds = 600 replication.factor = 2 replication.policy.class = class org.apache.kafka.connect.mirror.DefaultReplicationPolicy replication.policy.separator = . sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT source.cluster.alias = m1-source ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS sync.topic.acls.enabled = true sync.topic.acls.interval.seconds = 600 sync.topic.configs.enabled = true sync.topic.configs.interval.seconds = 600 target.cluster.alias = m1-backup task.assigned.groups = null task.assigned.partitions = null tasks.max = 1 topic.filter.class = class org.apache.kafka.connect.mirror.DefaultTopicFilter topics = [.*] topics.blacklist = [.*[\-\.]internal, .*\.replica, __.*] transforms = [] value.converter = null (org.apache.kafka.connect.mirror.MirrorTaskConfig:347) [2020-04-07 07:25:21,070] INFO WorkerSourceTask{id=MirrorHeartbeatConnector-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:209) [2020-04-07 07:25:21,073] INFO AdminClientConfig values: bootstrap.servers = [172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-04-07 07:25:21,074] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:21,074] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:21,074] INFO Kafka startTimeMs: 1586233521074 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:21,084] INFO creating internal topics took 12 ms (org.apache.kafka.connect.mirror.Scheduler:95) [2020-04-07 07:25:21,085] INFO Finished creating connector MirrorHeartbeatConnector (org.apache.kafka.connect.runtime.Worker:273) [2020-04-07 07:25:21,085] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:21,085] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:347) [2020-04-07 07:25:21,085] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-07 07:25:21,085] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:21,087] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1125) [2020-04-07 07:25:21,106] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Session key updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1438) [2020-04-07 07:25:21,108] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:21,110] INFO AbstractConfig values: (org.apache.kafka.common.config.AbstractConfig:347) [2020-04-07 07:25:21,114] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Connector MirrorSourceConnector config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1394) [2020-04-07 07:25:21,134] INFO Connector m1-backup->m1-source configured. (org.apache.kafka.connect.mirror.MirrorMaker:212) [2020-04-07 07:25:21,134] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:21,135] INFO AbstractConfig values: (org.apache.kafka.common.config.AbstractConfig:347) [2020-04-07 07:25:21,137] INFO [Producer clientId=connector-producer-MirrorHeartbeatConnector-0] Cluster ID: TmO4uHX0QJKoWtbcEQ20Xg (org.apache.kafka.clients.Metadata:261) [2020-04-07 07:25:21,139] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Connector MirrorHeartbeatConnector config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1394) [2020-04-07 07:25:21,641] INFO Connector m1-backup->m1-source configured. (org.apache.kafka.connect.mirror.MirrorMaker:212) [2020-04-07 07:25:21,641] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:21,641] INFO AbstractConfig values: (org.apache.kafka.common.config.AbstractConfig:347) [2020-04-07 07:25:21,644] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Connector MirrorCheckpointConnector config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1394) [2020-04-07 07:25:22,147] INFO Connector m1-backup->m1-source configured. (org.apache.kafka.connect.mirror.MirrorMaker:212) [2020-04-07 07:25:22,147] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Handling connector-only config update by restarting connector MirrorSourceConnector (org.apache.kafka.connect.runtime.distributed.DistributedHerder:536) [2020-04-07 07:25:22,147] INFO Stopping connector MirrorSourceConnector (org.apache.kafka.connect.runtime.Worker:358) [2020-04-07 07:25:22,147] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:22,148] INFO Stopped connector MirrorSourceConnector (org.apache.kafka.connect.runtime.Worker:374) [2020-04-07 07:25:22,148] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Starting connector MirrorSourceConnector (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1179) [2020-04-07 07:25:22,148] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorSourceConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:347) [2020-04-07 07:25:22,149] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorSourceConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-07 07:25:22,149] INFO Creating connector MirrorSourceConnector of type org.apache.kafka.connect.mirror.MirrorSourceConnector (org.apache.kafka.connect.runtime.Worker:251) [2020-04-07 07:25:22,149] INFO Instantiated connector MirrorSourceConnector with version 1 of type class org.apache.kafka.connect.mirror.MirrorSourceConnector (org.apache.kafka.connect.runtime.Worker:254) [2020-04-07 07:25:22,149] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:22,149] INFO MirrorConnectorConfig values: admin.timeout.ms = 60000 checkpoints.topic.replication.factor = 3 config.action.reload = restart config.properties.blacklist = [follower\.replication\.throttled\.replicas, leader\.replication\.throttled\.replicas, message\.timestamp\.difference\.max\.ms, message\.timestamp\.type, unclean\.leader\.election\.enable, min\.insync\.replicas] config.property.filter.class = class org.apache.kafka.connect.mirror.DefaultConfigPropertyFilter connector.class = org.apache.kafka.connect.mirror.MirrorSourceConnector consumer.poll.timeout.ms = 1000 emit.checkpoints.enabled = true emit.checkpoints.interval.seconds = 60 emit.heartbeats.enabled = true emit.heartbeats.interval.seconds = 1 enabled = false errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none group.filter.class = class org.apache.kafka.connect.mirror.DefaultGroupFilter groups = [.*] groups.blacklist = [console-consumer-.*, connect-.*, __.*] header.converter = null heartbeats.topic.replication.factor = 3 key.converter = null metric.reporters = null name = mm2-backupFlow offset-syncs.topic.replication.factor = 3 offset.lag.max = 100 refresh.groups.enabled = true refresh.groups.interval.seconds = 600 refresh.topics.enabled = true refresh.topics.interval.seconds = 600 replication.factor = 2 replication.policy.class = class org.apache.kafka.connect.mirror.DefaultReplicationPolicy replication.policy.separator = . sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT source.cluster.alias = m1-source ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS sync.topic.acls.enabled = true sync.topic.acls.interval.seconds = 600 sync.topic.configs.enabled = true sync.topic.configs.interval.seconds = 600 target.cluster.alias = m1-backup task.assigned.groups = null task.assigned.partitions = null tasks.max = 1 topic.filter.class = class org.apache.kafka.connect.mirror.DefaultTopicFilter topics = [.*] topics.blacklist = [.*[\-\.]internal, .*\.replica, __.*] transforms = [] value.converter = null (org.apache.kafka.connect.mirror.MirrorConnectorConfig:347) [2020-04-07 07:25:22,150] INFO Finished creating connector MirrorSourceConnector (org.apache.kafka.connect.runtime.Worker:273) [2020-04-07 07:25:22,150] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:22,150] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorSourceConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:347) [2020-04-07 07:25:22,150] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorSourceConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-07 07:25:22,150] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:22,150] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Handling connector-only config update by restarting connector MirrorHeartbeatConnector (org.apache.kafka.connect.runtime.distributed.DistributedHerder:536) [2020-04-07 07:25:22,150] INFO Stopping connector MirrorHeartbeatConnector (org.apache.kafka.connect.runtime.Worker:358) [2020-04-07 07:25:22,150] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:22,152] INFO Stopped connector MirrorHeartbeatConnector (org.apache.kafka.connect.runtime.Worker:374) [2020-04-07 07:25:22,152] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Starting connector MirrorHeartbeatConnector (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1179) [2020-04-07 07:25:22,152] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:347) [2020-04-07 07:25:22,152] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-07 07:25:22,152] INFO Creating connector MirrorHeartbeatConnector of type org.apache.kafka.connect.mirror.MirrorHeartbeatConnector (org.apache.kafka.connect.runtime.Worker:251) [2020-04-07 07:25:22,152] INFO Instantiated connector MirrorHeartbeatConnector with version 1 of type class org.apache.kafka.connect.mirror.MirrorHeartbeatConnector (org.apache.kafka.connect.runtime.Worker:254) [2020-04-07 07:25:22,153] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:22,153] INFO MirrorConnectorConfig values: admin.timeout.ms = 60000 checkpoints.topic.replication.factor = 3 config.action.reload = restart config.properties.blacklist = [follower\.replication\.throttled\.replicas, leader\.replication\.throttled\.replicas, message\.timestamp\.difference\.max\.ms, message\.timestamp\.type, unclean\.leader\.election\.enable, min\.insync\.replicas] config.property.filter.class = class org.apache.kafka.connect.mirror.DefaultConfigPropertyFilter connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector consumer.poll.timeout.ms = 1000 emit.checkpoints.enabled = true emit.checkpoints.interval.seconds = 60 emit.heartbeats.enabled = true emit.heartbeats.interval.seconds = 1 enabled = false errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none group.filter.class = class org.apache.kafka.connect.mirror.DefaultGroupFilter groups = [.*] groups.blacklist = [console-consumer-.*, connect-.*, __.*] header.converter = null heartbeats.topic.replication.factor = 3 key.converter = null metric.reporters = null name = mm2-backupFlow offset-syncs.topic.replication.factor = 3 offset.lag.max = 100 refresh.groups.enabled = true refresh.groups.interval.seconds = 600 refresh.topics.enabled = true refresh.topics.interval.seconds = 600 replication.factor = 2 replication.policy.class = class org.apache.kafka.connect.mirror.DefaultReplicationPolicy replication.policy.separator = . sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT source.cluster.alias = m1-source ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS sync.topic.acls.enabled = true sync.topic.acls.interval.seconds = 600 sync.topic.configs.enabled = true sync.topic.configs.interval.seconds = 600 target.cluster.alias = m1-backup task.assigned.groups = null task.assigned.partitions = null tasks.max = 1 topic.filter.class = class org.apache.kafka.connect.mirror.DefaultTopicFilter topics = [.*] topics.blacklist = [.*[\-\.]internal, .*\.replica, __.*] transforms = [] value.converter = null (org.apache.kafka.connect.mirror.MirrorConnectorConfig:347) [2020-04-07 07:25:22,154] INFO AdminClientConfig values: bootstrap.servers = [172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-04-07 07:25:22,154] INFO Kafka version: 2.4.0 (org.apache.kafka.common.utils.AppInfoParser:117) [2020-04-07 07:25:22,154] INFO Kafka commitId: 77a89fcf8d7fa018 (org.apache.kafka.common.utils.AppInfoParser:118) [2020-04-07 07:25:22,155] INFO Kafka startTimeMs: 1586233522154 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-04-07 07:25:22,162] INFO creating internal topics took 9 ms (org.apache.kafka.connect.mirror.Scheduler:95) [2020-04-07 07:25:22,163] INFO Finished creating connector MirrorHeartbeatConnector (org.apache.kafka.connect.runtime.Worker:273) [2020-04-07 07:25:22,163] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:22,163] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:347) [2020-04-07 07:25:22,163] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-07 07:25:22,163] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:22,164] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Handling connector-only config update by restarting connector MirrorCheckpointConnector (org.apache.kafka.connect.runtime.distributed.DistributedHerder:536) [2020-04-07 07:25:22,164] INFO Stopping connector MirrorCheckpointConnector (org.apache.kafka.connect.runtime.Worker:358) [2020-04-07 07:25:22,164] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:22,165] INFO Stopped connector MirrorCheckpointConnector (org.apache.kafka.connect.runtime.Worker:374) [2020-04-07 07:25:22,165] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Starting connector MirrorCheckpointConnector (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1179) [2020-04-07 07:25:22,165] INFO ConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorCheckpointConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:347) [2020-04-07 07:25:22,165] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorCheckpointConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-07 07:25:22,165] INFO Creating connector MirrorCheckpointConnector of type org.apache.kafka.connect.mirror.MirrorCheckpointConnector (org.apache.kafka.connect.runtime.Worker:251) [2020-04-07 07:25:22,165] INFO Instantiated connector MirrorCheckpointConnector with version 1 of type class org.apache.kafka.connect.mirror.MirrorCheckpointConnector (org.apache.kafka.connect.runtime.Worker:254) [2020-04-07 07:25:22,165] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:22,165] INFO MirrorConnectorConfig values: admin.timeout.ms = 60000 checkpoints.topic.replication.factor = 3 config.action.reload = restart config.properties.blacklist = [follower\.replication\.throttled\.replicas, leader\.replication\.throttled\.replicas, message\.timestamp\.difference\.max\.ms, message\.timestamp\.type, unclean\.leader\.election\.enable, min\.insync\.replicas] config.property.filter.class = class org.apache.kafka.connect.mirror.DefaultConfigPropertyFilter connector.class = org.apache.kafka.connect.mirror.MirrorCheckpointConnector consumer.poll.timeout.ms = 1000 emit.checkpoints.enabled = true emit.checkpoints.interval.seconds = 60 emit.heartbeats.enabled = true emit.heartbeats.interval.seconds = 1 enabled = false errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none group.filter.class = class org.apache.kafka.connect.mirror.DefaultGroupFilter groups = [.*] groups.blacklist = [console-consumer-.*, connect-.*, __.*] header.converter = null heartbeats.topic.replication.factor = 3 key.converter = null metric.reporters = null name = mm2-backupFlow offset-syncs.topic.replication.factor = 3 offset.lag.max = 100 refresh.groups.enabled = true refresh.groups.interval.seconds = 600 refresh.topics.enabled = true refresh.topics.interval.seconds = 600 replication.factor = 2 replication.policy.class = class org.apache.kafka.connect.mirror.DefaultReplicationPolicy replication.policy.separator = . sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT source.cluster.alias = m1-source ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS sync.topic.acls.enabled = true sync.topic.acls.interval.seconds = 600 sync.topic.configs.enabled = true sync.topic.configs.interval.seconds = 600 target.cluster.alias = m1-backup task.assigned.groups = null task.assigned.partitions = null tasks.max = 1 topic.filter.class = class org.apache.kafka.connect.mirror.DefaultTopicFilter topics = [.*] topics.blacklist = [.*[\-\.]internal, .*\.replica, __.*] transforms = [] value.converter = null (org.apache.kafka.connect.mirror.MirrorConnectorConfig:347) [2020-04-07 07:25:22,166] INFO Finished creating connector MirrorCheckpointConnector (org.apache.kafka.connect.runtime.Worker:273) [2020-04-07 07:25:22,166] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:25:22,166] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorCheckpointConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:347) [2020-04-07 07:25:22,166] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = org.apache.kafka.connect.mirror.MirrorCheckpointConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = mm2-backupFlow tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-04-07 07:25:22,166] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:26:21,038] INFO WorkerSourceTask{id=MirrorHeartbeatConnector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416) [2020-04-07 07:26:21,039] INFO WorkerSourceTask{id=MirrorHeartbeatConnector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433) [2020-04-07 07:26:21,049] INFO WorkerSourceTask{id=MirrorHeartbeatConnector-0} Finished commitOffsets successfully in 9 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:515) [2020-04-07 07:26:59,283] INFO Kafka MirrorMaker stopping (org.apache.kafka.connect.mirror.MirrorMaker:183) [2020-04-07 07:26:59,284] INFO [Worker clientId=connect-1, groupId=m1-source-mm2] Herder stopping (org.apache.kafka.connect.runtime.distributed.DistributedHerder:609) [2020-04-07 07:26:59,284] INFO [Worker clientId=connect-1, groupId=m1-source-mm2] Stopping connectors and tasks that are still assigned to this worker. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:583) [2020-04-07 07:26:59,285] INFO Connector m1-source->m1-backup configured. (org.apache.kafka.connect.mirror.MirrorMaker:212) org.apache.kafka.connect.errors.ConnectException: Worker is shutting down at org.apache.kafka.connect.runtime.distributed.DistributedHerder.halt(DistributedHerder.java:599) at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:285) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) [2020-04-07 07:26:59,287] INFO Connector m1-source->m1-backup configured. (org.apache.kafka.connect.mirror.MirrorMaker:212) org.apache.kafka.connect.errors.ConnectException: Worker is shutting down at org.apache.kafka.connect.runtime.distributed.DistributedHerder.halt(DistributedHerder.java:599) at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:285) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) [2020-04-07 07:26:59,287] INFO Connector m1-source->m1-backup configured. (org.apache.kafka.connect.mirror.MirrorMaker:212) org.apache.kafka.connect.errors.ConnectException: Worker is shutting down at org.apache.kafka.connect.runtime.distributed.DistributedHerder.halt(DistributedHerder.java:599) at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:285) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) [2020-04-07 07:26:59,288] INFO Stopping KafkaBasedLog for topic mm2-status.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:165) [2020-04-07 07:26:59,290] INFO [Producer clientId=producer-3] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183) [2020-04-07 07:26:59,292] INFO Stopped KafkaBasedLog for topic mm2-status.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:191) [2020-04-07 07:26:59,292] INFO Closing KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:272) [2020-04-07 07:26:59,292] INFO Stopping KafkaBasedLog for topic mm2-configs.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:165) [2020-04-07 07:26:59,294] INFO [Producer clientId=producer-5] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183) [2020-04-07 07:26:59,296] INFO Stopped KafkaBasedLog for topic mm2-configs.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:191) [2020-04-07 07:26:59,296] INFO Closed KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:274) [2020-04-07 07:26:59,296] INFO Worker stopping (org.apache.kafka.connect.runtime.Worker:198) [2020-04-07 07:26:59,296] INFO Stopping KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:115) [2020-04-07 07:26:59,296] INFO Stopping KafkaBasedLog for topic mm2-offsets.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:165) [2020-04-07 07:26:59,298] INFO [Producer clientId=producer-2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183) [2020-04-07 07:26:59,300] INFO Stopped KafkaBasedLog for topic mm2-offsets.m1-source.internal (org.apache.kafka.connect.util.KafkaBasedLog:191) [2020-04-07 07:26:59,300] INFO Stopped KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:117) [2020-04-07 07:26:59,300] INFO Worker stopped (org.apache.kafka.connect.runtime.Worker:219) [2020-04-07 07:26:59,300] INFO [Worker clientId=connect-1, groupId=m1-source-mm2] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:287) [2020-04-07 07:26:59,304] INFO [Worker clientId=connect-1, groupId=m1-source-mm2] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:629) [2020-04-07 07:26:59,304] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Herder stopping (org.apache.kafka.connect.runtime.distributed.DistributedHerder:609) [2020-04-07 07:26:59,304] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Stopping connectors and tasks that are still assigned to this worker. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:583) [2020-04-07 07:26:59,305] INFO Stopping connector MirrorSourceConnector (org.apache.kafka.connect.runtime.Worker:358) [2020-04-07 07:26:59,305] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:26:59,305] INFO Stopped connector MirrorSourceConnector (org.apache.kafka.connect.runtime.Worker:374) [2020-04-07 07:26:59,306] INFO Stopping connector MirrorHeartbeatConnector (org.apache.kafka.connect.runtime.Worker:358) [2020-04-07 07:26:59,306] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:26:59,308] INFO Stopping connector MirrorCheckpointConnector (org.apache.kafka.connect.runtime.Worker:358) [2020-04-07 07:26:59,308] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165) [2020-04-07 07:26:59,309] INFO Stopped connector MirrorCheckpointConnector (org.apache.kafka.connect.runtime.Worker:374) [2020-04-07 07:26:59,310] INFO Stopped connector MirrorHeartbeatConnector (org.apache.kafka.connect.runtime.Worker:374) [2020-04-07 07:26:59,311] INFO Stopping task MirrorHeartbeatConnector-0 (org.apache.kafka.connect.runtime.Worker:704) [2020-04-07 07:26:59,312] INFO WorkerSourceTask{id=MirrorHeartbeatConnector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416) [2020-04-07 07:26:59,312] INFO WorkerSourceTask{id=MirrorHeartbeatConnector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433) [2020-04-07 07:26:59,315] INFO WorkerSourceTask{id=MirrorHeartbeatConnector-0} Finished commitOffsets successfully in 3 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:515) [2020-04-07 07:26:59,315] INFO [Producer clientId=connector-producer-MirrorHeartbeatConnector-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183) [2020-04-07 07:26:59,318] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Member connect-2-14e4f598-dd1c-49c9-b414-5ff8afac2463 sending LeaveGroup request to coordinator 172.17.165.49:9090 (id: 2147483647 rack: null) due to the consumer is being closed (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:916) [2020-04-07 07:26:59,319] WARN [Worker clientId=connect-2, groupId=m1-backup-mm2] Close timed out with 1 pending requests to coordinator, terminating client connections (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:897) [2020-04-07 07:26:59,320] INFO Stopping KafkaBasedLog for topic mm2-status.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:165) [2020-04-07 07:26:59,320] INFO [Producer clientId=producer-4] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183) [2020-04-07 07:26:59,322] INFO Stopped KafkaBasedLog for topic mm2-status.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:191) [2020-04-07 07:26:59,322] INFO Closing KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:272) [2020-04-07 07:26:59,322] INFO Stopping KafkaBasedLog for topic mm2-configs.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:165) [2020-04-07 07:26:59,322] INFO [Producer clientId=producer-6] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183) [2020-04-07 07:26:59,323] INFO Stopped KafkaBasedLog for topic mm2-configs.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:191) [2020-04-07 07:26:59,323] INFO Closed KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:274) [2020-04-07 07:26:59,323] INFO Worker stopping (org.apache.kafka.connect.runtime.Worker:198) [2020-04-07 07:26:59,324] INFO Stopping KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:115) [2020-04-07 07:26:59,324] INFO Stopping KafkaBasedLog for topic mm2-offsets.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:165) [2020-04-07 07:26:59,324] INFO [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183) [2020-04-07 07:26:59,325] INFO Stopped KafkaBasedLog for topic mm2-offsets.m1-backup.internal (org.apache.kafka.connect.util.KafkaBasedLog:191) [2020-04-07 07:26:59,326] INFO Stopped KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:117) [2020-04-07 07:26:59,326] INFO Worker stopped (org.apache.kafka.connect.runtime.Worker:219) [2020-04-07 07:26:59,326] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:287) [2020-04-07 07:26:59,329] INFO [Worker clientId=connect-2, groupId=m1-backup-mm2] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:629) [2020-04-07 07:26:59,330] INFO Kafka MirrorMaker stopped. (org.apache.kafka.connect.mirror.MirrorMaker:191)