2022-05-17 13:15:09,039 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] Connector TUN_TUN1_SB01_1652793308_123 config updated   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2022-05-17 13:15:09,039 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] Rebalance started   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2022-05-17 13:15:09,039 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] (Re-)joining group   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2022-05-17 13:15:09,042 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] Successfully joined group with generation Generation{generationId=226, memberId='connect-1-2f36602e-a9cc-4634-9969-63b08c4a2aee', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2022-05-17 13:15:09,046 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] Successfully synced group in generation Generation{generationId=226, memberId='connect-1-2f36602e-a9cc-4634-9969-63b08c4a2aee', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2022-05-17 13:15:09,047 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] Joined group at generation 226 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-92699213-a209-49ed-a2f6-fdfc299776df', leaderUrl='http://debezium-connector:8083/', offset=7529, connectorIds=[TUN_TUN1_SB01_1652793308_123, TUN_TUN1_PB15_1652786837_121, TUN_TUN1_PB1_1652785805_113, TUN_TUN1_PB4_1652783970_118, TUN_TUN1_PB2_1652783957_114, sbernhard_SBE1_PB50_Einsparung_1652783944_119, KGS2_KGS2_PB06_KGS2_PB07_1652783930_117, TUN_TUN1_PB8_1652783917_116, TUN_TUN1_PB2_1652783890_112, MRZ1_MRZ1_PB01_1652438239_108, TUN_TUN1_PB15_1652438380_100, sbernhard_SBE1_PB07_1650970854_5544, KGS2_KGS2_PB01_1650970598_5541, TUN_TUN1_PB3_1650975277_5552, TUN_TUN1_PB7_1652438273_109, TestDB_SBE1_PB01_test_1652438286_104, TUN_TUN1_PB6_1650975344_5557, TUN_TUN1_PB6_1650966275_5520, psa_APSApplicationItems_1652438326_115, KGS2_KGS2_PB05_1650970534_5537, KGS2_KGS2_PB02_1652435369_101, MRX-Giebel_GB3_1650970699_5543, sbernhard_SBE1_PB05_1650970921_5550, KGS2_KGS2_PB09_KGS2_PB10_KGS2_PB13_KGS2_PB15_1650970582_5539], taskIds=[TUN_TUN1_PB15_1652786837_121-0, TUN_TUN1_PB1_1652785805_113-0, TUN_TUN1_PB4_1652783970_118-0, TUN_TUN1_PB2_1652783957_114-0, KGS2_KGS2_PB06_KGS2_PB07_1652783930_117-0, sbernhard_SBE1_PB50_Einsparung_1652783944_119-0, TUN_TUN1_PB8_1652783917_116-0, TUN_TUN1_PB2_1652783890_112-0, MRZ1_MRZ1_PB01_1652438239_108-0, TUN_TUN1_PB15_1652438380_100-0, sbernhard_SBE1_PB07_1650970854_5544-0, KGS2_KGS2_PB01_1650970598_5541-0, TUN_TUN1_PB3_1650975277_5552-0, TUN_TUN1_PB7_1652438273_109-0, TestDB_SBE1_PB01_test_1652438286_104-0, TUN_TUN1_PB6_1650975344_5557-0, TUN_TUN1_PB6_1650966275_5520-0, psa_APSApplicationItems_1652438326_115-0, KGS2_KGS2_PB05_1650970534_5537-0, KGS2_KGS2_PB02_1652435369_101-0, MRX-Giebel_GB3_1650970699_5543-0, sbernhard_SBE1_PB05_1650970921_5550-0, KGS2_KGS2_PB09_KGS2_PB10_KGS2_PB13_KGS2_PB15_1650970582_5539-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2022-05-17 13:15:09,047 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] Starting connectors and tasks using config offset 7529   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2022-05-17 13:15:09,047 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] Starting connector TUN_TUN1_SB01_1652793308_123   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2022-05-17 13:15:09,047 INFO   ||  Creating connector TUN_TUN1_SB01_1652793308_123 of type io.debezium.connector.mysql.MySqlConnector   [org.apache.kafka.connect.runtime.Worker]
2022-05-17 13:15:09,047 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 = class org.apache.kafka.connect.json.JsonConverter
	name = TUN_TUN1_SB01_1652793308_123
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = [filter, Reroute]
	value.converter = class org.apache.kafka.connect.json.JsonConverter
   [org.apache.kafka.connect.runtime.SourceConnectorConfig]
