- fetcherMain
void fetcherMain()
Undocumented in source. Be warned that the author may not have intended to support it.
- getMetadata
Metadata getMetadata(string[] topics)
Undocumented in source. Be warned that the author may not have intended to support it.
- getStartingOffset
long getStartingOffset(string topic, int partition, long offset)
Undocumented in source. Be warned that the author may not have intended to support it.
- pusherMain
void pusherMain()
Undocumented in source. Be warned that the author may not have intended to support it.
- receiverMain
void receiverMain()
Undocumented in source. Be warned that the author may not have intended to support it.