[2021-06-11 19:13:19,669] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed:92)
[2021-06-11 19:13:19,686] INFO Loading plugin from: /usr/share/connect/debezium (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:246)
[2021-06-11 19:13:20,620] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/connect/debezium/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:269)
[2021-06-11 19:13:20,621] INFO Added plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:20,622] INFO Added plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:20,622] INFO Added plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:20,622] INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:20,623] INFO Added plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:20,623] INFO Added plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:20,623] INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:20,623] INFO Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:20,624] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:20,624] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:20,624] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:20,632] INFO Loading plugin from: /usr/share/connect/debezium/guava-30.0-jre.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:246)
[2021-06-11 19:13:20,824] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/connect/debezium/guava-30.0-jre.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:269)
[2021-06-11 19:13:20,825] INFO Loading plugin from: /usr/share/connect/debezium/failureaccess-1.0.1.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:246)
[2021-06-11 19:13:20,830] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/connect/debezium/failureaccess-1.0.1.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:269)
[2021-06-11 19:13:20,831] INFO Loading plugin from: /usr/share/connect/debezium/mysql-connector-java-8.0.21.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:246)
[2021-06-11 19:13:20,940] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/connect/debezium/mysql-connector-java-8.0.21.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:269)
[2021-06-11 19:13:20,945] INFO Loading plugin from: /usr/share/connect/debezium/debezium-ddl-parser-1.5.0.Final.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:246)
[2021-06-11 19:13:21,066] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/connect/debezium/debezium-ddl-parser-1.5.0.Final.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:269)
[2021-06-11 19:13:21,067] INFO Loading plugin from: /usr/share/connect/debezium/debezium-core-1.5.0.Final.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:246)
[2021-06-11 19:13:21,131] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/connect/debezium/debezium-core-1.5.0.Final.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:269)
[2021-06-11 19:13:21,132] INFO Loading plugin from: /usr/share/connect/debezium/mysql-binlog-connector-java-0.25.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:246)
[2021-06-11 19:13:21,147] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/connect/debezium/mysql-binlog-connector-java-0.25.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:269)
[2021-06-11 19:13:21,148] INFO Loading plugin from: /usr/share/connect/debezium/debezium-connector-mysql-1.5.0.Final.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:246)
[2021-06-11 19:13:21,170] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/connect/debezium/debezium-connector-mysql-1.5.0.Final.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:269)
[2021-06-11 19:13:21,171] INFO Loading plugin from: /usr/share/connect/debezium/antlr4-runtime-4.7.2.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:246)
[2021-06-11 19:13:21,203] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/connect/debezium/antlr4-runtime-4.7.2.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:269)
[2021-06-11 19:13:21,204] INFO Loading plugin from: /usr/share/connect/debezium/debezium-api-1.5.0.Final.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:246)
[2021-06-11 19:13:21,210] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/connect/debezium/debezium-api-1.5.0.Final.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:269)
[2021-06-11 19:13:21,211] INFO Loading plugin from: /usr/share/connect/debezium/aws-msk-iam-auth-1.0.0-all.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:246)
[2021-06-11 19:13:21,455] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/connect/debezium/aws-msk-iam-auth-1.0.0-all.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:269)
[2021-06-11 19:13:22,649] INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@3d4eac69 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:269)
[2021-06-11 19:13:22,650] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,650] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,650] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,650] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,650] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,650] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,650] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,651] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,651] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,651] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,651] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,651] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,651] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,652] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,652] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,652] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,652] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,652] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,652] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,653] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,653] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,653] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,653] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,653] INFO Added plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,654] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,654] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,654] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,654] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,654] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,654] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,655] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,655] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,655] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,655] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,655] INFO Added plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,655] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,656] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,656] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,656] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,656] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,656] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,656] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,657] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,657] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,657] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,657] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,657] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,658] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198)
[2021-06-11 19:13:22,658] INFO Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,659] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,659] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,659] INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,659] INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,660] INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,660] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,660] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,660] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,661] INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,661] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,661] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,661] INFO Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,662] INFO Added aliases 'CloudEventsConverter' and 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,662] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,662] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,662] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,663] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,663] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,663] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,663] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,663] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,664] INFO Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,664] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,664] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,664] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,665] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,665] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,665] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,665] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,665] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424)
[2021-06-11 19:13:22,666] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,666] INFO Added alias 'ReadToInsertEvent' to plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424)
[2021-06-11 19:13:22,666] INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424)
[2021-06-11 19:13:22,667] INFO Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424)
[2021-06-11 19:13:22,667] INFO Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424)
[2021-06-11 19:13:22,667] INFO Added alias 'ActivateTracingSpan' to plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424)
[2021-06-11 19:13:22,667] INFO Added aliases 'PredicatedTransformation' and 'Predicated' to plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,668] INFO Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424)
[2021-06-11 19:13:22,668] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424)
[2021-06-11 19:13:22,669] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424)
[2021-06-11 19:13:22,669] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424)
[2021-06-11 19:13:22,669] INFO Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424)
[2021-06-11 19:13:22,669] INFO Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424)
[2021-06-11 19:13:22,669] INFO Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424)
[2021-06-11 19:13:22,670] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424)
[2021-06-11 19:13:22,670] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,670] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
[2021-06-11 19:13:22,670] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427)
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
[2021-06-11 19:13:22,743] INFO DistributedConfig values:
	access.control.allow.methods =
	access.control.allow.origin =
	admin.listeners = null
	bootstrap.servers = [SERVERS]
	client.dns.lookup = use_all_dns_ips
	client.id =
	config.providers = []
	config.storage.replication.factor = 3
	config.storage.topic = criteria-test-debezium-config
	connect.protocol = sessioned
	connections.max.idle.ms = 540000
	connector.client.config.override.policy = None
	group.id = criteria-test-debezium-connect
	header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
	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.storage.StringConverter
	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 = 50
	offset.storage.replication.factor = 3
	offset.storage.topic = criteria-test-debezium-offset
	plugin.path = [/usr/share/java, /usr/share/confluent-hub-components, /usr/share/connect, /usr/share/connect/debezium]
	rebalance.timeout.ms = 60000
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 40000
	response.http.headers.config =
	rest.advertised.host.name = HOST_NAME
	rest.advertised.listener = null
	rest.advertised.port = 8083
	rest.extension.classes = []
	rest.host.name = null
	rest.port = 8083
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	scheduled.rebalance.max.delay.ms = 300000
	security.protocol = SASL_SSL
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.client.auth = none
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOME_LOCATION
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
	status.storage.partitions = 10
	status.storage.replication.factor = 3
	status.storage.topic = criteria-test-debezium-status
	task.shutdown.graceful.timeout.ms = 5000
	topic.creation.enable = true
	topic.tracking.allow.reset = true
	topic.tracking.enable = true
	value.converter = class org.apache.kafka.connect.json.JsonConverter
	worker.sync.timeout.ms = 3000
	worker.unsync.backoff.ms = 300000
 (org.apache.kafka.connect.runtime.distributed.DistributedConfig:372)
