Search before asking

• I had searched in the issues and found no similar issues.

Environment

Mac

EventMesh version

master

What happened

It is possible that the Kafka consumer will be closed twice. It will raise an IllegalStateException when being closed again.

How to reproduce

1. Run Eventmesh on Kafka
2. Call shutdown to the consumer implementation

The exception will be raised.

Debug logs

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!