I forgot to mention I was building with kafka-clients-0.8.2-beta. To reproduce this problem, I cloned kafka github repo and changed the source tree to the tag:0.8.2-beta and modified the dependency in my IDE from kafka-clients-0.8.2-beta to the source tree with tag:0.8.2-beta but I couldn't reproduce it... weird.
Also, I found out in 0.8.2 branch Producer interface was changed with generics. So, do I need to expect 0.8.2 official release will have generic Producer interface? On Sun, Dec 28, 2014 at 11:57 AM, Neha Narkhede <neha.narkh...@gmail.com> wrote: > This is a bug. Would you mind filing a JIRA? Also feel free to upload a > patch. > > On Sat, Dec 27, 2014 at 7:25 PM, Bae, Jae Hyeon <metac...@gmail.com> > wrote: > > > Hi > > > > While I am testing kafka java producer, I saw the following NPE > > > > SLF4J: Failed toString() invocation on an object of type > > [org.apache.kafka.common.Cluster] > > java.lang.NullPointerException > > at org.apache.kafka.common.PartitionInfo.toString(PartitionInfo.java:72) > > at java.lang.String.valueOf(String.java:2854) > > at java.lang.StringBuilder.append(StringBuilder.java:128) > > at java.util.AbstractCollection.toString(AbstractCollection.java:458) > > at java.lang.String.valueOf(String.java:2854) > > at java.lang.StringBuilder.append(StringBuilder.java:128) > > at org.apache.kafka.common.Cluster.toString(Cluster.java:151) > > at > > > > > org.slf4j.helpers.MessageFormatter.safeObjectAppend(MessageFormatter.java:305) > > at > > > > > org.slf4j.helpers.MessageFormatter.deeplyAppendParameter(MessageFormatter.java:277) > > at > > org.slf4j.helpers.MessageFormatter.arrayFormat(MessageFormatter.java:231) > > at org.slf4j.helpers.MessageFormatter.format(MessageFormatter.java:152) > > at org.slf4j.impl.Log4jLoggerAdapter.debug(Log4jLoggerAdapter.java:251) > > at > > > > > org.apache.kafka.clients.producer.internals.Metadata.update(Metadata.java:133) > > at > > > > > org.apache.kafka.clients.NetworkClient.handleMetadataResponse(NetworkClient.java:299) > > at > > > > > org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:284) > > at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:185) > > at > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:175) > > at > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:115) > > at java.lang.Thread.run(Thread.java:744) > > > > This looks like not critical because it's debug() statement but this NPE > > means potential threat in kafka producer stableness. > > > > Do you have any idea? If you want, I can share my test code. > > > > Thank you > > Best, Jae > > >
