情况如下。
我们在kafka代理中设置了ssl+acl。
我们正在设置流，它从两个主题读取消息：

KStream<String, String> stringInput 
    = kBuilder.stream( STRING_SERDE, STRING_SERDE, inTopicName );

stringInput
    .filter( streamFilter::passOrFilterMessages )
    .map( processor )
    .to( outTopicName );

这是做了两次（在循环）。然后设置常规错误处理程序：

streams.setUncaughtExceptionHandler( ( Thread t, Throwable e ) -> {
                    synchronized ( this ) {
                        LOG.fatal( ... );
                        this.stop();
                    }
                }
        );

问题如下。例如，在一个主题中，证书不再有效。流正在引发未授权访问主题的异常。。。到现在为止，一直都还不错。
但是异常是由常规错误处理程序处理的，因此即使第二个主题没有问题，整个应用程序也会停止。
问题是，如何处理每个主题的异常？如何避免由于某个主题的授权有问题而导致整个应用程序在某个时刻停止的情况？
我明白，如果代理不可用，那么完整的应用程序可能会停止。但是如果只有一个主题不可用，那么单个流应该停止，并且不能完成应用，或者？