public class KafkaRpcServerManager extends Object
Constructor and Description |
---|
KafkaRpcServerManager(KafkaConfigProvider configProvider,
MinionIdentity minionIdentity,
TracerRegistry tracerRegistry) |
Modifier and Type | Method and Description |
---|---|
void |
bind(RpcModule module) |
void |
destroy() |
void |
init() |
protected void |
startConsumerForModule(RpcModule<RpcRequest,RpcResponse> rpcModule) |
protected void |
stopConsumerForModule(RpcModule<RpcRequest,RpcResponse> rpcModule) |
void |
unbind(RpcModule module) |
public KafkaRpcServerManager(KafkaConfigProvider configProvider, MinionIdentity minionIdentity, TracerRegistry tracerRegistry)
public void init() throws IOException
IOException
protected void startConsumerForModule(RpcModule<RpcRequest,RpcResponse> rpcModule)
protected void stopConsumerForModule(RpcModule<RpcRequest,RpcResponse> rpcModule)
public void destroy()
Copyright © 2020. All rights reserved.