Search before asking

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

Enhancement Request

• In storage modules of knative, rocketmq, pulsar, kafka, the model of Producer's hierarchy is not unified and confused: 3 AbstractProducers in module knative, rocketmq, pulsar have some similar contents, but some implement Producer and some not. Even AbstractProducer in kafka is not been designed into Producer's hierarchy.
• InterruptedException should never be ignored. Or the import interrupted state of Thread may be ignored unexpected.
• Some logic has been provided by existing util, so no need to code again.
• Smaller synchronized scope, lower the thread competitiveness
• In AtomicXxx, set() is thread safe and better than CAS when no need to get a return value.

Describe the solution you'd like

• Unify the model of Producer's hierarchy: Rename 3 AbstractProducer in module knative, rocketmq to KnativeAbstractProducer, RocketmqAbstractProducer. Add a AbstractProducer in api module implements Producer. Make AbstractProducers in module knative, kafka, rocketmq, pulsar all extends AbstractProducer in api module or its sub abstract class. Remove AbstractProducer in module pulsar.
• Catch InterruptedException and call interrupt() of current Thread.
• Use existing util.
• Minimize synchronized scope.
• Use set replace CAS where no need get a return value.

Are you willing to submit PR?

• Yes I am willing to submit a PR!