Re: consume ***-changelog topic encounter IllegalArgumentException: Window startMs time cannot be negative

[Damian Guy <da...@gmail.com>]

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 <sh...@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> )
>
>
>

Re: consume ***-changelog topic encounter IllegalArgumentException: Window startMs time cannot be negative

["sy.pan" <sh...@gmail.com>]

Thank you very much , Damian

^_^


> 在 2017年6月22日，22:43，Damian Guy <da...@gmail.com> 写道：
> 
> 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 <sh...@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> )
>> 
>> 
>>