public static class BlockingSendClient.Builder extends Object
Constructor and Description |
---|
Builder(kafka.server.KafkaConfig config,
org.apache.kafka.common.utils.Time time,
String clientId,
org.apache.kafka.common.utils.LogContext logContext) |
Modifier and Type | Method and Description |
---|---|
BlockingSendClient |
build(kafka.cluster.BrokerEndPoint targetBroker) |
public Builder(kafka.server.KafkaConfig config, org.apache.kafka.common.utils.Time time, String clientId, org.apache.kafka.common.utils.LogContext logContext)
public BlockingSendClient build(kafka.cluster.BrokerEndPoint targetBroker)