Navina Ramesh created SAMZA-524: ----------------------------------- Summary: Update KafkaSystemProducer after Kafka provides a flush behavior Key: SAMZA-524 URL: https://issues.apache.org/jira/browse/SAMZA-524 Project: Samza Issue Type: Bug Components: kafka Reporter: Navina Ramesh
Currently, kafka producer does not implement a "flush" interface for clients to invoke. Once such a feature is provided, we can hook it up in KafkaSystemProducer.scala -- This message was sent by Atlassian JIRA (v6.3.4#6332)