Flaky-test: io.streamnative.pulsar.handlers.kop.OffsetResetTest.testCliReset

[Demogorgon314]

io.streamnative.pulsar.handlers.kop.OffsetResetTest is flaky. The testCliReset test method fails sporadically.

example failure

Error:  testCliReset(io.streamnative.pulsar.handlers.kop.OffsetResetTest)  Time elapsed: 30.066 s  <<< FAILURE!
org.testng.internal.thread.ThreadTimeoutException: Method io.streamnative.pulsar.handlers.kop.OffsetResetTest.testCliReset() didn't finish within the time-out 30000
	at java.base@17.0.5/java.lang.Throwable.fillInStackTrace(Native Method)
	at java.base@17.0.5/java.lang.Throwable.fillInStackTrace(Throwable.java:798)
	at java.base@17.0.5/java.lang.Throwable.<init>(Throwable.java:256)
	at java.base@17.0.5/java.lang.Exception.<init>(Exception.java:55)
	at java.base@17.0.5/java.lang.InterruptedException.<init>(InterruptedException.java:57)
	at app//org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.maybeThrowInterruptException(ConsumerNetworkClient.java:520)
	at app//org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:281)
	at app//org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236)
	at app//org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1296)
	at app//org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1237)
	at app//org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1210)
	at app//io.streamnative.pulsar.handlers.kop.OffsetResetTest.testCliReset(OffsetResetTest.java:412)
	at java.base@17.0.5/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base@17.0.5/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
	at java.base@17.0.5/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base@17.0.5/java.lang.reflect.Method.invoke(Method.java:568)
	at app//org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
	at app//org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:54)
	at app//org.testng.internal.InvokeMethodRunnable.run(InvokeMethodRunnable.java:44)
	at java.base@17.0.5/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base@17.0.5/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base@17.0.5/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base@17.0.5/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base@17.0.5/java.lang.Thread.run(Thread.java:833)