application.properties:

spring.ai.mcp.client.sse.connections.server1.url= "https://mcp-d8512d23-412f-46b1.api-inference.modelscope.cn

**code like this： **

client:

private final ToolCallbackProvider tools;
private final ChatClient.Builder chatClientBuilder;

chatClientBuilder
.defaultTools(tools)
.defaultAdvisors(
new PromptChatMemoryAdvisor(chatMemory),
new LoggingAdvisor()
)
.build();

private Flux processUserInput(String input) {
return chatClient.prompt()
.system(s -> s.param("current_date", LocalDate.now().toString()))
.user(input)
.advisors(a -> a.param(CHAT_MEMORY_CONVERSATION_ID_KEY, sessionId)
.param(CHAT_MEMORY_RETRIEVE_SIZE_KEY, 100))
.stream()
.chatResponse()
.flatMap(response -> sinkHandler.handleTextResponse(response));
}

when i start the demo ，it look very nice，but few seconds later， it always failed with ERROR “Received unrecognized SSE event type: null”

next details error ：

2025-04-29 17:23:07 INFO o.s.b.w.e.tomcat.TomcatWebServer - Tomcat started on port 9004 (http) with context path '/'
2025-04-29 17:23:07 INFO n.q.q.a.AiAssistantApplication - Started AiAssistantApplication in 4.396 seconds (process running for 5.014)
2025-04-29 17:23:21 ERROR reactor.core.publisher.Operators - Operator called default onErrorDropped
reactor.core.Exceptions$ErrorCallbackNotImplemented: io.modelcontextprotocol.spec.McpError: Received unrecognized SSE event type: null
Caused by: io.modelcontextprotocol.spec.McpError: Received unrecognized SSE event type: null
at io.modelcontextprotocol.client.transport.WebFluxSseClientTransport.lambda$connect$0(WebFluxSseClientTransport.java:194)
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.MonoHandle] :
reactor.core.publisher.Mono.handle(Mono.java:3297)
io.modelcontextprotocol.client.transport.WebFluxSseClientTransport.lambda$connect$1(WebFluxSseClientTransport.java:172)
Error has been observed at the following site(s):
*___Mono.handle ⇢ at io.modelcontextprotocol.client.transport.WebFluxSseClientTransport.lambda$connect$1(WebFluxSseClientTransport.java:172)
| Mono.doOnNext ⇢ at io.modelcontextprotocol.spec.DefaultMcpSession.lambda$new$4(DefaultMcpSession.java:125)
| Mono.transform ⇢ at io.modelcontextprotocol.client.transport.WebFluxSseClientTransport.lambda$connect$1(WebFluxSseClientTransport.java:196)
*__Flux.concatMap ⇢ at io.modelcontextprotocol.client.transport.WebFluxSseClientTransport.connect(WebFluxSseClientTransport.java:172)
Original Stack Trace:
at io.modelcontextprotocol.client.transport.WebFluxSseClientTransport.lambda$connect$0(WebFluxSseClientTransport.java:194)
at reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:113)
at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2571)
at reactor.core.publisher.FluxHandle$HandleSubscriber.request(FluxHandle.java:272)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.request(FluxPeekFuseable.java:144)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2367)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2241)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onSubscribe(FluxPeekFuseable.java:178)
at reactor.core.publisher.FluxHandle$HandleSubscriber.onSubscribe(FluxHandle.java:90)
at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:55)
at reactor.core.publisher.Mono.subscribe(Mono.java:4576)
at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onNext(FluxConcatMapNoPrefetch.java:207)
at reactor.core.publisher.SerializedSubscriber.onNext(SerializedSubscriber.java:99)
at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onNext(FluxRetryWhen.java:178)
at reactor.core.publisher.MonoFlatMapMany$FlatMapManyInner.onNext(MonoFlatMapMany.java:251)
at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79)
at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.innerNext(FluxConcatMapNoPrefetch.java:259)
at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:865)
at reactor.core.publisher.FluxConcatMap$WeakScalarSubscription.request(FluxConcatMap.java:480)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2367)
at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onNext(FluxConcatMapNoPrefetch.java:202)
at reactor.core.publisher.FluxBufferPredicate$BufferPredicateSubscriber.onNextNewBuffer(FluxBufferPredicate.java:317)
at reactor.core.publisher.FluxBufferPredicate$BufferPredicateSubscriber.tryOnNext(FluxBufferPredicate.java:227)
at reactor.core.publisher.FluxBufferPredicate$BufferPredicateSubscriber.onNext(FluxBufferPredicate.java:200)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onNext(FluxPeekFuseable.java:503)
at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onNext(FluxMapFuseable.java:299)
at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onNext(FluxContextWrite.java:107)
at reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onNext(FluxDoFinally.java:113)
at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onNext(FluxConcatArray.java:180)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drainAsync(FluxFlattenIterable.java:453)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drain(FluxFlattenIterable.java:724)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.onNext(FluxFlattenIterable.java:256)
at reactor.core.publisher.FluxPublish$PublishSubscriber.drain(FluxPublish.java:571)
at reactor.core.publisher.FluxPublish$PublishSubscriber.onNext(FluxPublish.java:310)
at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onNext(FluxContextWrite.java:107)
at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onNext(FluxMapFuseable.java:299)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drainAsync(FluxFlattenIterable.java:453)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drain(FluxFlattenIterable.java:724)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.onNext(FluxFlattenIterable.java:256)
at reactor.adapter.JdkFlowAdapter$SubscriberToRS.onNext(JdkFlowAdapter.java:150)
at java.net.http/jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.onNext(ResponseSubscribers.java:1006)
at java.net.http/jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.onNext(ResponseSubscribers.java:846)
at java.net.http/jdk.internal.net.http.Http1Response$Http1BodySubscriber.onNext(Http1Response.java:382)
at java.net.http/jdk.internal.net.http.Http1Response$Http1BodySubscriber.onNext(Http1Response.java:297)
at java.net.http/jdk.internal.net.http.ResponseContent$UnknownLengthBodyParser.accept(ResponseContent.java:503)
at java.net.http/jdk.internal.net.http.ResponseContent$UnknownLengthBodyParser.accept(ResponseContent.java:456)
at java.net.http/jdk.internal.net.http.Http1Response$BodyReader.handle(Http1Response.java:790)
at java.net.http/jdk.internal.net.http.Http1Response$BodyReader.handle(Http1Response.java:720)
at java.net.http/jdk.internal.net.http.Http1Response$Receiver.accept(Http1Response.java:612)
at java.net.http/jdk.internal.net.http.Http1Response$BodyReader.tryAsyncReceive(Http1Response.java:750)
at java.net.http/jdk.internal.net.http.Http1AsyncReceiver.flush(Http1AsyncReceiver.java:233)
at java.net.http/jdk.internal.net.http.common.SequentialScheduler$LockingRestartableTask.run(SequentialScheduler.java:205)
at java.net.http/jdk.internal.net.http.common.SequentialScheduler$CompleteRestartableTask.run(SequentialScheduler.java:149)
at java.net.http/jdk.internal.net.http.common.SequentialScheduler$SchedulableTask.run(SequentialScheduler.java:230)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:840)

how to do？.....