Guozhang Wang

The situation is a bit different with processing-modes here: * at-least-once / exactly-once-beta: N producer, 2 * N consumer, 1 admin * exactly-once: M producers, 2 * N consumer, 1...

I'm big +1 on disallowing CSAS/CTAS to define a schema on selected columns for those cases that have schema registration integrated. If users are only interested in a subset of...

Thanks @philipnee , I think we can merge the PR as is since it's new interfaces and if we found anything in follow-up developments we can always come back and...

Hello @vamossagar12 thanks for the PR. I took another pass on KIP-691 and updated some exception cases in the wiki, and I think we need to thoroughly go through them...

Thanks @ahmedsobeh ! Will take a look.

There's still jenkins failures: ``` [2022-09-23T00:16:58.037Z] [ant:checkstyle] [ERROR] /home/jenkins/jenkins-agent/workspace/Kafka_kafka-pr_PR-12670/streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java:161:22: Name 'APPLICATION_ID' must match pattern '^[a-z][a-zA-Z0-9]*$'. [LocalFinalVariableName] [2022-09-23T00:16:58.037Z] [ant:checkstyle] [ERROR] /home/jenkins/jenkins-agent/workspace/Kafka_kafka-pr_PR-12670/streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java:162:22: Name 'STATE_STORE_NAME' must match pattern '^[a-z][a-zA-Z0-9]*$'. [LocalFinalVariableName] [2022-09-23T00:16:58.037Z] [ant:checkstyle] [ERROR]...

Hi @vamossagar12 @ableegoldman I took a quick look at the PR and I have a few questions: * The fix itself seems to be applied only to persistent stores (built-in...

Personally I'd suggest we enforce the rentention at the inner store, which means: 1) for built-in in-memory stores, enforce at the InMemoryXXStore level. 2) for built-in persistent stores, enforce at...

> While InMemoryWindowStore does enable strict retention but when combined with the caching store, it breaks. That's where doing it on MeteredStore might be beneficial. I see that, and personally...

@mjsax @ableegoldman could you chime in here?