...
Code Block | ||
---|---|---|
| ||
public static final String REQUEST_TIMEOUT_CONFIG = "network.request.timeout.ms"; private static final String REQUEST_TIMEOUT_DOC = "The configuration controls the maximum amount of time the producer will wait " + "for the response of a request. If the response is not received before the timeout " + "elapses the producer will resend the request if necessary or fail the request if " + "retries are exhausted." |
...
Code Block | ||
---|---|---|
| ||
public static final String MAX_ENQUEUE_TIMEOUT_MS_CONFIG = "max.enqueue.timeout.ms"
private static final String MAX_ENQUEUE_TIMEOUT_DOC = "The configuration controls how long {@link KafkaProducer#send()} will block." +
"The send method can be blocked because of buffer full, metadata not available, " +
"customized partitioner/serialzier." |
...