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"
On 4/30/13 5:57 AM, Arjun Harish wrote:
> 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)?
> Arjun Harish Nadh