Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Plain View
Kafka >> mail # user >> Kafka 0.8 - KeyedMessage?

Copy link to this message
Kafka 0.8 - KeyedMessage?

I did some search on the web but couldn't find any documentation for
0.8 so I am trying to ask here:

KeyedMessage is introduced in 0.8.0:
class KeyedMessage[K, V](val topic: String, val key: K, val message: V)

Does the parameter "key" = "partition key"?

If I build a KeyedMessage with a specific key string, then the message
will be stored to this partition, right?

If I build a KeyedMessage without a key, then the message will be
distributed to a random partition belonging to this topic? Or will it
always use a certain default partition?



Jun Rao 2013-01-07, 17:04
Jason Huang 2013-01-07, 17:31
Neha Narkhede 2013-01-07, 18:52
Jason Huang 2013-01-07, 19:09