Description
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
Attachments
Issue Links
- is blocked by
-
KAFKA-1865 Add a flush() call to the new producer API
- Resolved
- is related to
-
SAMZA-227 Upgrade KafkaSystemProducer to new API
- Resolved