redis断连重启后，stream流监听会失效？-灵析社区

使用cancelOnError方法，返回false //注册 var options = StreamMessageListenerContainer.StreamReadRequest .builder(StreamOffset.create(redisStreamName, ReadOffset.lastConsumed())) .cancelOnError(throwable -> { System.out.println("这是一个错误"+throwable); // 不能取消 return !(throwable instanceof RuntimeException); }) .consumer(Consumer.from(groups[0], this.getClass().getName())) .autoAck(true) .build();