Hi, Yes the key format used by a window store changelog is the same format as is stored in RocksDB. You can see what the format is by looking here: https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreUtils.java
Thanks, Damian On Thu, 22 Jun 2017 at 15:23 sy.pan <shengyi....@gmail.com> wrote: > I explicitly call KTable.to(Serde<Windowed<String>>, Serdes.Long(), > String topic), > > save the same data to another topic(manually created by myself), then the > excp is gone. > > > so the **-changelog internal topic has special key format ? (even the key > type is same = windowed<String> ) > > >
