Chris Riccomini created SAMZA-458:
-------------------------------------
Summary: Close in KafkaSystemProducer should flush all source
buffers
Key: SAMZA-458
URL: https://issues.apache.org/jira/browse/SAMZA-458
Project: Samza
Issue Type: Bug
Components: kafka
Reporter: Chris Riccomini
I noticed that calling KafkaSystemProducer.stop does not flush any outstanding
messages in the sourceBuffers array. Calling close should flush all buffers.
Without this, shutting down can cause messages to be dropped.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
