Blocker Description
Currently, Producer.send() doesn't return any value. In 0.8, since each produce request will be acked, we should pass the response back. What we can do is that if the producer is in sync mode, we can return a map of (topic,partitionId) -> (errorcode, offset). If the producer is in async mode, we can just return a null.
Attachments
Issue Links
- duplicates
-
KAFKA-1227 Code dump of new producer
-
- Resolved
-
