(correcting recipient address) On Thu, Mar 9, 2017 at 10:39 AM, Gaurav Agarwal <gauravagarw...@gmail.com> wrote:
> Hi All, > > We are trying to upgrade to Kafka 0.12.0. In the process we noticed that > the Kafka 0.10.0 KafkaProducer client api does not provide any > configuration to send() the messages synchronously. One needs to wait on > the returned Future for synchronous guarantees. > > I am trying to figure out, how to make our Samza task processing strictly > ordered - i.e. we want to process an incoming message and optionally write > back some messages to kafka. We do not want to start processing of next > message till it is guaranteed that our previously emitted messages from > samza tasks have been accepted by Kafka broker. > > Is there any samza configuration that will make this happen? The ` > MessageCollector` interface does not expose a 'flush()' method that we > could have called after doing a send() to ensure the delivery of message > to Kafka Broker. (note that `TaskInstanceCollector` - specific > implementation of `MessageCollector` interface does provide the required > flush() method) > > -- > cheers, > gaurav >
