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

toString() on KafkaStream gets stuck indefinitely

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Trivial
    • Resolution: Fixed
    • Affects Version/s: 0.8.0
    • Fix Version/s: 0.8.2.0
    • Component/s: consumer
    • Labels:

      Description

      There is no toString implementation for KafkaStream, so if a user tries to print the stream it falls back to default toString implementation which tries to iterate over the collection and gets stuck indefinitely as it awaits messages. KafkaStream could instead override the toString and return a verbose description of the stream with topic name etc.

      println("Current stream: " + stream) // This call never returns

        Attachments

        1. KAFKA-1146.patch
          0.5 kB
          Arup Malakar

          Activity

            People

            • Assignee:
              amalakar Arup Malakar
              Reporter:
              amalakar Arup Malakar
            • Votes:
              1 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: