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	Does no logging at all
Error	An error for cases where further investigation is not necessary
InactivityTimeoutSecs	The time after which a stream or partition is considered inactive.
LogLogger	A logger based on log
MaxUncommittedEvents
SlogLogger	A logger based on slog
StdErrLogger	Logs to stderr
StdOutLogger	Logs to stdout
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	An adapter for pluggable logging.