byte[] serializeBaseKey(String topic, Windowed<T> data)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.
serializeBaseKey is used exclusively when WindowedStreamPartitioner is requested to determine the partition for a record.
| WindowedSerializer | Description |
|---|---|
|
|
|