Getting this NPE on few occasions on kafka connectors

[SubhraB]

Hello, I keep getting the below errors on my connectors. They are not consistent and show up few times, then I restart the connectors and then they go away. Anyone else faced this problem? I am using strimizi version 0.35.1 with AWS MSK.

Failed to start task db-source-connector-0 (org.apache.kafka.connect.runtime.Worker) [DistributedHerder-connect-1-1]
java.lang.NullPointerException: Cannot invoke "java.util.Map.entrySet()" because "originals" is null
	at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:108)
	at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:146)
	at org.apache.kafka.connect.runtime.TaskConfig.<init>(TaskConfig.java:51)
	at org.apache.kafka.connect.runtime.Worker.startTask(Worker.java:607)
	at org.apache.kafka.connect.runtime.Worker.startSourceTask(Worker.java:544)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.startTask(DistributedHerder.java:1756)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$doRestartConnectorAndTasks$28(DistributedHerder.java:1451)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.doRestartConnectorAndTasks(DistributedHerder.java:1449)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$processRestartRequests$25(DistributedHerder.java:1392)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.processRestartRequests(DistributedHerder.java:1390)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:455)
	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:352)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)

[aj84276]

@scholzj any pointer here.. this happens after rebalancing mostly for debezium postgres source connectors. Also doesnt happen everytime

I am using strimzi operator 0.38

[scholzj]

It is absolutely missing any context. It is not even clear where does it come from etc. So no, I do not have any pointers. Sorry.

[katheris]

From the stack trace you shared it looks like something is going wrong when Connect is building the set of configuration properties for the task. However it's unclear whether it's originating from the connector, from a configuration provider or from somewhere in Connect. I doubt it's being caused by running on Strimzi, so probably worth raising an issue either in Debezium or Kafka Connect directly.

[SubhraB]

Actually i don't get this error anymore after upgrading my operator version to 39