this is used right below, line 312:
```
public KafkaConsumer<byte[], byte[]> createConsumerAndSubscribeTo(String...
topics) {
KafkaConsumer<byte[], byte[]> consumer = createConsumer();
consumer.subscribe(Arrays.asList(topics));
....
```[ Full content available at: https://github.com/apache/kafka/pull/5516 ] This message was relayed via gitbox.apache.org for [email protected]
