kafka-workers
kafka-workers copied to clipboard
Features nice to have
eager initialization
A single task is used only in context of a single subpartition. A suggestion is to provide all arguments during task creation – methodWorkerTaskFactory::createTask(...)
instead of during later init
call.
topic's configuration parameters
In multiple projects we have some configuration parameters specific to a topic. It would be very convenient to get those parameters when a task is instantiated.
contexts
Related to eager initialization.
Provide an immutable context to a task during construction. A context consists of multiple information and decreases possible memory footprint of a task, because many objects like WorkerSubpartition
may be reused and shared during application life.