[jira] [Commented] (HADOOP-14623) KafkaSink#init should set acks to 1,not 0

[ https://issues.apache.org/jira/browse/HADOOP-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076628#comment-16076628 ] Hongyuan Li commented on HADOOP-14623: -- futuremore, flush method is to confirm that data has been

[jira] [Commented] (HADOOP-14623) KafkaSink#init should set acks to 1,not 0

[ https://issues.apache.org/jira/browse/HADOOP-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076154#comment-16076154 ] Hongyuan Li commented on HADOOP-14623: -- i don't think so, setting it to 1 does not means that it

[jira] [Commented] (HADOOP-14623) KafkaSink#init should set acks to 1,not 0

[ https://issues.apache.org/jira/browse/HADOOP-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16074965#comment-16074965 ] Allen Wittenauer commented on HADOOP-14623: --- I believe setting acks to 0 is intentional so

[jira] [Commented] (HADOOP-14623) KafkaSink#init should set acks to 1,not 0

[ https://issues.apache.org/jira/browse/HADOOP-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16074856#comment-16074856 ] Hongyuan Li commented on HADOOP-14623: -- [~jojochuang] i will try to test it, but iam not sure it

[jira] [Commented] (HADOOP-14623) KafkaSink#init should set acks to 1,not 0

[ https://issues.apache.org/jira/browse/HADOOP-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16074698#comment-16074698 ] Wei-Chiu Chuang commented on HADOOP-14623: -- Sorry I don't know Kafka enough to make an