Struct KinesisMessage 

pub struct KinesisMessage { /* private fields */ }

A record delivered by a KinesisSubscriber.

Acknowledgement is a per-shard checkpoint, not per-message settlement: ack marks this record handled, and when every earlier record on the shard is handled too, the watermark advances and is persisted to the lease store. nack(requeue = true) answers AckError::Unsupported: a sharded log repositions, it cannot requeue one message. The record stays unhandled, so the watermark stops advancing, and the records from it onward are delivered again when the shard’s lease is next taken. nack(requeue = false) skips the record (checkpoints past it).

In a handler, HandlerOutcome::ack() is the ack, HandlerOutcome::drop() the skip, and HandlerOutcome::retry() the requeue, unless the registration declares max_attempts(..) or a dead-letter stream: then the retry publishes a counted copy of the record back to its stream.

Trait Implementations

impl BuildBatchContext<KinesisMessage> for KinesisBatchContext

fn build(first: &KinesisMessage) -> Self

Builds the context value by reading subscription-scoped fields out of the batch’s first delivery, or out of the batch itself where it lends its values as one slice.

impl BuildContext<KinesisMessage> for KinesisContext

fn build(msg: &KinesisMessage) -> Self

Builds the context value by reading fields out of msg.

impl Debug for KinesisMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl IncomingMessage for KinesisMessage

fn payload(&self) -> &[u8]

Returns the raw payload of the message.

fn headers(&self) -> &HeaderMap

Returns the headers attached to the message.

async fn ack(self) -> Result<(), AckError>

Acknowledges successful processing. Consumes the message handle.

async fn nack(self, requeue: bool) -> Result<(), AckError>

Negatively acknowledges the message. When requeue is true the broker should redeliver according to its own retry policy; when false it should drop or dead-letter the message.

fn partition_key(&self) -> Option<&[u8]>

Returns the routing key the broker partitioned this message by, or None when the message carries no key.

fn redelivery_count(&self) -> Option<u64>

How many times the broker has delivered this message, counting this delivery. None where the transport counts nothing.

fn decode_error(&self) -> Option<&CodecError>

The error the broker met while reading this delivery, or None when it read the delivery whole.

fn supports_nack_after(&self) -> bool

Reports whether this transport can honor nack_after natively.

fn nack_after( self, delay: Duration, ) -> impl Future<Output = Result<(), AckError>> + Send

where Self: Sized,

Negatively acknowledges the message, asking the broker to redeliver it no sooner than delay from now.

impl Partitioned for KinesisMessage

fn partition_key(&self) -> Option<&[u8]>

Returns the partition key for this item, or None if the broker should pick a partition.

impl Positioned for KinesisMessage

type Position = KinesisPosition

The position type, matching the subscription’s Seeker::Position.

fn position(&self) -> KinesisPosition

Returns the position of this delivery; seeking to it redelivers this message.