[2021-06-11 19:13:22,743] INFO Worker configuration property 'internal.key.converter' is deprecated and may be removed in an upcoming release. The specified value 'org.apache.kafka.connect.json.JsonConverter' matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:389)
[2021-06-11 19:13:22,743] INFO Worker configuration property 'internal.key.converter.schemas.enable' (along with all configuration for 'internal.key.converter') is deprecated and may be removed in an upcoming release. The specified value 'false' matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:389)
[2021-06-11 19:13:22,744] INFO Worker configuration property 'internal.value.converter' is deprecated and may be removed in an upcoming release. The specified value 'org.apache.kafka.connect.json.JsonConverter' matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:389)
[2021-06-11 19:13:22,744] INFO Worker configuration property 'internal.value.converter.schemas.enable' (along with all configuration for 'internal.value.converter') is deprecated and may be removed in an upcoming release. The specified value 'false' matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:389)
[2021-06-11 19:13:22,746] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49)
[2021-06-11 19:13:22,750] INFO AdminClientConfig values:
	bootstrap.servers = [SERVERS]
	client.dns.lookup = use_all_dns_ips
	client.id =
	connections.max.idle.ms = 300000
	default.api.timeout.ms = 60000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOME_LOCATIONS
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:372)
[2021-06-11 19:13:22,863] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin:61)
[2021-06-11 19:13:23,236] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,236] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,236] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,236] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,237] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,237] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,237] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,237] WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,237] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,238] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,238] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,238] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,238] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,238] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,239] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,239] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,239] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,239] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,240] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,240] WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,240] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,240] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,240] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,240] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,241] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,241] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,241] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,241] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,241] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,241] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,241] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,241] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,242] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,242] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,242] WARN The configuration 'consumer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:23,242] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:23,243] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:23,243] INFO Kafka startTimeMs: 1623438803242 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:24,546] INFO Kafka cluster ID: zoOepbg8Sx-miAtUIcP1vw (org.apache.kafka.connect.util.ConnectUtils:65)
[2021-06-11 19:13:24,548] INFO App info kafka.admin.client for adminclient-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2021-06-11 19:13:24,563] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2021-06-11 19:13:24,563] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2021-06-11 19:13:24,563] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2021-06-11 19:13:24,577] INFO Logging initialized @5602ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:169)
[2021-06-11 19:13:24,619] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:132)
[2021-06-11 19:13:24,619] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer:204)
[2021-06-11 19:13:24,628] INFO jetty-9.4.39.v20210325; built: 2021-03-25T14:42:11.471Z; git: 9fc7ca5a922f2a37b84ec9dbc26a5168cee7e667; jvm 11.0.11+9-Ubuntu-0ubuntu2.18.04 (org.eclipse.jetty.server.Server:375)
[2021-06-11 19:13:24,673] INFO Started http_8083@2cae9b8{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:331)
[2021-06-11 19:13:24,674] INFO Started @5698ms (org.eclipse.jetty.server.Server:415)
[2021-06-11 19:13:24,706] INFO Advertised URI: http://up-crit-debezium-iam-msk-test-4.dm.vpc:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:371)
[2021-06-11 19:13:24,707] INFO REST server listening at SOME_URI (org.apache.kafka.connect.runtime.rest.RestServer:219)
[2021-06-11 19:13:24,707] INFO Advertised URI: SOME_URI (org.apache.kafka.connect.runtime.rest.RestServer:371)
[2021-06-11 19:13:24,707] INFO REST admin endpoints at SOME_URI (org.apache.kafka.connect.runtime.rest.RestServer:220)
[2021-06-11 19:13:24,707] INFO Advertised URI: SOME_URI/ (org.apache.kafka.connect.runtime.rest.RestServer:371)
[2021-06-11 19:13:24,712] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49)
[2021-06-11 19:13:24,713] INFO AdminClientConfig values:
	bootstrap.servers = [SERVERS]
	client.dns.lookup = use_all_dns_ips
	client.id =
	connections.max.idle.ms = 300000
	default.api.timeout.ms = 60000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = LOCATION
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:372)
[2021-06-11 19:13:24,715] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin:61)
[2021-06-11 19:13:24,886] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,886] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,887] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,887] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,887] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,887] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,887] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,887] WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,888] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,888] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,888] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,888] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,888] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,889] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,889] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,889] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,889] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,890] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,890] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,890] WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,890] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,891] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,891] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,891] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,891] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,892] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,892] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,892] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,892] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,893] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,893] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,893] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,893] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,894] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,894] WARN The configuration 'consumer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:24,894] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:24,895] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:24,895] INFO Kafka startTimeMs: 1623438804894 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:25,057] INFO Kafka cluster ID: zoOepbg8Sx-miAtUIcP1vw (org.apache.kafka.connect.util.ConnectUtils:65)
[2021-06-11 19:13:25,059] INFO App info kafka.admin.client for adminclient-2 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2021-06-11 19:13:25,065] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2021-06-11 19:13:25,065] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2021-06-11 19:13:25,066] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2021-06-11 19:13:25,070] INFO Setting up None Policy for ConnectorClientConfigOverride. This will disallow any client configuration to be overridden (org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy:45)
[2021-06-11 19:13:25,077] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49)
[2021-06-11 19:13:25,078] INFO AdminClientConfig values:
	bootstrap.servers = [SERVER]
	client.dns.lookup = use_all_dns_ips
	client.id =
	connections.max.idle.ms = 300000
	default.api.timeout.ms = 60000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = LOCATION
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:372)
[2021-06-11 19:13:25,080] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin:61)
[2021-06-11 19:13:25,138] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,139] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,139] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,141] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,141] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,141] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,142] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,142] WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,142] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,142] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,142] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,142] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,142] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,142] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,142] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,143] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,143] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,143] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,143] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,143] WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,143] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,143] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,143] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,143] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,143] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,143] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,144] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,144] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,144] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,144] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,144] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,144] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,144] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,144] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,144] WARN The configuration 'consumer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,144] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:25,144] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:25,145] INFO Kafka startTimeMs: 1623438805144 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:25,314] INFO Kafka cluster ID: zoOepbg8Sx-miAtUIcP1vw (org.apache.kafka.connect.util.ConnectUtils:65)
[2021-06-11 19:13:25,315] INFO App info kafka.admin.client for adminclient-3 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2021-06-11 19:13:25,319] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2021-06-11 19:13:25,320] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2021-06-11 19:13:25,320] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2021-06-11 19:13:25,323] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:25,324] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:25,324] INFO Kafka startTimeMs: 1623438805323 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:25,441] INFO JsonConverterConfig values:
	converter.type = key
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig:372)
[2021-06-11 19:13:25,443] INFO JsonConverterConfig values:
	converter.type = value
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig:372)
[2021-06-11 19:13:25,443] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49)
[2021-06-11 19:13:25,444] INFO AdminClientConfig values:
	bootstrap.servers = [SERVER]
	client.dns.lookup = use_all_dns_ips
	client.id =
	connections.max.idle.ms = 300000
	default.api.timeout.ms = 60000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = LOCATION
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:372)
[2021-06-11 19:13:25,446] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin:61)
[2021-06-11 19:13:25,492] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,492] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,493] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,493] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,493] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,493] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,493] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,493] WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,493] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,493] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,493] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,493] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,494] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,494] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,494] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,494] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,494] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,494] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,494] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,494] WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,494] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,494] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,494] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,495] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,495] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,495] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,495] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,495] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,495] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,495] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,495] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,495] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,495] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,496] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,496] WARN The configuration 'consumer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,496] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:25,496] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:25,496] INFO Kafka startTimeMs: 1623438805496 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:25,618] INFO Kafka cluster ID: zoOepbg8Sx-miAtUIcP1vw (org.apache.kafka.connect.util.ConnectUtils:65)
[2021-06-11 19:13:25,619] INFO App info kafka.admin.client for adminclient-4 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2021-06-11 19:13:25,624] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2021-06-11 19:13:25,624] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2021-06-11 19:13:25,624] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2021-06-11 19:13:25,632] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49)
[2021-06-11 19:13:25,633] INFO AdminClientConfig values:
	bootstrap.servers = [SERVERS]
	client.dns.lookup = use_all_dns_ips
	client.id =
	connections.max.idle.ms = 300000
	default.api.timeout.ms = 60000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOMNE_LOCATION
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:372)
[2021-06-11 19:13:25,636] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin:61)
[2021-06-11 19:13:25,677] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,678] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,678] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,678] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,678] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,678] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,678] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,678] WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,679] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,679] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,679] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,679] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,679] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,679] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,679] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,679] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,679] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,679] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,679] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,679] WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,680] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,680] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,680] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,680] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,680] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,680] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,680] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,680] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,680] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,680] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,680] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,680] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,680] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,681] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,681] WARN The configuration 'consumer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,681] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:25,681] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:25,681] INFO Kafka startTimeMs: 1623438805681 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:25,784] INFO Kafka cluster ID: zoOepbg8Sx-miAtUIcP1vw (org.apache.kafka.connect.util.ConnectUtils:65)
[2021-06-11 19:13:25,785] INFO App info kafka.admin.client for adminclient-5 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2021-06-11 19:13:25,788] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2021-06-11 19:13:25,789] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2021-06-11 19:13:25,789] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2021-06-11 19:13:25,794] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49)
[2021-06-11 19:13:25,795] INFO AdminClientConfig values:
	bootstrap.servers = [SERVER]
	client.dns.lookup = use_all_dns_ips
	client.id =
	connections.max.idle.ms = 300000
	default.api.timeout.ms = 60000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOMNE_LOCATION
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:372)
[2021-06-11 19:13:25,800] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin:61)
[2021-06-11 19:13:25,864] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,865] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,865] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,865] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,865] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,865] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,865] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,865] WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,865] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,865] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,865] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,865] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,865] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,866] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,867] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,867] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,867] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,867] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,867] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,867] WARN The configuration 'consumer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:25,867] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:25,867] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:25,867] INFO Kafka startTimeMs: 1623438805867 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:25,977] INFO Kafka cluster ID: zoOepbg8Sx-miAtUIcP1vw (org.apache.kafka.connect.util.ConnectUtils:65)
[2021-06-11 19:13:25,978] INFO App info kafka.admin.client for adminclient-6 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2021-06-11 19:13:25,981] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2021-06-11 19:13:25,981] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2021-06-11 19:13:25,981] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2021-06-11 19:13:25,982] WARN Ignoring 'config.storage.partitions=1' setting, since config topic partitions is always 1 (org.apache.kafka.connect.runtime.distributed.DistributedConfig:432)
[2021-06-11 19:13:25,994] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49)
[2021-06-11 19:13:25,994] INFO AdminClientConfig values:
	bootstrap.servers = [SERVER]
	client.dns.lookup = use_all_dns_ips
	client.id =
	connections.max.idle.ms = 300000
	default.api.timeout.ms = 60000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOMNE_LOCATION
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:372)
[2021-06-11 19:13:25,996] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin:61)
[2021-06-11 19:13:26,043] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,044] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,044] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,044] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,044] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,044] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,044] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,044] WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,044] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,044] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,044] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,044] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,044] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,045] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,046] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,046] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,046] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,046] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,046] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,046] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,046] WARN The configuration 'consumer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,046] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:26,046] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:26,046] INFO Kafka startTimeMs: 1623438806046 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:26,144] INFO Kafka cluster ID: zoOepbg8Sx-miAtUIcP1vw (org.apache.kafka.connect.util.ConnectUtils:65)
[2021-06-11 19:13:26,145] INFO App info kafka.admin.client for adminclient-7 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2021-06-11 19:13:26,147] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2021-06-11 19:13:26,147] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2021-06-11 19:13:26,147] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2021-06-11 19:13:26,151] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin:61)
[2021-06-11 19:13:26,214] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:26,214] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:26,214] INFO Kafka startTimeMs: 1623438806214 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:26,217] INFO Kafka Connect distributed worker initialization took 6547ms (org.apache.kafka.connect.cli.ConnectDistributed:138)
[2021-06-11 19:13:26,217] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:51)
[2021-06-11 19:13:26,218] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer:224)
[2021-06-11 19:13:26,218] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder:308)
[2021-06-11 19:13:26,219] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:195)
[2021-06-11 19:13:26,219] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:144)
[2021-06-11 19:13:26,219] INFO Starting KafkaBasedLog with topic criteria-test-debezium-offset (org.apache.kafka.connect.util.KafkaBasedLog:162)
[2021-06-11 19:13:26,221] INFO AdminClientConfig values:
	bootstrap.servers = [SERVER]
	client.dns.lookup = use_all_dns_ips
	client.id =
	connections.max.idle.ms = 300000
	default.api.timeout.ms = 60000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOMNE_LOCATION
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:372)
[2021-06-11 19:13:26,262] INFO Adding admin resources to main listener (org.apache.kafka.connect.runtime.rest.RestServer:241)
[2021-06-11 19:13:26,287] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,291] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,291] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,292] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,292] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,292] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,292] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,292] WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,292] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,293] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,293] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,293] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,293] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,293] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,293] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,294] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,294] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,294] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,294] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,294] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,294] WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,298] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,298] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,298] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,298] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,298] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,298] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,299] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,299] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,299] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,299] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,299] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,299] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,299] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,300] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,300] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,300] WARN The configuration 'consumer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380)
[2021-06-11 19:13:26,300] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:26,304] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:26,305] INFO Kafka startTimeMs: 1623438806300 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:26,354] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:334)
[2021-06-11 19:13:26,354] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:339)
[2021-06-11 19:13:26,356] INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session:132)
[2021-06-11 19:13:26,651] INFO ProducerConfig values:
	acks = -1
	batch.size = 16384
	bootstrap.servers = [SERVER]
	buffer.memory = 33554432
	client.dns.lookup = use_all_dns_ips
	client.id = producer-1
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 2147483647
	enable.idempotence = false
	interceptor.classes = []
	internal.auto.downgrade.txn.commit = false
	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
	metadata.max.idle.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 = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOMNE_LOCATION
	ssl.truststore.password = [hidden]
	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:372)
