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.
>
