WindowedSerializer Contract

WindowedSerializer is the extension of the Serializer contract in Apache Kafka for serializers that can serialize Windowed keys.

WindowedSerializer defines the single serializeBaseKey method to convert (serialize) objects of Windowed type to bytes.

byte[] serializeBaseKey(String topic, Windowed<T> data)

serializeBaseKey is used exclusively when WindowedStreamPartitioner is requested to determine the partition for a record.

Table 1. WindowedSerializers
WindowedSerializer Description

SessionWindowedSerializer

TimeWindowedSerializer

results matching ""

    No results matching ""