Jun 11, 2021 7:13:26 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResource will be ignored.
Jun 11, 2021 7:13:26 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource will be ignored.
Jun 11, 2021 7:13:26 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource will be ignored.
Jun 11, 2021 7:13:26 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource will be ignored.
[2021-06-11 19:13:26,755] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,755] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,755] WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,755] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,756] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,756] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,756] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,756] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,756] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,756] WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,756] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,756] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,756] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,756] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,756] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,756] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,757] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,757] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,757] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,757] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,757] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,757] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,757] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,757] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,757] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,757] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,758] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,758] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,758] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,758] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,758] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,758] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,758] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,758] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,758] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,758] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,758] WARN The configuration 'consumer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:26,759] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:26,759] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:26,759] INFO Kafka startTimeMs: 1623438806758 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:26,782] INFO ConsumerConfig values:
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [SERVER]
	check.crcs = true
	client.dns.lookup = use_all_dns_ips
	client.id = consumer-criteria-test-debezium-connect-1
	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 = criteria-test-debezium-connect
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	internal.throw.on.fetch.stable.offset.unsupported = false
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	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 = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOMNE_LOCATION
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:372)
[2021-06-11 19:13:26,860] INFO [Producer clientId=producer-1] Cluster ID: zoOepbg8Sx-miAtUIcP1vw (org.apache.kafka.clients.Metadata:279)
[2021-06-11 19:13:26,911] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,919] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,919] WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,919] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,919] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,919] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,919] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,919] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,919] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,919] WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,919] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,920] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,921] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,921] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,921] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,921] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,921] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,921] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,921] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,921] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,921] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,921] WARN The configuration 'consumer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:26,921] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:26,922] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:26,922] INFO Kafka startTimeMs: 1623438806921 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:26,990] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Cluster ID: zoOepbg8Sx-miAtUIcP1vw (org.apache.kafka.clients.Metadata:279)
[2021-06-11 19:13:26,997] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Subscribed to partition(s): criteria-test-debezium-offset-0, criteria-test-debezium-offset-10, criteria-test-debezium-offset-20, criteria-test-debezium-offset-40, criteria-test-debezium-offset-30, criteria-test-debezium-offset-9, criteria-test-debezium-offset-39, criteria-test-debezium-offset-11, criteria-test-debezium-offset-31, criteria-test-debezium-offset-13, criteria-test-debezium-offset-18, criteria-test-debezium-offset-22, criteria-test-debezium-offset-32, criteria-test-debezium-offset-8, criteria-test-debezium-offset-43, criteria-test-debezium-offset-29, criteria-test-debezium-offset-34, criteria-test-debezium-offset-1, criteria-test-debezium-offset-6, criteria-test-debezium-offset-41, criteria-test-debezium-offset-27, criteria-test-debezium-offset-48, criteria-test-debezium-offset-5, criteria-test-debezium-offset-15, criteria-test-debezium-offset-35, criteria-test-debezium-offset-25, criteria-test-debezium-offset-46, criteria-test-debezium-offset-26, criteria-test-debezium-offset-36, criteria-test-debezium-offset-44, criteria-test-debezium-offset-16, criteria-test-debezium-offset-37, criteria-test-debezium-offset-17, criteria-test-debezium-offset-45, criteria-test-debezium-offset-3, criteria-test-debezium-offset-4, criteria-test-debezium-offset-24, criteria-test-debezium-offset-38, criteria-test-debezium-offset-33, criteria-test-debezium-offset-23, criteria-test-debezium-offset-28, criteria-test-debezium-offset-2, criteria-test-debezium-offset-12, criteria-test-debezium-offset-19, criteria-test-debezium-offset-14, criteria-test-debezium-offset-47, criteria-test-debezium-offset-49, criteria-test-debezium-offset-42, criteria-test-debezium-offset-7, criteria-test-debezium-offset-21 (org.apache.kafka.clients.consumer.KafkaConsumer:1120)
[2021-06-11 19:13:27,000] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,001] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-10 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,001] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-20 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,001] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-40 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,002] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-30 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,002] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-9 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,002] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-39 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,002] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-11 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,002] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-31 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,002] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-13 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,002] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-18 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,003] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-22 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,003] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-32 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,003] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-8 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,003] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-43 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,003] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-29 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,003] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-34 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,003] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,004] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-6 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,004] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-41 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,004] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-27 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,004] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-48 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,004] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-5 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,004] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-15 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,004] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-35 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,004] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-25 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,005] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-46 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,005] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-26 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,005] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-36 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,005] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-44 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,005] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-16 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,005] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-37 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,005] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-17 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,005] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-45 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,005] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,006] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,006] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-24 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,006] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-38 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,006] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-33 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,006] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-23 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,006] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-28 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,006] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,006] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-12 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,006] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-19 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,006] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-14 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,006] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-47 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,007] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-49 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,007] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-42 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,007] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-7 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,007] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-21 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
Jun 11, 2021 7:13:27 PM org.glassfish.jersey.internal.Errors logErrors
WARNING: The following warnings have been detected: WARNING: The (sub)resource method listLoggers in org.apache.kafka.connect.runtime.rest.resources.LoggingResource contains empty path annotation.
WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation.
WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation.
[2021-06-11 19:13:27,040] INFO Started o.e.j.s.ServletContextHandler@999b951{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:916)
[2021-06-11 19:13:27,041] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:319)
[2021-06-11 19:13:27,041] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:57)
[2021-06-11 19:13:27,282] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-19 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,282] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-25 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,283] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-22 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,283] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-13 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,283] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-10 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,283] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-43 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,283] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-16 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,284] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-49 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,284] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-46 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,284] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,284] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-37 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,284] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-34 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,285] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-40 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,285] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-7 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,285] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-28 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,285] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,285] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-31 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,295] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-20 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,296] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-23 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,296] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-44 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,296] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-11 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,297] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-17 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,297] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-14 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,297] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-47 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,297] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-5 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,297] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,297] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-35 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,298] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-8 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,298] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-41 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,298] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-38 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,298] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-29 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,298] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-26 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,298] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-32 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,300] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-21 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,300] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-18 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,300] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-24 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,300] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-12 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,300] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-45 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,301] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-42 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,301] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-48 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,301] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-15 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,301] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-36 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,301] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,302] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-9 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,302] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-6 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,302] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-39 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,302] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-27 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,302] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,302] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-33 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,303] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-30 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,304] INFO Finished reading KafkaBasedLog for topic criteria-test-debezium-offset (org.apache.kafka.connect.util.KafkaBasedLog:202)
[2021-06-11 19:13:27,304] INFO Started KafkaBasedLog for topic criteria-test-debezium-offset (org.apache.kafka.connect.util.KafkaBasedLog:204)
[2021-06-11 19:13:27,304] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:146)
[2021-06-11 19:13:27,307] INFO Worker started (org.apache.kafka.connect.runtime.Worker:202)
[2021-06-11 19:13:27,307] INFO Starting KafkaBasedLog with topic criteria-test-debezium-status (org.apache.kafka.connect.util.KafkaBasedLog:162)
[2021-06-11 19:13:27,453] INFO ProducerConfig values:
	acks = -1
	batch.size = 16384
	bootstrap.servers = [SERVER]
	buffer.memory = 33554432
	client.dns.lookup = use_all_dns_ips
	client.id = producer-2
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 120000
	enable.idempotence = false
	interceptor.classes = []
	internal.auto.downgrade.txn.commit = false
	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
	metadata.max.idle.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 = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOMNE_LOCATION
	ssl.truststore.password = [hidden]
	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:372)
