kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jun Rao <jun...@gmail.com>
Subject Re: How to import ImmutableMap in quick start?
Date Tue, 17 Apr 2012 15:02:04 GMT
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 <liubaochun@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
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message