Consumer

Undocumented in source.

class Consumer : IWorker {

void throwException(Exception ex);

string topic [@property getter];

int partition [@property getter];

WorkerType workerType [@property getter];

this(Client client, string topic, int partition, Offset startingOffset);

Message front();

void popFront();

Message getMessage();

}

Constructors

this this(Client client, string topic, int partition, Offset startingOffset): Undocumented in source.

Members

Functions

front Message front(): Undocumented in source. Be warned that the author may not have intended to support it.
getMessage Message getMessage(): Undocumented in source. Be warned that the author may not have intended to support it.
popFront void popFront(): Undocumented in source. Be warned that the author may not have intended to support it.
throwException void throwException(Exception ex): Throws an exception in the consumer task. This is used to pass the connection exceptions to the user.

Manifest constants

empty enum empty;: Undocumented in source.

Properties

partition int partition [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
queue queue [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
topic string topic [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
workerType WorkerType workerType [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From IWorker

workerType WorkerType workerType [@property getter]: Undocumented in source.
topic string topic [@property getter]: Undocumented in source.
partition int partition [@property getter]: Undocumented in source.
throwException void throwException(Exception ex): throws exception in the worker task

Meta

Source

See Implementation

kafkad consumer aliases

Offset

classes

Consumer

enums

Offsets

structs

Message