Jesse Anderson created KAFKA-2892:
-------------------------------------
Summary: Consumer Docs Use Wrong Method
Key: KAFKA-2892
URL: https://issues.apache.org/jira/browse/KAFKA-2892
Project: Kafka
Issue Type: Bug
Components: clients
Affects Versions: 0.9.0.0
Reporter: Jesse Anderson
The KafkaConsumer docs use a non-existent method for assigning partitions
({{consumer.assign}}).
The JavaDocs show as:
String topic = "foo";
TopicPartition partition0 = new TopicPartition(topic, 0);
TopicPartition partition1 = new TopicPartition(topic, 1);
consumer.assign(partition0);
consumer.assign(partition1);
Should be:
String topic = "foo";
TopicPartition partition0 = new TopicPartition(topic, 0);
TopicPartition partition1 = new TopicPartition(topic, 1);
consumer.assign(Arrays.asList(partition0));
consumer.assign(Arrays.asList(partition1));
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
