Hongyuan Li created HADOOP-14623:
------------------------------------

             Summary: KafkaSink#init should set ack to 1
                 Key: HADOOP-14623
                 URL: https://issues.apache.org/jira/browse/HADOOP-14623
             Project: Hadoop Common
          Issue Type: Bug
            Reporter: Hongyuan Li


{{KafkaSink}}#{{init}}  should set ack to 1 to make sure the message has been 
written to the broker at least.
current code list below:

{code}
  
    props.put("request.required.acks", "0");

{code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

---------------------------------------------------------------------
To unsubscribe, e-mail: common-issues-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-issues-h...@hadoop.apache.org

Reply via email to