Arup Malakar created KAFKA-1146:
-----------------------------------

             Summary: toString() on KafkaStream gets stuck indefinitely
                 Key: KAFKA-1146
                 URL: https://issues.apache.org/jira/browse/KAFKA-1146
             Project: Kafka
          Issue Type: Bug
          Components: consumer
    Affects Versions: 0.8
            Reporter: Arup Malakar
            Assignee: Neha Narkhede
            Priority: Trivial


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



--
This message was sent by Atlassian JIRA
(v6.1#6144)

Reply via email to