[
https://issues.apache.org/jira/browse/HADOOP-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongyuan Li updated HADOOP-14623:
-
Attachment: HADOOP-14623-004.patch
modify compile error and check style warn
> fixed some bugs
[
https://issues.apache.org/jira/browse/HADOOP-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongyuan Li updated HADOOP-14623:
-
Attachment: HADOOP-14623-003.patch
> fixed some bugs in KafkaSink
> ---
[
https://issues.apache.org/jira/browse/HADOOP-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongyuan Li updated HADOOP-14623:
-
Attachment: HADOOP-14623-002.patch
> fixed some bugs in KafkaSink
> ---
[
https://issues.apache.org/jira/browse/HADOOP-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongyuan Li updated HADOOP-14623:
-
Summary: fixed some bugs in KafkaSink (was: KafkaSink#init should set
acks to 1,not 0 and key.