You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Please provide full log files (redact and sensitive information)
org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:618)
at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:336)
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:237)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:206)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:181)
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)
Caused by: java.lang.IllegalArgumentException: requirement failed: ErrorTracker is not set call. Initialize.
at scala.Predef$.require(Predef.scala:337)
at com.datamountaineer.streamreactor.common.errors.ErrorHandler.handleTry(ErrorHandler.scala:48)
at com.datamountaineer.streamreactor.common.errors.ErrorHandler.handleTry$(ErrorHandler.scala:47)
at com.datamountaineer.streamreactor.connect.redis.sink.writer.RedisWriter.handleTry(RedisWriter.scala:31)
at com.datamountaineer.streamreactor.connect.redis.sink.writer.RedisGeoAdd.$anonfun$insert$1(RedisGeoAdd.scala:117)
at com.datamountaineer.streamreactor.connect.redis.sink.writer.RedisGeoAdd.$anonfun$insert$1$adapted(RedisGeoAdd.scala:54)
at scala.collection.immutable.HashMap.foreach(HashMap.scala:1076)
at com.datamountaineer.streamreactor.connect.redis.sink.writer.RedisGeoAdd.insert(RedisGeoAdd.scala:54)
at com.datamountaineer.streamreactor.connect.redis.sink.writer.RedisGeoAdd.write(RedisGeoAdd.scala:49)
at com.datamountaineer.streamreactor.connect.redis.sink.RedisSinkTask.$anonfun$put$2(RedisSinkTask.scala:239)
at com.datamountaineer.streamreactor.connect.redis.sink.RedisSinkTask.$anonfun$put$2$adapted(RedisSinkTask.scala:239)
at scala.collection.immutable.List.foreach(List.scala:333)
at com.datamountaineer.streamreactor.connect.redis.sink.RedisSinkTask.put(RedisSinkTask.scala:239)
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:587)
... 11 more
The text was updated successfully, but these errors were encountered:
What version of the Stream Reactor are you reporting this issue for?
4.2.0
Are you running the correct version of Kafka/Confluent for the Stream reactor release?
yes
What is the expected behaviour?
I'm trying to insert this kafka record :
into Redis with the kcql :
INSERT INTO buses: SELECT veh from geo_test PK oper STOREAS GEOADD
What was observed?
An exception is throw right after startup of the connector
What is your connector properties configuration ?
Please provide full log files (redact and sensitive information)
The text was updated successfully, but these errors were encountered: