Re: KSQL with changelog topic
Thanks for confirming! From: Matthias J. Sax Sent: Saturday, November 3, 2018 1:35 AM To: dev@kafka.apache.org Subject: Re: KSQL with changelog topic I see. Makes sense. AFAIK, this is not supported atm, because KSQL cannot handle the `Windowed` datatype yet. -Matthias On 11/1/18 9:28 PM, Boyang Chen wrote: > For example, I have a stream windowed aggregation changlog topic > KStream--XXX--changelog-26, does KSQL support a simple query like > > ``` > > select * from > > changelog_topic > > limit 10 > > ``` > > I'm not sure because the serde for window store changelog is compound > Windowed. > > > Hope this makes sense. Thank you! > > > > From: Matthias J. Sax > Sent: Friday, November 2, 2018 5:06 AM > To: dev@kafka.apache.org > Subject: Re: KSQL with changelog topic > > I am not sure if I understand the question. Can you elaborate? > > -Matthias > > > On 11/1/18 10:38 AM, Boyang Chen wrote: >> Hey there, >> >> >> a dumb question that I haven't found the answer anywhere: does KSQL support >> query towards Stream applications' >> >> changelog topic? Especially window store changelog, since it has a more >> complex key schema. >> >> >> Thanks! >> > >
Re: KSQL with changelog topic
I see. Makes sense. AFAIK, this is not supported atm, because KSQL cannot handle the `Windowed` datatype yet. -Matthias On 11/1/18 9:28 PM, Boyang Chen wrote: > For example, I have a stream windowed aggregation changlog topic > KStream--XXX--changelog-26, does KSQL support a simple query like > > ``` > > select * from > > changelog_topic > > limit 10 > > ``` > > I'm not sure because the serde for window store changelog is compound > Windowed. > > > Hope this makes sense. Thank you! > > > > From: Matthias J. Sax > Sent: Friday, November 2, 2018 5:06 AM > To: dev@kafka.apache.org > Subject: Re: KSQL with changelog topic > > I am not sure if I understand the question. Can you elaborate? > > -Matthias > > > On 11/1/18 10:38 AM, Boyang Chen wrote: >> Hey there, >> >> >> a dumb question that I haven't found the answer anywhere: does KSQL support >> query towards Stream applications' >> >> changelog topic? Especially window store changelog, since it has a more >> complex key schema. >> >> >> Thanks! >> > > signature.asc Description: OpenPGP digital signature
Re: KSQL with changelog topic
For example, I have a stream windowed aggregation changlog topic KStream--XXX--changelog-26, does KSQL support a simple query like ``` select * from changelog_topic limit 10 ``` I'm not sure because the serde for window store changelog is compound Windowed. Hope this makes sense. Thank you! From: Matthias J. Sax Sent: Friday, November 2, 2018 5:06 AM To: dev@kafka.apache.org Subject: Re: KSQL with changelog topic I am not sure if I understand the question. Can you elaborate? -Matthias On 11/1/18 10:38 AM, Boyang Chen wrote: > Hey there, > > > a dumb question that I haven't found the answer anywhere: does KSQL support > query towards Stream applications' > > changelog topic? Especially window store changelog, since it has a more > complex key schema. > > > Thanks! >
Re: KSQL with changelog topic
I am not sure if I understand the question. Can you elaborate? -Matthias On 11/1/18 10:38 AM, Boyang Chen wrote: > Hey there, > > > a dumb question that I haven't found the answer anywhere: does KSQL support > query towards Stream applications' > > changelog topic? Especially window store changelog, since it has a more > complex key schema. > > > Thanks! > signature.asc Description: OpenPGP digital signature
KSQL with changelog topic
Hey there, a dumb question that I haven't found the answer anywhere: does KSQL support query towards Stream applications' changelog topic? Especially window store changelog, since it has a more complex key schema. Thanks!
