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

Reply via email to