Is this the same issue as KAFKA-2880
<https://issues.apache.org/jira/browse/KAFKA-2880>? It is solved in trunk
and will be included in 0.9.0.1 release.
On Wed, Dec 23, 2015 at 1:14 PM, Gwen Shapira <g...@confluent.io> wrote:
> Yes, this looks like a bug. Please file a JIRA :)
>
> On Wed, Dec 23, 2015 at 1:08 AM, Enrico Olivelli - Diennea <
> enrico.olive...@diennea.com> wrote:
>
> > Hi,
> > I'm running a brand new Kafka cluster (version 0.9.0.0). During my tests
> I
> > noticed this error at Consumer.partitionsFor during a full cluster
> restart.
> > My DEV cluster is made of 4 brokers
> >
> > Maybe I can workaround the error doing sanity checks on cluster /using my
> > platform middleware tools) before instantiating the Consumer
> >
> > Should I file an issue on your JIRA ?
> >
> > Thanks
> >
> > This is my code:
> >
> > this.properties = new Properties();
> > properties.put("bootstrap.servers", "list of servers"));
> > properties.put("acks", "all");
> > properties.put("retries", 0);
> > properties.put("batch.size", 16384);
> > properties.put("linger.ms", 1);
> > properties.put("buffer.memory", 33554432);
> > properties.put("group.id", "test");
> > properties.put("session.timeout.ms", "30000");
> > properties.put("key.deserializer",
> > "org.apache.kafka.common.serialization.ByteArrayDeserializer");
> > properties.put("value.deserializer",
> > "org.apache.kafka.common.serialization.ByteArrayDeserializer");
> >
> > String topic = "xxx";
> > try (KafkaConsumer<byte[], byte[]> consumer = new
> > KafkaConsumer<>(properties);) {
> > List<PartitionInfo> partitions =
> consumer.partitionsFor(topic);
> > ....
> > }
> >
> > This is the error:
> > java.lang.NullPointerException
> > at
> >
> org.apache.kafka.common.requests.MetadataResponse.<init>(MetadataResponse.java:130)
> > at
> >
> org.apache.kafka.clients.consumer.internals.Fetcher.getTopicMetadata(Fetcher.java:203)
> > at
> >
> org.apache.kafka.clients.consumer.KafkaConsumer.partitionsFor(KafkaConsumer.java:1143)
> > at
> >
> magnews.datastream.KafkaDataStreamConsumer.fetchNewData(KafkaDataStreamConsumer.java:44)
> >
> > Enrico Olivelli
> > Software Development Manager @Diennea
> > Tel.: (+39) 0546 066100 - Int. 925
> > Viale G.Marconi 30/14 - 48018 Faenza (RA)
> >
> > MagNews - E-mail Marketing Solutions
> > http://www.magnews.it<http://www.magnews.it/>
> > Diennea - Digital Marketing Solutions
> > http://www.diennea.com<http://www.diennea.com/>
> >
> >
> > ________________________________
> > Iscriviti alla nostra newsletter per rimanere aggiornato su digital ed
> > email marketing! http://www.magnews.it/newsletter/
> >
> > The information in this email is confidential and may be legally
> > privileged. If you are not the intended recipient please notify the
> sender
> > immediately and destroy this email. Any unauthorized, direct or indirect,
> > disclosure, copying, storage, distribution or other use is strictly
> > forbidden.
> >
>
--
-- Guozhang
