| ControlMessage |
ControlMessage payloads contain metadata about the stream of data, for validation and debuggability purposes.
|
| Delete |
Delete payloads contain fields related to replication metadata of the record.
|
| EndOfIncrementalPush |
This ControlMessage is sent per partition by each offline incremental push job, once per partition, at the end of a incremental push
|
| EndOfPush |
This ControlMessage is sent once per partition, at the end of a bulk load, after all of the data producers come online.
|
| EndOfSegment |
This ControlMessage is sent at least once per partition per producer.
|
| GUID |
|
| KafkaMessageEnvelope |
|
| LeaderMetadata |
|
| ProducerMetadata |
|
| Put |
Put payloads contain a record value, and information on how to deserialize it.
|
| StartOfBufferReplay |
This ControlMessage is sent by the Controller, once per partition, after the EndOfPush ControlMessage, in Hybrid Stores that ingest from both offline and nearline sources.
|
| StartOfIncrementalPush |
This ControlMessage is sent per partition by each offline incremental push job, once per partition, at the beginning of a incremental push.
|
| StartOfPush |
This ControlMessage is sent once per partition, at the beginning of a bulk load, before any of the data producers come online.
|
| StartOfSegment |
This ControlMessage is sent at least once per partition per producer.
|
| TopicSwitch |
This ControlMessage is sent by the Controller, once per partition; it will only be used in leader/follower state transition model; this control message will indicate the leader to switch to a new source topic and start consuming from offset with a specific timestamp.
|
| Update |
Partial update operation, which merges the update value with the existing value.
|
| VersionSwap |
This controlMessage is written to the real-time topic by the controller or to the store-version topic by the current version's leader server.
|