[
https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14175500#comment-14175500
]
BalajiSeshadri commented on KAFKA-1476:
---------------------------------------
[~nehanarkhede] I tried to implement the describe group,but the cal is getting
stuck in while loop of readFrom.
Please see log below.
io.EOFException: Received -1 when reading from channel, socket has likely been
closed.
at kafka.utils.Utils$.read(Utils.scala:381)
at
kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
at kafka.network.Receive$class.readCompletely(Transmission.scala:56)
at
kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
at kafka.network.BlockingChannel.receive(BlockingChannel.scala:108)
at
kafka.client.ClientUtils$.channelToOffsetManager(ClientUtils.scala:154)
at
kafka.tools.ConsumerCommand$.getOffsetsByTopic(ConsumerCommand.scala:92)
at kafka.tools.ConsumerCommand$.main(ConsumerCommand.scala:67)
at kafka.tools.ConsumerCommand.main(ConsumerCommand.scala)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)
java.io.EOFException: Received -1 when reading from channel, socket has likely
been closed.
at kafka.utils.Utils$.read(Utils.scala:381)
at
kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
at kafka.network.Receive$class.readCompletely(Transmission.scala:56)
at
kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
at kafka.network.BlockingChannel.receive(BlockingChannel.scala:108)
at
kafka.client.ClientUtils$.channelToOffsetManager(ClientUtils.scala:154)
at
kafka.tools.ConsumerCommand$.getOffsetsByTopic(ConsumerCommand.scala:92)
at kafka.tools.ConsumerCommand$.main(ConsumerCommand.scala:67)
at kafka.tools.ConsumerCommand.main(ConsumerCommand.scala)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)
java.io.EOFException: Received -1 when reading from channel, socket has likely
been closed.
at kafka.utils.Utils$.read(Utils.scala:381)
at
kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
at kafka.network.Receive$class.readCompletely(Transmission.scala:56)
at
kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
at kafka.network.BlockingChannel.receive(BlockingChannel.scala:108)
at
kafka.client.ClientUtils$.channelToOffsetManager(ClientUtils.scala:154)
at
kafka.tools.ConsumerCommand$.getOffsetsByTopic(ConsumerCommand.scala:92)
at kafka.tools.ConsumerCommand$.main(ConsumerCommand.scala:67)
at kafka.tools.ConsumerCommand.main(ConsumerCommand.scala)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)
Its just continously going through while loop of
kafka.client.ClientUtils$.channelToOffsetManager(ClientUtils.scala:154).
> Get a list of consumer groups
> -----------------------------
>
> Key: KAFKA-1476
> URL: https://issues.apache.org/jira/browse/KAFKA-1476
> Project: Kafka
> Issue Type: Wish
> Components: tools
> Affects Versions: 0.8.1.1
> Reporter: Ryan Williams
> Assignee: BalajiSeshadri
> Labels: newbie
> Fix For: 0.9.0
>
> Attachments: KAFKA-1476-LIST-GROUPS.patch, KAFKA-1476-RENAME.patch,
> KAFKA-1476.patch
>
>
> It would be useful to have a way to get a list of consumer groups currently
> active via some tool/script that ships with kafka. This would be helpful so
> that the system tools can be explored more easily.
> For example, when running the ConsumerOffsetChecker, it requires a group
> option
> bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --topic test --group
> ?
> But, when just getting started with kafka, using the console producer and
> consumer, it is not clear what value to use for the group option. If a list
> of consumer groups could be listed, then it would be clear what value to use.
> Background:
> http://mail-archives.apache.org/mod_mbox/kafka-users/201405.mbox/%3cCAOq_b1w=slze5jrnakxvak0gu9ctdkpazak1g4dygvqzbsg...@mail.gmail.com%3e
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
