kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-5618) Kafka stream not receive any topic/partitions/records info
Date Fri, 21 Jul 2017 05:00:00 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095784#comment-16095784
] 

Matthias J. Sax commented on KAFKA-5618:
----------------------------------------

Thanks for following up. If it hangs and the threads never start up it might be good to get
DEBUG logs to see where is got stuck. Btw: half an hour might be a recovery time that could
happen depending of the number of stores and store sized (ie, record size, number of distinct
keys).

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

Mime
View raw message