OffsetGap

class OffsetGap @InternalWowApi constructor(val topic: String, val partition: Int) : ObservedEvent

A read of partition of topic was to start from an offset the partition no longer holds (the topic's retention deleted it, or the topic was created again): messages were lost to its subscriptions, an error to alert on whatever the transport did about it.

Constructors

Link copied to clipboard
constructor(topic: String, partition: Int)

Properties

Link copied to clipboard
Link copied to clipboard