Hi Dmitry, Could you tell us more on the exact API you'd like? Perhaps if others find it useful too we/you can do a KIP.
Thanks Eno > On 21 Feb 2017, at 22:01, Dmitry Minkovsky <dminkov...@gmail.com> wrote: > > At KAFKA-2984: ktable sends old values when required > <https://github.com/apache/kafka/pull/672#issue-122101101>, @ymatsuda > writes: > >> NOTE: This is meant to be used by aggregation. But, if there is a use > case like a SQL database trigger, we can add a new KTable method to expose > this. > > Looking through the source it does not seem that this API was ever exposed. > Not finding anything on Google on this subject either. The SQL database > trigger is my exact use case. Enabling change-streaming for some tables > would help simplify my code. Is this possible? Is this scheduled for a > future version? > > Thank you, > Dmitry
