And also there something that I think worth mentioning,when I call
prod.send(KeyedMessage("foo", "a", "test message")), the data can't be
delivered to the brokers, the only way to make it work is
through:prod.send(KeyedMessage("foo", "a".getBytes, "test message".getBytes)).
When I convert the data and key to bytes, the data is not going to the proper
partitions.
Thanks
On Thursday, March 5, 2015 12:59 PM, Zijing Guo
<alter...@yahoo.com.INVALID> wrote:
Hi Guozhang,I'm using kafka 0.8.2.0
Thanks
On Thursday, March 5, 2015 12:57 PM, Guozhang Wang <wangg...@gmail.com>
wrote:
Zijing,
Which version of Kafka client are you using?
On Thu, Mar 5, 2015 at 8:50 AM, Zijing Guo <alter...@yahoo.com.invalid>
wrote:
> Hi community,I have a 2 nodes test cluster with 2 zk instance and 2 broker
> instance running and I'm experimenting kafka producer in a cluster
> environment. So I create a topic "foo" with 2 partitions and replication
> 1.I create a async Producer without defining partition.class (so the
> partitioner will be the default one, which is
> "kafka.producer.DefaultPartitioner" and I verified.)
> Now since I know that there is 2 partitions for topic "foo" and I create
> 1000 KeyedMessage with key = "a"
> val msgs = val msgs = (1 to 1000).map(e => KeyedMessage("foo","test
> message" + e, "a")) prod.send(msgs)
>
> In theory, "a".hashCode=97, 97 % 2 = 1. so I should expect all the message
> go to broker1. However,after I send the message, from the kafka Web
> console, I can see that the data is evenly distributed around the 2 brokers.
> Any help will be appreciated.Thanks
>
>
--
-- Guozhang
