StoreChangeLogger

StoreChangeLogger is created when the following state stores are requested to initialize:

StoreChangeLogger takes the following to be created:

StoreChangeLogger initializes the internal properties.

void logChange(K key, V value) (1)
void logChange(K key, V value, long timestamp)

logChange simply requests the RecordCollector to send the key and the value to the topic and the partition (using the keySerializer and the valueSerializer).

Note

logChange is used when:

ChangeLoggingKeyValueBytesStore is requested to log
ChangeLoggingSessionBytesStore is requested to remove and put
ChangeLoggingWindowBytesStore is requested to log
ChangeLoggingTimestampedKeyValueBytesStore and ChangeLoggingTimestampedWindowBytesStore are requested to log

Name Description

Name	Description
`collector`	RecordCollector Used exclusively when `StoreChangeLogger` is requested to logChange.
`topic`	The name of the changelog topic (given the application ID and the store name) Used when…FIXME

collector

Used exclusively when StoreChangeLogger is requested to logChange.

topic

The name of the changelog topic (given the application ID and the store name)

Used when…FIXME

results matching ""