Gavin Manning created KAFKA-3956: ------------------------------------ Summary: MockProducer.send() sends a message before completeNext() or errorNext() are called Key: KAFKA-3956 URL: https://issues.apache.org/jira/browse/KAFKA-3956 Project: Kafka Issue Type: Bug Components: producer Affects Versions: 0.10.0.0 Environment: JUnit test Reporter: Gavin Manning
I pass false for autoComplete to MockProducer's constructor. I then call MockProducer.send(). MockProducer.history() now contains that message. I would expect completeNext() to cause the message to be added to history and errorNext() to *not* add the message to history. -- This message was sent by Atlassian JIRA (v6.3.4#6332)