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
