In 0.7, we create a new socket after reconnect.interval messages. Messages
sent through different sockets may not arrive at the broker in order. The
reason to have reconnect.interval is for the producer to get a chance to
see the new broker added to a load balancer (if one uses a VIP to send
messag
I see, can you share more details of your verification ? Do you print
the messages sent by the producer and then compare that to the
messages printed on the consumer side ?
Thanks,
Neha
On Fri, Apr 19, 2013 at 5:51 PM, Jason Loveland
wrote:
> We are running kafka 0.7.2.
>
> We have a simple prod
We are running kafka 0.7.2.
We have a simple producer that sends messages in time order into a single
broker with a single partition. We have a simple consumer that has 1 thread
that gets messages. Our simple program shows some messages out of order when
consuming. This was very surprising beca