Hi,
My UID is javier.freire. I wanted to create a KIP to add to Kafka Streams
the ability to convert a changelog stream to a stream by computing the
value by comparing the old and new value of the record.
These are the changes:
https://github.com/javierfreire/kafka/commit/d32169f06452388800ceb2a
[
https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10569.
-
Resolution: Invalid
> Running aggregate queries on KSQL client side is getting to ERROR
Thanks a lot, Matthias for detailed feedback. I tend to agree with changing the
state machine
itself if required. I think at the end of the day InvalidOffsetException is a
rare event and is not
as frequent as rebalancing. So, pausing all tasks for once in while should be
ok from a processi
