[ https://issues.apache.org/jira/browse/KAFKA-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094886#comment-16094886 ]
Matthias J. Sax commented on KAFKA-5618: ---------------------------------------- [~yogeshbelur] I did have a look into the logs. They don't contain anything from Streams (expect the used configs). There are a couple of other exception there that seem to come from you application code though. Can you double check that it's really a Streams problem? Also, what do you mean by "not bring up Stream successfully" -- does it hang or does it crash? If it hangs, how long did you wait? Does the app need to rebuild state (depending on the state this, this can take some time) > Kafka stream not receive any topic/partitions/records info > ---------------------------------------------------------- > > Key: KAFKA-5618 > URL: https://issues.apache.org/jira/browse/KAFKA-5618 > Project: Kafka > Issue Type: Bug > Components: streams > Reporter: Yogesh BG > Priority: Critical > Attachments: rtp-kafkastreams2.log, rtp-kafkastreams3.log, > rtp-kafkastreams.log > > > I have 3 brokers and 3 stream consumers. > I have there are 360 partitions and not able to bring up streams successfully > even after several retry. > I have attached the logs. > There are other topics which are having around 16 partitions and they are > able to successfully be consumed by kafka client<no streaming> > when tried getting thread dump using jstack the process is not responding > Attaching to process ID 10663, please wait... > Debugger attached successfully. > Server compiler detected. > JVM version is 24.141-b02 > Deadlock Detection: > java.lang.RuntimeException: Unable to deduce type of thread from address > 0x00007fdac4009000 (expected type JavaThread, CompilerThread, ServiceThread, > JvmtiAgentThread, or SurrogateLockerThread) > at > sun.jvm.hotspot.runtime.Threads.createJavaThreadWrapper(Threads.java:162) > at sun.jvm.hotspot.runtime.Threads.first(Threads.java:150) > at > sun.jvm.hotspot.runtime.DeadlockDetector.createThreadTable(DeadlockDetector.java:149) > at > sun.jvm.hotspot.runtime.DeadlockDetector.print(DeadlockDetector.java:56) > at > sun.jvm.hotspot.runtime.DeadlockDetector.print(DeadlockDetector.java:39) -- This message was sent by Atlassian JIRA (v6.4.14#64029)