public class StateSerde extends SelfSerde<org.apache.kafka.streams.KafkaStreams.State>
Constructor and Description |
---|
StateSerde() |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.streams.KafkaStreams.State |
deserialize(String topic,
byte[] data) |
byte[] |
serialize(String topic,
org.apache.kafka.streams.KafkaStreams.State data) |
close, configure, deserializer, serializer
Copyright © 2020 Red Hat. All rights reserved.