Matthias J. Sax comments

Results 91 comments of


                                            Matthias J. Sax

Query upgrades: Changing the filter on a table can result in missed tombstones

Well, in general query migration is hard... Seems to be an incompatible query upgrade that we should reject until we can handle it correctly?

Query upgrades: Changing the filter on a table can result in missed tombstones

Well, but if you change the example, the row in the result could be deleted: ```sql // after the upgrade // Andy's example INSERT INTO a (id, col1) VALUES (1,...

KAFKA-13818: Add generation to consumer assignor logs

Build failed. Looks concerning?

KAFKA-12960: Enforcing strict retention time for WindowStore and Sess…

Did not look into this PR. Left the following comment on the JIRA: > I just got a report, that `InMemoryWindowStore` does not enforce strict retention for IQ if caching...

KAFKA-7883 add schema.namespace support to SetSchemaMetadata SMT in Kafka Connect

I am not familiar with Connect code -- @rhauch @kkonstantine @mimaison should be able to help.

KAFKA-7016: Not hide the stack trace for ApiException

@guozhangwang Seem the Jira number is not correct?

KAFKA-13817 Always sync nextTimeToEmit with wall clock

@qingwei91 -- What is the status of this PR? Seems there is open comments that would need to be addressed? Would be great if we could push this over the...

ksqlDB should support N-Way joins on the same table multiple times

Self-join optimization was done in KS in the meant-time: https://cwiki.apache.org/confluence/display/KAFKA/KIP-862%3A+Self-join+optimization+for+stream-stream+joins But ksqlDB does not yet leverage it.

KAFKA-13817 Always sync nextTimeToEmit with wall clock

Thanks for the PR! Merged to `trunk`.

WIP: KAFKA-12549 Prototype for transactional state stores

Closing this PR as stale. KIP-844 was discarded in favor of KIP-892.