IWorker

worker may be either a producer or a consumer

interface IWorker {

WorkerType workerType [@property getter];

string topic [@property getter];

int partition [@property getter];

void throwException(Exception ex);

}

Members

Functions

throwException void throwException(Exception ex): throws exception in the worker task

Properties

partition int partition [@property getter]: Undocumented in source.
topic string topic [@property getter]: Undocumented in source.
workerType WorkerType workerType [@property getter]: Undocumented in source.

Meta

Source

See Implementation

kafkad worker enums

WorkerType

interfaces

IWorker