[2021-06-11 19:13:27,504] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,504] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,504] WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,504] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,504] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,505] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,505] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,505] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,505] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,505] WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,505] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,505] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,505] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,505] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,505] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,506] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,506] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,506] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,506] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,506] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,506] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,506] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,506] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,506] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,506] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,506] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,507] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,507] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,507] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,507] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,507] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,507] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,507] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,507] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,507] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,507] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,507] WARN The configuration 'consumer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:27,508] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:27,508] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:27,508] INFO Kafka startTimeMs: 1623438807508 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:27,509] INFO ConsumerConfig values:
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [SERVER]
	check.crcs = true
	client.dns.lookup = use_all_dns_ips
	client.id = consumer-criteria-test-debezium-connect-2
	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 = criteria-test-debezium-connect
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	internal.throw.on.fetch.stable.offset.unsupported = false
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	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 = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOMNE_LOCATION
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:372)
[2021-06-11 19:13:27,562] INFO [Producer clientId=producer-2] Cluster ID: zoOepbg8Sx-miAtUIcP1vw (org.apache.kafka.clients.Metadata:279)
[2021-06-11 19:13:27,574] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,574] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,575] WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,575] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,575] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,575] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,575] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,575] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,575] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,575] WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,575] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,575] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,576] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,576] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,576] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,576] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,576] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,576] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,576] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,576] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,576] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,576] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,576] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,576] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,577] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,577] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,577] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,577] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,577] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,577] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,577] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,577] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,577] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,577] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,577] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,577] WARN The configuration 'consumer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:27,578] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:27,578] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:27,578] INFO Kafka startTimeMs: 1623438807578 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:27,655] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Cluster ID: zoOepbg8Sx-miAtUIcP1vw (org.apache.kafka.clients.Metadata:279)
[2021-06-11 19:13:27,658] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Subscribed to partition(s): criteria-test-debezium-status-0, criteria-test-debezium-status-5, criteria-test-debezium-status-2, criteria-test-debezium-status-8, criteria-test-debezium-status-9, criteria-test-debezium-status-4, criteria-test-debezium-status-1, criteria-test-debezium-status-6, criteria-test-debezium-status-7, criteria-test-debezium-status-3 (org.apache.kafka.clients.consumer.KafkaConsumer:1120)
[2021-06-11 19:13:27,658] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,658] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-5 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,658] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,658] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-8 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,658] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-9 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,658] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,659] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,659] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-6 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,659] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-7 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,659] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:27,810] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-status-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,810] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-status-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,810] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-status-7 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 3 rack: use1-az1)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,816] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-status-9 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,816] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-status-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,816] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-status-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,816] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-status-6 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2 rack: use1-az6)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,823] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-status-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,823] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-status-8 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,823] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-2, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-status-5 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:27,906] INFO Finished reading KafkaBasedLog for topic criteria-test-debezium-status (org.apache.kafka.connect.util.KafkaBasedLog:202)
[2021-06-11 19:13:27,907] INFO Started KafkaBasedLog for topic criteria-test-debezium-status (org.apache.kafka.connect.util.KafkaBasedLog:204)
[2021-06-11 19:13:27,908] INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:275)
[2021-06-11 19:13:27,908] INFO Starting KafkaBasedLog with topic criteria-test-debezium-config (org.apache.kafka.connect.util.KafkaBasedLog:162)
[2021-06-11 19:13:28,009] INFO ProducerConfig values:
	acks = -1
	batch.size = 16384
	bootstrap.servers = [SERVER]
	buffer.memory = 33554432
	client.dns.lookup = use_all_dns_ips
	client.id = producer-3
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 2147483647
	enable.idempotence = false
	interceptor.classes = []
	internal.auto.downgrade.txn.commit = false
	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
	metadata.max.idle.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 = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOMNE_LOCATION
	ssl.truststore.password = [hidden]
	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:372)
