kafka java客户端kafka-clients 0.8.2.1

Question

1. 首先maven依赖如下：

<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>0.8.2.1</version>

</dependency>

    2.kafka实践demo的producer已经能够往kafka里发布消息。

    3.consumer却一直配置出错，在apache的官网上找不到这版本kafka-clients的示例，配置如下：

    props.put("group.id", "test");

    props.put("partition.assignment.strategy", "range");

报错如下：

    2015-07-27 15:43:48,616 [main] WARN  [org.apache.kafka.clients.consumer.ConsumerConfig] - The configuration group.id = test was supplied but isn't a known config.
    2015-07-27 15:43:48,616 [main] WARN  [org.apache.kafka.clients.consumer.ConsumerConfig] - The configuration partition.assignment.strategy = range was supplied but isn't a known config.

    各路大神，麻烦帮我看看。

Answer 1

嗯，貌似是这样。