it is a defect or a
genuine requirement.
Thanks,
-Manu
From: Pere Urbón Bayes
Sent: Monday, February 04, 2019 11:41 PM
To: Manu Jacob
Cc: users@kafka.apache.org
Subject: Re: Kafka connect FieldPartitioner with scheduled rotation
EXTERNAL
Hi Manu,
if we take master of the connector, I
utureTask.java:266)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> [2019-02-03 17:59:01,262]
.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
[2019-02-03 17:59:01,262] ERROR Task is being killed and will not recover until
manually restarted
Hi Manu,
can you share your s3 connector config as well the exception you are
getting? with only this info, I do need more details to understand your
issue. Keep in mind the option you are using "rotate.schedule.interval.ms"
from the docs says:
> This configuration is useful when you have to com
