[jira] [Updated] (KAFKA-1146) toString() on KafkaStream gets stuck indefinitely
[
https://issues.apache.org/jira/browse/KAFKA-1146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-1146:
---
Resolution: Fixed
Fix Version/s: (was: 0.9.0)
0.8.2
Assignee: Arup Malakar
Status: Resolved (was: Patch Available)
Thanks for the patch. +1 and committed to trunk.
> 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.0
>Reporter: Arup Malakar
>Assignee: Arup Malakar
>Priority: Trivial
> Labels: newbie
> Fix For: 0.8.2
>
> Attachments: KAFKA-1146.patch
>
>
> 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.2#6252)
[jira] [Updated] (KAFKA-1146) toString() on KafkaStream gets stuck indefinitely
[
https://issues.apache.org/jira/browse/KAFKA-1146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arup Malakar updated KAFKA-1146:
Attachment: KAFKA-1146.patch
> 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.0
>Reporter: Arup Malakar
>Priority: Trivial
> Labels: newbie
> Fix For: 0.9.0
>
> Attachments: KAFKA-1146.patch
>
>
> 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.2#6252)
[jira] [Updated] (KAFKA-1146) toString() on KafkaStream gets stuck indefinitely
[
https://issues.apache.org/jira/browse/KAFKA-1146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arup Malakar updated KAFKA-1146:
Status: Patch Available (was: Open)
> 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.0
>Reporter: Arup Malakar
>Priority: Trivial
> Labels: newbie
> Fix For: 0.9.0
>
> Attachments: KAFKA-1146.patch
>
>
> 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.2#6252)
[jira] [Updated] (KAFKA-1146) toString() on KafkaStream gets stuck indefinitely
[
https://issues.apache.org/jira/browse/KAFKA-1146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1146:
-
Fix Version/s: (was: 0.8.1)
0.9.0
> 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.0
>Reporter: Arup Malakar
>Priority: Trivial
> Labels: newbie
> Fix For: 0.9.0
>
>
> 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.5#6160)
[jira] [Updated] (KAFKA-1146) toString() on KafkaStream gets stuck indefinitely
[
https://issues.apache.org/jira/browse/KAFKA-1146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-1146:
---
Assignee: (was: Neha Narkhede)
Labels: newbie (was: )
> 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.0
>Reporter: Arup Malakar
>Priority: Trivial
> Labels: newbie
> Fix For: 0.8.1
>
>
> 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.5#6160)
[jira] [Updated] (KAFKA-1146) toString() on KafkaStream gets stuck indefinitely
[
https://issues.apache.org/jira/browse/KAFKA-1146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1146:
--
Fix Version/s: 0.8.1
Yes this is due to KafkaStream being a scala iterable - toString on
an iterable (per the scala-doc): "returns a string representation of
this collection. By default this string consists of the stringPrefix
of this immutable iterable collection, followed by all elements
separated by commas and enclosed in parentheses."
We can just override it simce others have run into this as well.
> 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
> Fix For: 0.8.1
>
>
> 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)
