Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-5618

Kafka stream not receive any topic/partitions/records info

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Critical
    • Resolution: Cannot Reproduce
    • None
    • None
    • streams
    • None

    Description

      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)

      Attachments

        1. rtp-kafkastreams.log
          310 kB
          Yogesh BG
        2. rtp-kafkastreams2.log
          529 kB
          Yogesh BG
        3. rtp-kafkastreams3.log
          703 kB
          Yogesh BG

        Activity

          People

            Unassigned Unassigned
            yogeshbelur Yogesh BG
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: