public class KafkaMessageService extends Object implements Lifecycleable
| 构造器和说明 |
|---|
KafkaMessageService() |
public void setMessageHandler(AbstractMessageHandler handler)
handler - should invoke init() succeedpublic void setConfig(KafkaMessageServiceConfig config)
public boolean init()
init 在接口中 Lifecycleablepublic void uninit()
uninit 在接口中 LifecycleableCopyright © 2017. All rights reserved.