4

Given the fact that a Consumer in Kafka can be configured to receive messages only from one partition, I haven't seen a configuration approach for this.

How do I tell a Kafka broker:

That I'm a CONSUMER A with this ID, under this GROUP L, subscribing to TOPIC X, willing to get the stream of PARTITION A?

And then, start another CONSUMER B, under GROUP L, which subscribes to TOPIC X, willing to get the stream of PARTITION B?

In other words, as in the scenario described by Kafka,

How do I start a consumer subscribing to a wall feed of a specific user? Can I start a consumer when a user logs in, consumer his/her partition form the topic and send the feed to the client?

4

1 回答 1

0

看来这不是 0.7 中实现的功能。

看看这个线程:

http://mail-archives.apache.org/mod_mbox/incubator-kafka-users/201205.mbox/browser

但是,它计划在未来的版本中:

https://issues.apache.org/jira/browse/KAFKA-345 https://issues.apache.org/jira/browse/KAFKA-909

于 2013-09-28T15:46:51.680 回答