kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jun Rao <jun...@gmail.com>
Subject Re: kafka partitioning
Date Tue, 25 Sep 2012 17:23:27 GMT
Producer uses a partitioning function to map partitionKey to a partition.

Thanks,

Jun

On Tue, Sep 25, 2012 at 9:55 AM, Raymond Ng <raymondair@gmail.com> wrote:

> Hi
>
> can someone please explain the relationship between the partitioning key in
> ProducerData(topic, *partitionKey*, eventList) from producer and the
> partition parameter in FetchRequest(topic, *partition*, offset, fetchsize)
> from consumer
>
> one is String and the other is int, so I assume there're not referring to
> the same thing, I want to know if I can specify which partition on the
> broker the producer's msg will be stored, and how to consume the  msg
> specifically on this partition
>
> thanks
>
> Ray
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message