Thanks Amir for digging deeper into this. On Wed, Aug 17, 2016 at 5:21 PM, amir bahmanyari <[email protected]> wrote:
> Ok. I see its Kafka that doesn't send records to KafkaIO() in the same > exact order as its being sent to it. > I proved it with a stand alone consumer several times and it shows. > As per Kafka docs suggestions, I recreated a new topic with number of > partitions=1 which Kafka docs say that guarantees exact order in a single > partition. > It still doesn't send them in the right order even with the number of > replications being just 1 i.e. no parallelism at all. > I would be very surprised if this is the case with Kafka. Are you publishing in single thread?
