Message order is guaranteed for a given partition, messages are read by
the consumer in a FIFO manner.
You say partitioning based on topic. Do you mean you are using the
default HashPartitioner with the topic name as the routing key? If this
is the case, then all of your messages will be going to the same
partition (which is not normally what you want). Perhaps you could paste
a sample of the code you are using to produce messages, as this will
clarify what you mean by "partitioned based on message topic"
Cheers
-David
On 4/30/13 5:57 AM, Arjun Harish wrote:
Hi
I have a kafka cluster partitioned based on message topic. My question is
if one of the topics get a lot of messages than usual (i mean a lot to use
up a lot of resources) and one of the other topics is coming at normal
rate, does kafka ensure that the messages in the latter topic reach the
consumer(Its a pull at the consumer)?
Regards
Arjun Harish Nadh
