Sorry I just created this. I'm going to mark it as duplicate https://issues.apache.org/jira/browse/KAFKA-3041
-----Messaggio originale----- Da: Guozhang Wang [mailto:wangg...@gmail.com] Inviato: mercoledì 23 dicembre 2015 22:24 A: users@kafka.apache.org Oggetto: Re: NPE on 0.9.0.0 Consumer during broker restart 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>(MetadataRespo > nse.java:130) > > at > > > org.apache.kafka.clients.consumer.internals.Fetcher.getTopicMetadata(F > etcher.java:203) > > at > > > org.apache.kafka.clients.consumer.KafkaConsumer.partitionsFor(KafkaCon > sumer.java:1143) > > at > > > magnews.datastream.KafkaDataStreamConsumer.fetchNewData(KafkaDataStrea > mConsumer.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 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.