[2021-06-11 19:13:28,049] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,049] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,050] WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,050] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,050] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,050] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,050] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,052] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,052] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,052] WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,052] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,052] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,052] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,052] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,052] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,052] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,052] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,052] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,052] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,052] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,053] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,053] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,053] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,053] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,053] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,053] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,053] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,053] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,053] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,053] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,053] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,053] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,053] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,053] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,054] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,054] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,054] WARN The configuration 'consumer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:28,054] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:28,054] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:28,054] INFO Kafka startTimeMs: 1623438808054 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:28,055] INFO ConsumerConfig values:
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [SERVER]
	check.crcs = true
	client.dns.lookup = use_all_dns_ips
	client.id = consumer-criteria-test-debezium-connect-3
	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 = criteria-test-debezium-connect
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	internal.throw.on.fetch.stable.offset.unsupported = false
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	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 = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOMNE_LOCATION
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:372)
[2021-06-11 19:13:28,109] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,109] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,109] WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,110] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,110] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,110] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,110] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,110] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,110] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,110] WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,110] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,110] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,110] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,110] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,110] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,110] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,111] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,111] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,111] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,111] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,111] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,111] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,111] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,111] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,111] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,111] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,111] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,111] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,111] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,112] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,112] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,112] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,112] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,112] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,112] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,112] WARN The configuration 'consumer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380)
[2021-06-11 19:13:28,112] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:28,112] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:28,112] INFO Kafka startTimeMs: 1623438808112 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:28,119] INFO [Producer clientId=producer-3] Cluster ID: zoOepbg8Sx-miAtUIcP1vw (org.apache.kafka.clients.Metadata:279)
[2021-06-11 19:13:28,163] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-3, groupId=criteria-test-debezium-connect] Cluster ID: zoOepbg8Sx-miAtUIcP1vw (org.apache.kafka.clients.Metadata:279)
[2021-06-11 19:13:28,166] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-3, groupId=criteria-test-debezium-connect] Subscribed to partition(s): criteria-test-debezium-config-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1120)
[2021-06-11 19:13:28,166] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-3, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-config-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619)
[2021-06-11 19:13:28,328] INFO [Consumer clientId=consumer-criteria-test-debezium-connect-3, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-config-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 1 rack: use1-az4)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2021-06-11 19:13:28,394] INFO Finished reading KafkaBasedLog for topic criteria-test-debezium-config (org.apache.kafka.connect.util.KafkaBasedLog:202)
[2021-06-11 19:13:28,394] INFO Started KafkaBasedLog for topic criteria-test-debezium-config (org.apache.kafka.connect.util.KafkaBasedLog:204)
[2021-06-11 19:13:28,394] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:290)
[2021-06-11 19:13:28,394] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:312)
[2021-06-11 19:13:28,973] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Cluster ID: zoOepbg8Sx-miAtUIcP1vw (org.apache.kafka.clients.Metadata:279)
[2021-06-11 19:13:29,015] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Discovered group coordinator b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: 2147483645 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:848)
[2021-06-11 19:13:29,018] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:221)
[2021-06-11 19:13:29,018] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:538)
[2021-06-11 19:13:29,065] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:538)
[2021-06-11 19:13:32,067] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Successfully joined group with generation Generation{generationId=11, memberId='connect-1-9e9cc463-f202-4d15-bf42-a27070b76944', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:594)
[2021-06-11 19:13:32,090] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Successfully synced group in generation Generation{generationId=11, memberId='connect-1-9e9cc463-f202-4d15-bf42-a27070b76944', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:758)
[2021-06-11 19:13:32,091] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Joined group at generation 11 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-9e9cc463-f202-4d15-bf42-a27070b76944', leaderUrl='http://up-crit-debezium-iam-msk-test-4.dm.vpc:8083/', offset=80, connectorIds=[criteria-test-cdc-iam-msk], taskIds=[criteria-test-cdc-iam-msk-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1693)
[2021-06-11 19:13:32,092] WARN [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Catching up to assignment's config offset. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1119)
[2021-06-11 19:13:32,092] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Current config state offset -1 is behind group assignment 80, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1183)
[2021-06-11 19:13:32,107] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Finished reading to end of log and updated config snapshot, new config log offset: 80 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1190)
[2021-06-11 19:13:32,107] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Starting connectors and tasks using config offset 80 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1244)
[2021-06-11 19:13:32,108] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Starting task criteria-test-cdc-iam-msk-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1286)
[2021-06-11 19:13:32,109] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Starting connector criteria-test-cdc-iam-msk (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1321)
[2021-06-11 19:13:32,114] INFO Creating task criteria-test-cdc-iam-msk-0 (org.apache.kafka.connect.runtime.Worker:509)
[2021-06-11 19:13:32,115] INFO Creating connector criteria-test-cdc-iam-msk of type io.debezium.connector.mysql.MySqlConnector (org.apache.kafka.connect.runtime.Worker:274)
[2021-06-11 19:13:32,118] INFO ConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mysql.MySqlConnector
	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 = criteria-test-cdc-iam-msk
	predicates = []
	tasks.max = 1
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:372)
[2021-06-11 19:13:32,118] INFO SourceConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mysql.MySqlConnector
	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 = criteria-test-cdc-iam-msk
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SourceConnectorConfig:372)
[2021-06-11 19:13:32,120] INFO EnrichedConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mysql.MySqlConnector
	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 = criteria-test-cdc-iam-msk
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372)
[2021-06-11 19:13:32,120] INFO EnrichedConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mysql.MySqlConnector
	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 = criteria-test-cdc-iam-msk
	predicates = []
	tasks.max = 1
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372)
[2021-06-11 19:13:32,125] INFO Instantiated connector criteria-test-cdc-iam-msk with version 1.5.0.Final of type class io.debezium.connector.mysql.MySqlConnector (org.apache.kafka.connect.runtime.Worker:284)
[2021-06-11 19:13:32,127] INFO Finished creating connector criteria-test-cdc-iam-msk (org.apache.kafka.connect.runtime.Worker:310)
[2021-06-11 19:13:32,137] INFO TaskConfig values:
	task.class = class io.debezium.connector.mysql.MySqlConnectorTask
 (org.apache.kafka.connect.runtime.TaskConfig:372)
