kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Raymond Ng <raymond...@gmail.com>
Subject kafka partitioning
Date Tue, 25 Sep 2012 16:55:53 GMT

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



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