Versions Compared

Old Version 22

changes.mady.by.user Jiangjie Qin

Saved on

compared with

New Version 23

changes.mady.by.user Jiangjie Qin

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
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."

If a request is timeout and retries have not been exhausted, the request will be retried.

...

Code Block
languagejava
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."

...