Class | Description |
---|---|
AckStats | |
KestrelThriftClient | |
KestrelThriftSpout |
This spout can be used to consume messages in a reliable way from a cluster
of Kestrel servers.
|
TestTopology | |
TestTopology.FailEveryOther | |
UnreliableKestrelThriftSpout |
A version of the
KestrelThriftSpout that is purposefully unreliable
and cuts other corners in an effort for improved speeds |