2022-05-17 13:15:09,047 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 = class org.apache.kafka.connect.json.JsonConverter
	name = TUN_TUN1_SB01_1652793308_123
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = [filter, Reroute]
	transforms.Reroute.key.enforce.uniqueness = true
	transforms.Reroute.key.field.regex = null
	transforms.Reroute.key.field.replacement = null
	transforms.Reroute.negate = false
	transforms.Reroute.predicate = 
	transforms.Reroute.topic.regex = (.*)
	transforms.Reroute.topic.replacement = TUN_TUN1_SB01_1652793308_123
	transforms.Reroute.type = class io.debezium.transforms.ByLogicalTableRouter
	transforms.filter.condition = value.schema().field('op')!=null && (value.op == 'r' || value.op == 'c') && value.schema().field('after')!=null && value.after.schema().field('Date_Time')!=null && value.after.Date_Time > 1652793308967
	transforms.filter.language = jsr223.groovy
	transforms.filter.negate = false
	transforms.filter.null.handling.mode = keep
	transforms.filter.predicate = 
	transforms.filter.topic.regex = null
	transforms.filter.type = class io.debezium.transforms.Filter
	value.converter = class org.apache.kafka.connect.json.JsonConverter
   [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig]
2022-05-17 13:15:09,048 INFO   ||  Instantiated connector TUN_TUN1_SB01_1652793308_123 with version 1.9.2.Final of type class io.debezium.connector.mysql.MySqlConnector   [org.apache.kafka.connect.runtime.Worker]
2022-05-17 13:15:09,048 INFO   ||  Finished creating connector TUN_TUN1_SB01_1652793308_123   [org.apache.kafka.connect.runtime.Worker]
2022-05-17 13:15:09,049 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] Finished starting connectors and tasks   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2022-05-17 13:15:09,050 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 = class org.apache.kafka.connect.json.JsonConverter
	name = TUN_TUN1_SB01_1652793308_123
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = [filter, Reroute]
	value.converter = class org.apache.kafka.connect.json.JsonConverter
   [org.apache.kafka.connect.runtime.SourceConnectorConfig]
2022-05-17 13:15:09,050 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 = class org.apache.kafka.connect.json.JsonConverter
	name = TUN_TUN1_SB01_1652793308_123
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = [filter, Reroute]
	transforms.Reroute.key.enforce.uniqueness = true
	transforms.Reroute.key.field.regex = null
	transforms.Reroute.key.field.replacement = null
	transforms.Reroute.negate = false
	transforms.Reroute.predicate = 
	transforms.Reroute.topic.regex = (.*)
	transforms.Reroute.topic.replacement = TUN_TUN1_SB01_1652793308_123
	transforms.Reroute.type = class io.debezium.transforms.ByLogicalTableRouter
	transforms.filter.condition = value.schema().field('op')!=null && (value.op == 'r' || value.op == 'c') && value.schema().field('after')!=null && value.after.schema().field('Date_Time')!=null && value.after.Date_Time > 1652793308967
	transforms.filter.language = jsr223.groovy
	transforms.filter.negate = false
	transforms.filter.null.handling.mode = keep
	transforms.filter.predicate = 
	transforms.filter.topic.regex = null
	transforms.filter.type = class io.debezium.transforms.Filter
	value.converter = class org.apache.kafka.connect.json.JsonConverter
   [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig]
2022-05-17 13:15:09,061 ERROR  ||  Error forwarding REST request   [org.apache.kafka.connect.runtime.rest.RestClient]
org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Internal request missing required signature
	at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:133)
	at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:65)
	at org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource.completeOrForwardRequest(ConnectorsResource.java:403)
	at org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource.completeOrForwardRequest(ConnectorsResource.java:427)
	at org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource.completeOrForwardRequest(ConnectorsResource.java:437)
	at org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource.putTaskConfigs(ConnectorsResource.java:320)
	at jdk.internal.reflect.GeneratedMethodAccessor50.invoke(Unknown Source)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
	at org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory.lambda$static$0(ResourceMethodInvocationHandlerFactory.java:52)
	at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:124)
	at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:167)
	at org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$VoidOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:159)
	at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:79)
	at org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:475)
	at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:397)
	at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:81)
	at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:255)
	at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248)
	at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244)
	at org.glassfish.jersey.internal.Errors.process(Errors.java:292)
	at org.glassfish.jersey.internal.Errors.process(Errors.java:274)
	at org.glassfish.jersey.internal.Errors.process(Errors.java:244)
	at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:265)
	at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:234)
	at org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:680)
	at org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:394)
	at org.glassfish.jersey.servlet.WebComponent.service(WebComponent.java:346)
	at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:366)
	at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:319)
	at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:205)
	at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799)
	at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:550)
	at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
	at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1624)
	at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
	at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1434)
	at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)
	at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:501)
	at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1594)
	at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)
	at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1349)
	at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
	at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:234)
	at org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:179)
	at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
	at org.eclipse.jetty.server.Server.handle(Server.java:516)
	at org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:388)
	at org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:633)
	at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:380)
	at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277)
	at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
	at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105)
	at org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104)
	at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:338)
	at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:315)
	at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:173)
	at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:131)
	at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:386)
	at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883)
	at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034)
	at java.base/java.lang.Thread.run(Thread.java:829)
