PulsarSourceITCase.testMultipleSplits fails due to "Consumer not found"

Sep 13 00:00:49 Caused by: org.apache.pulsar.client.api.PulsarClientException$BrokerMetadataException: Consumer not found
Sep 13 00:00:49 	at org.apache.pulsar.client.api.PulsarClientException.unwrap(PulsarClientException.java:987)
Sep 13 00:00:49 	at org.apache.pulsar.client.impl.PulsarClientImpl.close(PulsarClientImpl.java:658)
Sep 13 00:00:49 	at org.apache.flink.connector.pulsar.source.reader.source.PulsarSourceReaderBase.close(PulsarSourceReaderBase.java:83)
Sep 13 00:00:49 	at org.apache.flink.connector.pulsar.source.reader.source.PulsarOrderedSourceReader.close(PulsarOrderedSourceReader.java:170)
Sep 13 00:00:49 	at org.apache.flink.streaming.api.operators.SourceOperator.close(SourceOperator.java:324)
Sep 13 00:00:49 	at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141)
Sep 13 00:00:49 	at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127)
Sep 13 00:00:49 	at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1030)
Sep 13 00:00:49 	at org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:874)
Sep 13 00:00:49 	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:762)
Sep 13 00:00:49 	at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
Sep 13 00:00:49 	at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)
Sep 13 00:00:49 	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)
Sep 13 00:00:49 	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
Sep 13 00:00:49 	at java.lang.Thread.run(Thread.java:748)