Hey Akash,
Thanks for the question! For a direct answer, no: throwing exceptions
from poll() is only one of many ways that a task can fail.
If you look at the AK source, every failure ultimately uses the
AbstractStatus.State.FAILED enum [1]. You can trace the usages of this
enum back to see all o
Hello,
I have a requirement where I need to detect failed tasks based on the
specific errors and emit a metric only when it doesn't fail based on these
specific errors (these include unknown_topic_or_partition, specific cases
of ConfigException etc)
I know about a similar metric accessible via Pr