[2021-06-11 19:13:32,139] INFO Instantiated task criteria-test-cdc-iam-msk-0 with version 1.5.0.Final of type io.debezium.connector.mysql.MySqlConnectorTask (org.apache.kafka.connect.runtime.Worker:524)
[2021-06-11 19:13:32,140] INFO StringConverterConfig values:
	converter.encoding = UTF8
	converter.type = key
 (org.apache.kafka.connect.storage.StringConverterConfig:372)
[2021-06-11 19:13:32,140] INFO Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task criteria-test-cdc-iam-msk-0 using the worker config (org.apache.kafka.connect.runtime.Worker:537)
[2021-06-11 19:13:32,141] INFO JsonConverterConfig values:
	converter.type = value
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig:372)
[2021-06-11 19:13:32,142] INFO Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task criteria-test-cdc-iam-msk-0 using the worker config (org.apache.kafka.connect.runtime.Worker:543)
[2021-06-11 19:13:32,142] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task criteria-test-cdc-iam-msk-0 using the worker config (org.apache.kafka.connect.runtime.Worker:550)
[2021-06-11 19:13:32,145] INFO SourceConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mysql.MySqlConnector
	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 = criteria-test-cdc-iam-msk
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SourceConnectorConfig:372)
[2021-06-11 19:13:32,146] INFO EnrichedConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mysql.MySqlConnector
	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 = criteria-test-cdc-iam-msk
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372)
[2021-06-11 19:13:32,149] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:606)
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
[2021-06-11 19:13:32,157] INFO ProducerConfig values:
	acks = -1
	batch.size = 16384
	bootstrap.servers = [SERVER]
	buffer.memory = 33554432
	client.dns.lookup = use_all_dns_ips
	client.id = connector-producer-criteria-test-cdc-iam-msk-0
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 2147483647
	enable.idempotence = false
	interceptor.classes = []
	internal.auto.downgrade.txn.commit = false
	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 = 5000000
	metadata.max.age.ms = 300000
	metadata.max.idle.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partitioner.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 = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOMNE_LOCATION
	ssl.truststore.password = [hidden]
	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:372)