2022-05-17 13:15:09,064 ERROR  ||  Error forwarding REST request   [org.apache.kafka.connect.runtime.rest.RestClient]
org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Error trying to forward REST request: Internal request missing required signature
	at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:133)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$reconfigureConnector$32(DistributedHerder.java:1607)
	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)
2022-05-17 13:15:09,065 ERROR  ||  [Worker clientId=connect-1, groupId=debezium-connector] Request to leader to reconfigure connector tasks failed   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Error trying to forward REST request: Error trying to forward REST request: Internal request missing required signature
	at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:147)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$reconfigureConnector$32(DistributedHerder.java:1607)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Error trying to forward REST request: Internal request missing required signature
	at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:133)
	... 6 more
2022-05-17 13:15:09,065 ERROR  ||  [Worker clientId=connect-1, groupId=debezium-connector] Failed to reconfigure connector's tasks (TUN_TUN1_SB01_1652793308_123), retrying after backoff:   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Error trying to forward REST request: Error trying to forward REST request: Internal request missing required signature
	at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:147)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$reconfigureConnector$32(DistributedHerder.java:1607)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Error trying to forward REST request: Internal request missing required signature
	at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:133)
	... 6 more
2022-05-17 13:15:09,316 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 = class org.apache.kafka.connect.json.JsonConverter
	name = TUN_TUN1_SB01_1652793308_123
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = [filter, Reroute]
	value.converter = class org.apache.kafka.connect.json.JsonConverter
   [org.apache.kafka.connect.runtime.SourceConnectorConfig]
2022-05-17 13:15:09,316 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 = class org.apache.kafka.connect.json.JsonConverter
	name = TUN_TUN1_SB01_1652793308_123
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = [filter, Reroute]
	transforms.Reroute.key.enforce.uniqueness = true
	transforms.Reroute.key.field.regex = null
	transforms.Reroute.key.field.replacement = null
	transforms.Reroute.negate = false
	transforms.Reroute.predicate = 
	transforms.Reroute.topic.regex = (.*)
	transforms.Reroute.topic.replacement = TUN_TUN1_SB01_1652793308_123
	transforms.Reroute.type = class io.debezium.transforms.ByLogicalTableRouter
	transforms.filter.condition = value.schema().field('op')!=null && (value.op == 'r' || value.op == 'c') && value.schema().field('after')!=null && value.after.schema().field('Date_Time')!=null && value.after.Date_Time > 1652793308967
	transforms.filter.language = jsr223.groovy
	transforms.filter.negate = false
	transforms.filter.null.handling.mode = keep
	transforms.filter.predicate = 
	transforms.filter.topic.regex = null
	transforms.filter.type = class io.debezium.transforms.Filter
	value.converter = class org.apache.kafka.connect.json.JsonConverter
   [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig]
2022-05-17 13:15:09,326 ERROR  ||  Error forwarding REST request   [org.apache.kafka.connect.runtime.rest.RestClient]
org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Internal request missing required signature
	at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:133)
	at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:65)
	at org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource.completeOrForwardRequest(ConnectorsResource.java:403)
	at org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource.completeOrForwardRequest(ConnectorsResource.java:427)
	at org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource.completeOrForwardRequest(ConnectorsResource.java:437)
	at org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource.putTaskConfigs(ConnectorsResource.java:320)
	at jdk.internal.reflect.GeneratedMethodAccessor50.invoke(Unknown Source)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
	at org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory.lambda$static$0(ResourceMethodInvocationHandlerFactory.java:52)
	at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:124)
	at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:167)
	at org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$VoidOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:159)
	at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:79)
	at org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:475)
	at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:397)
	at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:81)
	at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:255)
	at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248)
	at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244)
	at org.glassfish.jersey.internal.Errors.process(Errors.java:292)
	at org.glassfish.jersey.internal.Errors.process(Errors.java:274)
	at org.glassfish.jersey.internal.Errors.process(Errors.java:244)
	at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:265)
	at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:234)
	at org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:680)
	at org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:394)
	at org.glassfish.jersey.servlet.WebComponent.service(WebComponent.java:346)
	at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:366)
	at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:319)
	at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:205)
	at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799)
	at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:550)
	at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
	at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1624)
	at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
	at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1434)
	at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)
	at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:501)
	at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1594)
	at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)
	at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1349)
	at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
	at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:234)
	at org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:179)
	at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
	at org.eclipse.jetty.server.Server.handle(Server.java:516)
	at org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:388)
	at org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:633)
	at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:380)
	at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277)
	at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
	at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105)
	at org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104)
	at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:338)
	at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:315)
	at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:173)
	at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:131)
	at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:386)
	at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883)
	at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034)
	at java.base/java.lang.Thread.run(Thread.java:829)
