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
Hi,
I want to use s3 connect by portioning with FieldPartitioner and
partition.field.name set to a non timestamp based field. I want to commit and
flush based on both size and time. I am getting an exception when I use the
option "rotate.schedule.interval.ms". Is it possible to rotate it with