[2021-06-11 19:13:32,221] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:32,222] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380)
[2021-06-11 19:13:32,222] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:32,222] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:32,223] INFO Kafka startTimeMs: 1623438812222 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:32,241] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1272)
[2021-06-11 19:13:32,274] INFO [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Failed authentication with b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com/172.19.35.253 (An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state.) (org.apache.kafka.common.network.Selector:616)
[2021-06-11 19:13:32,276] ERROR [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Connection to node -2 (b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com/172.19.35.253:9098) failed authentication due to: An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state. (org.apache.kafka.clients.NetworkClient:765)
[2021-06-11 19:13:32,277] WARN [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Bootstrap broker b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: -2 rack: null) disconnected (org.apache.kafka.clients.NetworkClient:1060)
[2021-06-11 19:13:32,315] WARN Using configuration property "table.whitelist" is deprecated and will be removed in future versions. Please use "table.include.list" instead. (io.debezium.config.Configuration:2132)
[2021-06-11 19:13:32,318] INFO Starting MySqlConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask:124)
[2021-06-11 19:13:32,343] INFO    connector.class = io.debezium.connector.mysql.MySqlConnector (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,344] INFO    snapshot.locking.mode = minimal (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,344] INFO    tasks.max = 1 (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,344] INFO    database.history.consumer.sasl.jaas.config = ******** (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,345] INFO    database.history.kafka.topic = criteria-test.schema-changes (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,345] INFO    database.history.producer.sasl.client.callback.handler.class = software.amazon.msk.auth.iam.IAMClientCallbackHandler (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,345] INFO    database.history.consumer.ssl.truststore.password = ******** (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,346] INFO    database.history.consumer.sasl.client.callback.handler.class = software.amazon.msk.auth.iam.IAMClientCallbackHandler (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,346] INFO    database.history.consumer.security.protocol = SASL_SSL (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,346] INFO    database.history.consumer.ssl.truststore.location = SOMNE_LOCATION (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,347] INFO    include.schema.changes = true (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,347] INFO    table.whitelist = usrcridb.DEFAULT_WATCHLIST_NOTIFICATIONS_TBL,usrcridb.SHARED_FOLDERS_TBL,usrcridb.SHARED_WATCHLISTS_TBL,usrcridb.USER_COMPANIES_TBL,usrcridb.USER_CUSTOMS_TBL,usrcridb.USER_FOCUSES_TBL,usrcridb.USER_RULES_TBL,usrcridb.USER_SECTORS_TBL,usrcridb.USER_TOPICS_TBL,usrcridb.USER_WATCHLIST_NOTIFICATIONS_TBL,usrcridb.USER_WATCHLIST_TBL,usrcridb.WATCHLIST_COMPONENTS_TBL,usrcridb.WATCHLIST_FOLDERS_TBL,usrcridb.WATCHLIST_SUBSCRIPTIONS_TBL,usrcridb.WL_GEO_WATCHLIST_TBL (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,347] INFO    database.history.ssl.truststore.password = ******** (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,348] INFO    database.history.skip.unparseable.ddl = true (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,348] INFO    database.whitelist = usrcridb (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,348] INFO    database.history.sasl.mechanism = AWS_MSK_IAM (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,349] INFO    database.history.producer.sasl.mechanism = AWS_MSK_IAM (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,349] INFO    database.history.producer.sasl.jaas.config = ******** (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,349] INFO    database.history.ssl.truststore.location = SOMNE_LOCATION (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,350] INFO    database.history.sasl.jaas.config = ******** (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,350] INFO    database.user = debezium (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,350] INFO    database.server.id = 139140890 (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,351] INFO    database.history.producer.security.protocol = SASL_SSL (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,351] INFO    database.history.kafka.bootstrap.servers = b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098,b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098,b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,351] INFO    database.history.producer.ssl.truststore.location = SOMNE_LOCATION (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,352] INFO    database.server.name = criteria (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,352] INFO    database.port = 3306 (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,352] INFO    inconsistent.schema.handling.mode = warn (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,352] INFO    database.history.producer.ssl.truststore.password = ******** (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,353] INFO    task.class = io.debezium.connector.mysql.MySqlConnectorTask (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,353] INFO    database.hostname = criteria-service-test-replica-1.cyrouu1r1adh.us-east-1.rds.amazonaws.com (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,353] INFO    database.history.sasl.client.callback.handler.class = software.amazon.msk.auth.iam.IAMClientCallbackHandler (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,354] INFO    database.password = ******** (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,354] INFO    name = criteria-test-cdc-iam-msk (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,355] INFO    database.history.store.only.monitored.tables.ddl = true (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,355] INFO    database.history.security.protocol = SASL_SSL (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,355] INFO    database.history.consumer.sasl.mechanism = AWS_MSK_IAM (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,355] INFO    snapshot.mode = schema_only (io.debezium.connector.common.BaseSourceTask:126)
[2021-06-11 19:13:32,379] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Session key updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1582)
[2021-06-11 19:13:32,397] INFO SourceConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mysql.MySqlConnector
	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 = criteria-test-cdc-iam-msk
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SourceConnectorConfig:372)
[2021-06-11 19:13:32,399] INFO EnrichedConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mysql.MySqlConnector
	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 = criteria-test-cdc-iam-msk
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372)
[2021-06-11 19:13:32,416] INFO [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Failed authentication with b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com/172.19.50.29 (An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state.) (org.apache.kafka.common.network.Selector:616)
[2021-06-11 19:13:32,417] ERROR [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Connection to node -3 (b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com/172.19.50.29:9098) failed authentication due to: An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state. (org.apache.kafka.clients.NetworkClient:765)
[2021-06-11 19:13:32,418] WARN [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Bootstrap broker b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: -3 rack: null) disconnected (org.apache.kafka.clients.NetworkClient:1060)
[2021-06-11 19:13:32,545] INFO [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Failed authentication with b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com/172.19.43.213 (An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state.) (org.apache.kafka.common.network.Selector:616)
[2021-06-11 19:13:32,546] ERROR [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Connection to node -1 (b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com/172.19.43.213:9098) failed authentication due to: An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state. (org.apache.kafka.clients.NetworkClient:765)
[2021-06-11 19:13:32,548] WARN [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Bootstrap broker b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient:1060)
[2021-06-11 19:13:32,636] INFO No previous offset found (io.debezium.connector.mysql.MySqlConnectorTask:89)
[2021-06-11 19:13:32,679] INFO [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Failed authentication with b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com/172.19.35.253 (An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state.) (org.apache.kafka.common.network.Selector:616)
[2021-06-11 19:13:32,680] ERROR [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Connection to node -2 (b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com/172.19.35.253:9098) failed authentication due to: An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state. (org.apache.kafka.clients.NetworkClient:765)
[2021-06-11 19:13:32,680] WARN [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Bootstrap broker b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: -2 rack: null) disconnected (org.apache.kafka.clients.NetworkClient:1060)
[2021-06-11 19:13:32,690] INFO KafkaDatabaseHistory Consumer config: {key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=criteria-dbhistory, bootstrap.servers=b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098,b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098,b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098, security.protocol=SASL_SSL, ssl.truststore.location=SOMNE_LOCATION, enable.auto.commit=false, sasl.mechanism=AWS_MSK_IAM, sasl.jaas.config=********, sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler, fetch.min.bytes=1, ssl.truststore.password=********, session.timeout.ms=10000, auto.offset.reset=earliest, client.id=criteria-dbhistory} (io.debezium.relational.history.KafkaDatabaseHistory:215)
[2021-06-11 19:13:32,690] INFO KafkaDatabaseHistory Producer config: {batch.size=32768, acks=1, bootstrap.servers=b-3.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098,b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098,b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098, buffer.memory=1048576, key.serializer=org.apache.kafka.common.serialization.StringSerializer, security.protocol=SASL_SSL, retries=1, ssl.truststore.location=SOMNE_LOCATION, value.serializer=org.apache.kafka.common.serialization.StringSerializer, sasl.mechanism=AWS_MSK_IAM, sasl.jaas.config=********, max.block.ms=10000, sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler, ssl.truststore.password=********, client.id=criteria-dbhistory, linger.ms=0} (io.debezium.relational.history.KafkaDatabaseHistory:216)
[2021-06-11 19:13:32,691] INFO Requested thread factory for connector MySqlConnector, id = criteria named = db-history-config-check (io.debezium.util.Threads:270)
[2021-06-11 19:13:32,694] INFO ProducerConfig values:
	acks = 1
	batch.size = 32768
	bootstrap.servers = [SERVER]
	buffer.memory = 1048576
	client.dns.lookup = use_all_dns_ips
	client.id = criteria-dbhistory
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 120000
	enable.idempotence = false
	interceptor.classes = []
	internal.auto.downgrade.txn.commit = false
	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
	linger.ms = 0
	max.block.ms = 10000
	max.in.flight.requests.per.connection = 5
	max.request.size = 1048576
	metadata.max.age.ms = 300000
	metadata.max.idle.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partitioner.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 = 1
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOMNE_LOCATION
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
	transaction.timeout.ms = 60000
	transactional.id = null
	value.serializer = class org.apache.kafka.common.serialization.StringSerializer
 (org.apache.kafka.clients.producer.ProducerConfig:372)
[2021-06-11 19:13:32,753] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:32,753] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:32,753] INFO Kafka startTimeMs: 1623438812752 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:32,788] INFO Connector started for the first time, database history recovery will not be executed (io.debezium.connector.mysql.MySqlConnectorTask:288)
[2021-06-11 19:13:32,790] INFO ConsumerConfig values:
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [SERVER]
	check.crcs = true
	client.dns.lookup = use_all_dns_ips
	client.id = criteria-dbhistory
	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 = criteria-dbhistory
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	internal.throw.on.fetch.stable.offset.unsupported = false
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	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 = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	sasl.jaas.config = [hidden]
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = SOMNE_LOCATION
	ssl.truststore.password = [hidden]
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:372)
[2021-06-11 19:13:32,802] INFO [Producer clientId=criteria-dbhistory] Failed authentication with b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com/172.19.35.253 (An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state.) (org.apache.kafka.common.network.Selector:616)
[2021-06-11 19:13:32,803] ERROR [Producer clientId=criteria-dbhistory] Connection to node -2 (b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com/172.19.35.253:9098) failed authentication due to: An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state. (org.apache.kafka.clients.NetworkClient:765)
[2021-06-11 19:13:32,804] WARN [Producer clientId=criteria-dbhistory] Bootstrap broker b-2.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: -2 rack: null) disconnected (org.apache.kafka.clients.NetworkClient:1060)
[2021-06-11 19:13:32,815] INFO [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Failed authentication with b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com/172.19.50.29 (An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state.) (org.apache.kafka.common.network.Selector:616)
[2021-06-11 19:13:32,816] ERROR [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Connection to node -3 (b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com/172.19.50.29:9098) failed authentication due to: An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state. (org.apache.kafka.clients.NetworkClient:765)
[2021-06-11 19:13:32,816] WARN [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Bootstrap broker b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: -3 rack: null) disconnected (org.apache.kafka.clients.NetworkClient:1060)
[2021-06-11 19:13:32,855] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-06-11 19:13:32,856] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser:120)
[2021-06-11 19:13:32,856] INFO Kafka startTimeMs: 1623438812855 (org.apache.kafka.common.utils.AppInfoParser:121)
[2021-06-11 19:13:32,887] INFO [Consumer clientId=criteria-dbhistory, groupId=criteria-dbhistory] Failed authentication with b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com/172.19.50.29 (An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state.) (org.apache.kafka.common.network.Selector:616)
[2021-06-11 19:13:32,887] ERROR [Consumer clientId=criteria-dbhistory, groupId=criteria-dbhistory] Connection to node -3 (b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com/172.19.50.29:9098) failed authentication due to: An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state. (org.apache.kafka.clients.NetworkClient:765)
[2021-06-11 19:13:32,888] WARN [Consumer clientId=criteria-dbhistory, groupId=criteria-dbhistory] Bootstrap broker b-1.evaluate-iam-auth-test.0jd3vm.c4.kafka.us-east-1.amazonaws.com:9098 (id: -3 rack: null) disconnected (org.apache.kafka.clients.NetworkClient:1060)
[2021-06-11 19:13:32,888] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2021-06-11 19:13:32,888] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2021-06-11 19:13:32,889] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2021-06-11 19:13:32,890] INFO App info kafka.consumer for criteria-dbhistory unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2021-06-11 19:13:32,890] INFO WorkerSourceTask{id=criteria-test-cdc-iam-msk-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:487)
[2021-06-11 19:13:32,891] ERROR WorkerSourceTask{id=criteria-test-cdc-iam-msk-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:184)
org.apache.kafka.common.errors.SaslAuthenticationException: An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]) occurred when evaluating SASL token received from the Kafka Broker. Kafka Client will go to AUTHENTICATION_FAILED state.
Caused by: javax.security.sasl.SaslException: Exception while evaluating challenge [Caused by javax.security.auth.callback.UnsupportedCallbackException]
	at software.amazon.msk.auth.iam.internals.IAMSaslClient.evaluateChallenge(IAMSaslClient.java:113)
	at org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.lambda$createSaslToken$1(SaslClientAuthenticator.java:534)
	at java.base/java.security.AccessController.doPrivileged(Native Method)
	at java.base/javax.security.auth.Subject.doAs(Subject.java:423)
	at org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.createSaslToken(SaslClientAuthenticator.java:534)
	at org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.sendSaslClientToken(SaslClientAuthenticator.java:433)
	at org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.sendInitialToken(SaslClientAuthenticator.java:332)
	at org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.authenticate(SaslClientAuthenticator.java:273)
	at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:181)
	at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543)
	at org.apache.kafka.common.network.Selector.poll(Selector.java:481)
	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:561)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:265)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:215)
	at org.apache.kafka.clients.consumer.internals.Fetcher.getTopicMetadata(Fetcher.java:374)
	at org.apache.kafka.clients.consumer.internals.Fetcher.getAllTopicMetadata(Fetcher.java:357)
	at org.apache.kafka.clients.consumer.KafkaConsumer.listTopics(KafkaConsumer.java:1994)
	at org.apache.kafka.clients.consumer.KafkaConsumer.listTopics(KafkaConsumer.java:1972)
	at io.debezium.relational.history.KafkaDatabaseHistory.storageExists(KafkaDatabaseHistory.java:353)
	at io.debezium.relational.HistorizedRelationalDatabaseSchema.initializeStorage(HistorizedRelationalDatabaseSchema.java:67)
	at io.debezium.connector.mysql.MySqlDatabaseSchema.initializeStorage(MySqlDatabaseSchema.java:362)
	at io.debezium.connector.mysql.MySqlConnectorTask.validateAndLoadDatabaseHistory(MySqlConnectorTask.java:289)
	at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:96)
	at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:130)
	at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:224)
	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:182)
	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:231)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: javax.security.auth.callback.UnsupportedCallbackException
	at software.amazon.msk.auth.iam.IAMClientCallbackHandler.handle(IAMClientCallbackHandler.java:68)
	at software.amazon.msk.auth.iam.internals.IAMSaslClient.generateClientMessage(IAMSaslClient.java:138)
	at software.amazon.msk.auth.iam.internals.IAMSaslClient.evaluateChallenge(IAMSaslClient.java:95)
	... 32 more
