That api is for scala users. If you are a java user, use kafka.javaapi.consumer.ConsumerConnector instead.
Thanks, Jun On Tue, Apr 17, 2012 at 2:16 AM, liu brent <liubaoc...@gmail.com> wrote: > Hi, > In http://incubator.apache.org/kafka/quickstart.html, there is a line: > Map<String, List<KafkaMessageStream<Message>>> topicMessageStreams = > connector.createMessageStreams(ImmutableMap.of("test", 4)); > But I do not know how to import ImmutableMap. Do we need to a package? > > Thanks, > Brent >
