RedisMessageBusObserver

Receives synchronous Redis message-bus recovery and decode observations.

Implementations must be non-blocking. Callback failures are isolated from message delivery. Metrics adapters should use the observation type, outcome, or RedisRecordDecodeFailureReason as low-cardinality dimensions instead of topic, consumer-group, record, or message-type values.

Inheritors

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
abstract fun onObservation(observation: RedisMessageBusObservation)