[2021-06-11 19:13:32,896] INFO Stopping down connector (io.debezium.connector.common.BaseSourceTask:238)
[2021-06-11 19:13:32,925] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:946)
[2021-06-11 19:13:32,926] INFO [Producer clientId=criteria-dbhistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1204)
[2021-06-11 19:13:32,929] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2021-06-11 19:13:32,929] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2021-06-11 19:13:32,929] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2021-06-11 19:13:32,929] INFO App info kafka.producer for criteria-dbhistory unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2021-06-11 19:13:32,930] INFO [Producer clientId=connector-producer-criteria-test-cdc-iam-msk-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1204)
[2021-06-11 19:13:32,935] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2021-06-11 19:13:32,935] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2021-06-11 19:13:32,936] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2021-06-11 19:13:32,936] INFO App info kafka.producer for connector-producer-criteria-test-cdc-iam-msk-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[0] cluster "zoOepbg8Sx-miAtUIcP1vw" is up and running
[0] trying to create or update connector criteria-test-cdc-iam-msk
[2021-06-11 19:13:38,776] WARN Using configuration property "table.whitelist" is deprecated and will be removed in future versions. Please use "table.include.list" instead. (io.debezium.config.Configuration:2132)
[2021-06-11 19:13:38,791] INFO Successfully tested connection for jdbc:mysql://criteria-service-test-replica-1.cyrouu1r1adh.us-east-1.rds.amazonaws.com:3306/?useInformationSchema=true&nullCatalogMeansCurrent=false&useSSL=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=CONVERT_TO_NULL&connectTimeout=30000 with user 'debezium' (io.debezium.connector.mysql.MySqlConnector:100)
[2021-06-11 19:13:38,792] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:946)
[2021-06-11 19:13:38,798] INFO AbstractConfig values:
 (org.apache.kafka.common.config.AbstractConfig:372)
[2021-06-11 19:13:38,806] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Connector criteria-test-cdc-iam-msk config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1538)
[2021-06-11 19:13:38,815] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Handling connector-only config update by restarting connector criteria-test-cdc-iam-msk (org.apache.kafka.connect.runtime.distributed.DistributedHerder:620)
[2021-06-11 19:13:38,815] INFO Stopping connector criteria-test-cdc-iam-msk (org.apache.kafka.connect.runtime.Worker:387)
[2021-06-11 19:13:38,815] INFO Scheduled shutdown for WorkerConnector{id=criteria-test-cdc-iam-msk} (org.apache.kafka.connect.runtime.WorkerConnector:248)
[2021-06-11 19:13:38,816] INFO Completed shutdown for WorkerConnector{id=criteria-test-cdc-iam-msk} (org.apache.kafka.connect.runtime.WorkerConnector:268)
[2021-06-11 19:13:38,818] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Starting connector criteria-test-cdc-iam-msk (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1321)
[2021-06-11 19:13:38,819] INFO Creating connector criteria-test-cdc-iam-msk of type io.debezium.connector.mysql.MySqlConnector (org.apache.kafka.connect.runtime.Worker:274)
[2021-06-11 19:13:38,819] INFO SourceConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mysql.MySqlConnector
	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 = criteria-test-cdc-iam-msk
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SourceConnectorConfig:372)
[2021-06-11 19:13:38,819] INFO EnrichedConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mysql.MySqlConnector
	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 = criteria-test-cdc-iam-msk
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372)
[2021-06-11 19:13:38,822] INFO Instantiated connector criteria-test-cdc-iam-msk with version 1.5.0.Final of type class io.debezium.connector.mysql.MySqlConnector (org.apache.kafka.connect.runtime.Worker:284)
[2021-06-11 19:13:38,824] INFO Finished creating connector criteria-test-cdc-iam-msk (org.apache.kafka.connect.runtime.Worker:310)
[2021-06-11 19:13:38,825] INFO SourceConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mysql.MySqlConnector
	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 = criteria-test-cdc-iam-msk
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SourceConnectorConfig:372)
[2021-06-11 19:13:38,825] INFO EnrichedConnectorConfig values:
	config.action.reload = restart
	connector.class = io.debezium.connector.mysql.MySqlConnector
	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 = criteria-test-cdc-iam-msk
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372)
[0] connector criteria-test-cdc-iam-msk successful updated
[2021-06-11 19:14:32,234] INFO WorkerSourceTask{id=criteria-test-cdc-iam-msk-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:487)
[2021-06-11 19:15:32,235] INFO WorkerSourceTask{id=criteria-test-cdc-iam-msk-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:487)
[2021-06-11 19:16:32,236] INFO WorkerSourceTask{id=criteria-test-cdc-iam-msk-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:487)
[2021-06-11 19:17:32,236] INFO WorkerSourceTask{id=criteria-test-cdc-iam-msk-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:487)