Sebastien Viale

Steps to init namespace: **I** Create a namespace with a dummy user ``` { "kind": "Namespace", "metadata": { "name": "myNamespace", "cluster": "myCluster" }, "spec": { "kafkaUser": "dummyUser" } } ```...

The e.getMessage() does not contain "Injected test exception" anymore. It is now getCause().getMessage() that contains "Injected test exception" Fix is pushed

@cadonna Thanks for the remarks, I did not realize that either! I see two solutions for Backward compatibility: 1/ log an error and throw the original exception: ```java private final...

Actually it is a StreamException but from line 752: https://github.com/apache/kafka/blob/8b6013f851fec537401f29769be5608c2d246747/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java#L751-L755

I executed the test from the trunk in debug mode, I confirm it is line 752

Regarding this comment https://github.com/apache/kafka/pull/16093#issuecomment-2194117929, what do you prefer ?

@loicgreffier @cadonna Seems ok for me but in this case we are losing the information: `Processing exception handler is set to fail upon a processing error. If you would rather...

> KIP is still under discussion: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1138%3A+Clean+up+TopologyConfig+and+API+for+supplying+configs+needed+by+the+topology @mjsax The KIP is voted since june: https://lists.apache.org/[email protected]:2025-6:KIP-1138 Do I have to update the status ?