Module nakadion::consumer

Kit for creating a consumer for a subscription

Start here if you want to consume a stream. You will need a BatchHandlerFactory to consume a stream.

Structs

AbortConnectOnAuthError	If true abort the consumer when an auth error occurs while connecting to a stream.
AbortConnectOnSubscriptionNotFound	If true abort the consumer when a subscription does not exist when connection to a stream.
BatchFlushTimeoutSecs
BatchLimit
BatchTimespanSecs
Builder	Creates a Consumer
CommitRetryDelayMillis	The delay between failed attempts to commit cursors.
CommitTimeoutMillis	The timeout for a request made to Nakadi to commit cursors.
ConnectStreamRetryMaxDelaySecs	The maximum retry delay between failed attempts to connect to a stream.
ConnectStreamTimeoutSecs	The timeout for a request made to Nakadi to connect to a stream.
Consumer	Consumes an event stream
ConsumerError	Always leads to Nakadion shutting down
ConsumerHandle	A handle for controlling a Consumer from externally.
ConsumerTask	A task returned when starting a Consumer which must be spawned on an executor.
ConsumptionOutcome	Returned once a Consumer has stopped. It contains the original consumer and if the Consumer was stopped for other reasons than the stream ending a ConsumerError.
DevNullLogger
Error	An error for cases where further investigation is not necessary
InactivityTimeoutSecs	The time after which a stream or partition is considered inactive.
LogLogger
MaxUncommittedEvents
SlogLogger
StdErrLogger
StdOutLogger
StreamDeadTimeoutSecs	The time after which a stream is considered stuck and has to be aborted.
StreamLimit
StreamParameters	Parameters for starting a new stream on a subscription
StreamTimeoutSecs
SubscriptionId	Id of a subscription
TickIntervalSecs	The internal tick interval.

Enums

CommitStrategy	Defines how to commit cursors
ConsumerErrorKind
DispatchStrategy	Defines how to dispatch batches to handlers.
Instrumentation

Traits

Instrumented
LoggingAdapter