2022-05-17 13:15:09,329 ERROR  ||  Error forwarding REST request   [org.apache.kafka.connect.runtime.rest.RestClient]
org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Error trying to forward REST request: Internal request missing required signature
	at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:133)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$reconfigureConnector$32(DistributedHerder.java:1607)
	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)
2022-05-17 13:15:09,330 ERROR  ||  [Worker clientId=connect-1, groupId=debezium-connector] Request to leader to reconfigure connector tasks failed   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Error trying to forward REST request: Error trying to forward REST request: Internal request missing required signature
	at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:147)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$reconfigureConnector$32(DistributedHerder.java:1607)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Error trying to forward REST request: Internal request missing required signature
	at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:133)
	... 6 more
2022-05-17 13:15:09,330 ERROR  ||  [Worker clientId=connect-1, groupId=debezium-connector] Failed to reconfigure connector's tasks (TUN_TUN1_SB01_1652793308_123), retrying after backoff:   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Error trying to forward REST request: Error trying to forward REST request: Internal request missing required signature
	at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:147)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$reconfigureConnector$32(DistributedHerder.java:1607)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Error trying to forward REST request: Internal request missing required signature
	at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:133)
	... 6 more
2022-05-17 13:15:09,581 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 = class org.apache.kafka.connect.json.JsonConverter
	name = TUN_TUN1_SB01_1652793308_123
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = [filter, Reroute]
	value.converter = class org.apache.kafka.connect.json.JsonConverter
   [org.apache.kafka.connect.runtime.SourceConnectorConfig]
2022-05-17 13:15:09,581 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 = class org.apache.kafka.connect.json.JsonConverter
	name = TUN_TUN1_SB01_1652793308_123
	predicates = []
	tasks.max = 1
	topic.creation.groups = []
	transforms = [filter, Reroute]
	transforms.Reroute.key.enforce.uniqueness = true
	transforms.Reroute.key.field.regex = null
	transforms.Reroute.key.field.replacement = null
	transforms.Reroute.negate = false
	transforms.Reroute.predicate = 
	transforms.Reroute.topic.regex = (.*)
	transforms.Reroute.topic.replacement = TUN_TUN1_SB01_1652793308_123
	transforms.Reroute.type = class io.debezium.transforms.ByLogicalTableRouter
	transforms.filter.condition = value.schema().field('op')!=null && (value.op == 'r' || value.op == 'c') && value.schema().field('after')!=null && value.after.schema().field('Date_Time')!=null && value.after.Date_Time > 1652793308967
	transforms.filter.language = jsr223.groovy
	transforms.filter.negate = false
	transforms.filter.null.handling.mode = keep
	transforms.filter.predicate = 
	transforms.filter.topic.regex = null
	transforms.filter.type = class io.debezium.transforms.Filter
	value.converter = class org.apache.kafka.connect.json.JsonConverter
   [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig]
2022-05-17 13:15:09,593 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] Tasks [TUN_TUN1_SB01_1652793308_123-0] configs updated   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2022-05-17 13:15:09,594 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] Handling task config update by restarting tasks []   [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
2022-05-17 13:15:09,594 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] Rebalance started   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2022-05-17 13:15:09,594 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] (Re-)joining group   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2022-05-17 13:15:09,597 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] Successfully joined group with generation Generation{generationId=227, memberId='connect-1-2f36602e-a9cc-4634-9969-63b08c4a2aee', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]
2022-05-17 13:15:09,601 INFO   ||  [Worker clientId=connect-1, groupId=debezium-connector] Successfully synced group in generation Generation{generationId=227, memberId='connect-1-2f36602e-a9cc-4634-9969-63b08c4a2aee', protocol='sessioned'}   [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator]