[jira] [Commented] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka
[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963998#comment-15963998 ] Mohammed amine GARMES commented on KAFKA-3355: -- Hello [~fredji], this fix is for kafka 0.9.1.0. Bests > GetOffsetShell command doesn't work with SASL enabled Kafka > --- > > Key: KAFKA-3355 > URL: https://issues.apache.org/jira/browse/KAFKA-3355 > Project: Kafka > Issue Type: Bug > Components: tools >Affects Versions: 0.9.0.1 > Environment: Kafka 0.9.0.1 >Reporter: TAO XIAO >Assignee: Ashish Singh > > I found that GetOffsetShell doesn't work with SASL enabled Kafka. I believe > this is due to old producer being used in GetOffsetShell. > Kafka version 0.9.0.1 > Exception > % bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list > localhost:9092 --topic test --time -1 > [2016-03-04 21:43:56,597] INFO Verifying properties > (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property client.id is overridden to > GetOffsetShell (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property metadata.broker.list is overridden to > localhost:9092 (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property request.timeout.ms is overridden to > 1000 (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,674] INFO Fetching metadata from broker > BrokerEndPoint(0,localhost,9092) with correlation id 0 for 1 topic(s) > Set(test) (kafka.client.ClientUtils$) > [2016-03-04 21:43:56,689] INFO Connected to localhost:9092 for producing > (kafka.producer.SyncProducer) > [2016-03-04 21:43:56,705] WARN Fetching topic metadata with correlation id 0 > for topics [Set(test)] from broker [BrokerEndPoint(0,localhost,9092)] failed > (kafka.client.ClientUtils$) > java.nio.BufferUnderflowException > at java.nio.Buffer.nextGetIndex(Buffer.java:498) > at java.nio.HeapByteBuffer.getShort(HeapByteBuffer.java:304) > at kafka.api.ApiUtils$.readShortString(ApiUtils.scala:36) > at kafka.cluster.BrokerEndPoint$.readFrom(BrokerEndPoint.scala:52) > at > kafka.api.TopicMetadataResponse$$anonfun$1.apply(TopicMetadataResponse.scala:28) > at > kafka.api.TopicMetadataResponse$$anonfun$1.apply(TopicMetadataResponse.scala:28) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at scala.collection.immutable.Range.foreach(Range.scala:166) > at scala.collection.TraversableLike$class.map(TraversableLike.scala:245) > at scala.collection.AbstractTraversable.map(Traversable.scala:104) > at > kafka.api.TopicMetadataResponse$.readFrom(TopicMetadataResponse.scala:28) > at kafka.producer.SyncProducer.send(SyncProducer.scala:120) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:94) > at kafka.tools.GetOffsetShell$.main(GetOffsetShell.scala:78) > at kafka.tools.GetOffsetShell.main(GetOffsetShell.scala) -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka
[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963307#comment-15963307 ] Fred Ji commented on KAFKA-3355: Thanks for fixing this one! what version of kafka has this fix in? > GetOffsetShell command doesn't work with SASL enabled Kafka > --- > > Key: KAFKA-3355 > URL: https://issues.apache.org/jira/browse/KAFKA-3355 > Project: Kafka > Issue Type: Bug > Components: tools >Affects Versions: 0.9.0.1 > Environment: Kafka 0.9.0.1 >Reporter: TAO XIAO >Assignee: Ashish Singh > > I found that GetOffsetShell doesn't work with SASL enabled Kafka. I believe > this is due to old producer being used in GetOffsetShell. > Kafka version 0.9.0.1 > Exception > % bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list > localhost:9092 --topic test --time -1 > [2016-03-04 21:43:56,597] INFO Verifying properties > (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property client.id is overridden to > GetOffsetShell (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property metadata.broker.list is overridden to > localhost:9092 (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property request.timeout.ms is overridden to > 1000 (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,674] INFO Fetching metadata from broker > BrokerEndPoint(0,localhost,9092) with correlation id 0 for 1 topic(s) > Set(test) (kafka.client.ClientUtils$) > [2016-03-04 21:43:56,689] INFO Connected to localhost:9092 for producing > (kafka.producer.SyncProducer) > [2016-03-04 21:43:56,705] WARN Fetching topic metadata with correlation id 0 > for topics [Set(test)] from broker [BrokerEndPoint(0,localhost,9092)] failed > (kafka.client.ClientUtils$) > java.nio.BufferUnderflowException > at java.nio.Buffer.nextGetIndex(Buffer.java:498) > at java.nio.HeapByteBuffer.getShort(HeapByteBuffer.java:304) > at kafka.api.ApiUtils$.readShortString(ApiUtils.scala:36) > at kafka.cluster.BrokerEndPoint$.readFrom(BrokerEndPoint.scala:52) > at > kafka.api.TopicMetadataResponse$$anonfun$1.apply(TopicMetadataResponse.scala:28) > at > kafka.api.TopicMetadataResponse$$anonfun$1.apply(TopicMetadataResponse.scala:28) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at scala.collection.immutable.Range.foreach(Range.scala:166) > at scala.collection.TraversableLike$class.map(TraversableLike.scala:245) > at scala.collection.AbstractTraversable.map(Traversable.scala:104) > at > kafka.api.TopicMetadataResponse$.readFrom(TopicMetadataResponse.scala:28) > at kafka.producer.SyncProducer.send(SyncProducer.scala:120) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:94) > at kafka.tools.GetOffsetShell$.main(GetOffsetShell.scala:78) > at kafka.tools.GetOffsetShell.main(GetOffsetShell.scala) -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka
[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928034#comment-15928034 ] ASF GitHub Bot commented on KAFKA-3355: --- Github user garmes-gdev closed the pull request at: https://github.com/apache/kafka/pull/2289 > GetOffsetShell command doesn't work with SASL enabled Kafka > --- > > Key: KAFKA-3355 > URL: https://issues.apache.org/jira/browse/KAFKA-3355 > Project: Kafka > Issue Type: Bug > Components: tools >Affects Versions: 0.9.0.1 > Environment: Kafka 0.9.0.1 >Reporter: TAO XIAO >Assignee: Ashish Singh > > I found that GetOffsetShell doesn't work with SASL enabled Kafka. I believe > this is due to old producer being used in GetOffsetShell. > Kafka version 0.9.0.1 > Exception > % bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list > localhost:9092 --topic test --time -1 > [2016-03-04 21:43:56,597] INFO Verifying properties > (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property client.id is overridden to > GetOffsetShell (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property metadata.broker.list is overridden to > localhost:9092 (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property request.timeout.ms is overridden to > 1000 (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,674] INFO Fetching metadata from broker > BrokerEndPoint(0,localhost,9092) with correlation id 0 for 1 topic(s) > Set(test) (kafka.client.ClientUtils$) > [2016-03-04 21:43:56,689] INFO Connected to localhost:9092 for producing > (kafka.producer.SyncProducer) > [2016-03-04 21:43:56,705] WARN Fetching topic metadata with correlation id 0 > for topics [Set(test)] from broker [BrokerEndPoint(0,localhost,9092)] failed > (kafka.client.ClientUtils$) > java.nio.BufferUnderflowException > at java.nio.Buffer.nextGetIndex(Buffer.java:498) > at java.nio.HeapByteBuffer.getShort(HeapByteBuffer.java:304) > at kafka.api.ApiUtils$.readShortString(ApiUtils.scala:36) > at kafka.cluster.BrokerEndPoint$.readFrom(BrokerEndPoint.scala:52) > at > kafka.api.TopicMetadataResponse$$anonfun$1.apply(TopicMetadataResponse.scala:28) > at > kafka.api.TopicMetadataResponse$$anonfun$1.apply(TopicMetadataResponse.scala:28) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at scala.collection.immutable.Range.foreach(Range.scala:166) > at scala.collection.TraversableLike$class.map(TraversableLike.scala:245) > at scala.collection.AbstractTraversable.map(Traversable.scala:104) > at > kafka.api.TopicMetadataResponse$.readFrom(TopicMetadataResponse.scala:28) > at kafka.producer.SyncProducer.send(SyncProducer.scala:120) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:94) > at kafka.tools.GetOffsetShell$.main(GetOffsetShell.scala:78) > at kafka.tools.GetOffsetShell.main(GetOffsetShell.scala) -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka
[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15769800#comment-15769800 ] ASF GitHub Bot commented on KAFKA-3355: --- GitHub user garmes-gdev opened a pull request: https://github.com/apache/kafka/pull/2289 Master KAFKA-3355 GetOffsetShell command doesn't work with SASL enabled Kafka You can merge this pull request into a Git repository by running: $ git pull https://github.com/garmes-gdev/kafka master Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2289.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2289 commit 7544b536926bb580dce0abb0d29b0fab2276f367 Author: garmes-gdev Date: 2016-12-20T14:42:43Z Merge remote-tracking branch 'refs/remotes/apache/trunk' commit d38df2ae92920cbbca38159cdd29c0c9bb5979f0 Author: garmes-gdev Date: 2016-12-22T11:10:29Z KAFKA-3355 GetOffsetShell command doesn't work with SASL enabled Kafka > GetOffsetShell command doesn't work with SASL enabled Kafka > --- > > Key: KAFKA-3355 > URL: https://issues.apache.org/jira/browse/KAFKA-3355 > Project: Kafka > Issue Type: Bug > Components: tools >Affects Versions: 0.9.0.1 > Environment: Kafka 0.9.0.1 >Reporter: TAO XIAO >Assignee: Ashish K Singh > > I found that GetOffsetShell doesn't work with SASL enabled Kafka. I believe > this is due to old producer being used in GetOffsetShell. > Kafka version 0.9.0.1 > Exception > % bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list > localhost:9092 --topic test --time -1 > [2016-03-04 21:43:56,597] INFO Verifying properties > (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property client.id is overridden to > GetOffsetShell (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property metadata.broker.list is overridden to > localhost:9092 (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property request.timeout.ms is overridden to > 1000 (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,674] INFO Fetching metadata from broker > BrokerEndPoint(0,localhost,9092) with correlation id 0 for 1 topic(s) > Set(test) (kafka.client.ClientUtils$) > [2016-03-04 21:43:56,689] INFO Connected to localhost:9092 for producing > (kafka.producer.SyncProducer) > [2016-03-04 21:43:56,705] WARN Fetching topic metadata with correlation id 0 > for topics [Set(test)] from broker [BrokerEndPoint(0,localhost,9092)] failed > (kafka.client.ClientUtils$) > java.nio.BufferUnderflowException > at java.nio.Buffer.nextGetIndex(Buffer.java:498) > at java.nio.HeapByteBuffer.getShort(HeapByteBuffer.java:304) > at kafka.api.ApiUtils$.readShortString(ApiUtils.scala:36) > at kafka.cluster.BrokerEndPoint$.readFrom(BrokerEndPoint.scala:52) > at > kafka.api.TopicMetadataResponse$$anonfun$1.apply(TopicMetadataResponse.scala:28) > at > kafka.api.TopicMetadataResponse$$anonfun$1.apply(TopicMetadataResponse.scala:28) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at scala.collection.immutable.Range.foreach(Range.scala:166) > at scala.collection.TraversableLike$class.map(TraversableLike.scala:245) > at scala.collection.AbstractTraversable.map(Traversable.scala:104) > at > kafka.api.TopicMetadataResponse$.readFrom(TopicMetadataResponse.scala:28) > at kafka.producer.SyncProducer.send(SyncProducer.scala:120) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:94) > at kafka.tools.GetOffsetShell$.main(GetOffsetShell.scala:78) > at kafka.tools.GetOffsetShell.main(GetOffsetShell.scala) -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka
[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15735361#comment-15735361 ] Mohammed amine GARMES commented on KAFKA-3355: -- Hello [~singhashish], [~gwenshap], I want to know if there is news in relation to the problem of GetOffsetShell ? I fixed this issue for my company, I want to know if I can pufh this fix to be provided with 0.10.0.1 version ??! And I want to fix create/delete topic commands, because we have some security issue regarding the PCI DSS audit. Best regards > GetOffsetShell command doesn't work with SASL enabled Kafka > --- > > Key: KAFKA-3355 > URL: https://issues.apache.org/jira/browse/KAFKA-3355 > Project: Kafka > Issue Type: Bug > Components: tools >Affects Versions: 0.9.0.1 > Environment: Kafka 0.9.0.1 >Reporter: TAO XIAO >Assignee: Ashish K Singh > > I found that GetOffsetShell doesn't work with SASL enabled Kafka. I believe > this is due to old producer being used in GetOffsetShell. > Kafka version 0.9.0.1 > Exception > % bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list > localhost:9092 --topic test --time -1 > [2016-03-04 21:43:56,597] INFO Verifying properties > (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property client.id is overridden to > GetOffsetShell (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property metadata.broker.list is overridden to > localhost:9092 (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property request.timeout.ms is overridden to > 1000 (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,674] INFO Fetching metadata from broker > BrokerEndPoint(0,localhost,9092) with correlation id 0 for 1 topic(s) > Set(test) (kafka.client.ClientUtils$) > [2016-03-04 21:43:56,689] INFO Connected to localhost:9092 for producing > (kafka.producer.SyncProducer) > [2016-03-04 21:43:56,705] WARN Fetching topic metadata with correlation id 0 > for topics [Set(test)] from broker [BrokerEndPoint(0,localhost,9092)] failed > (kafka.client.ClientUtils$) > java.nio.BufferUnderflowException > at java.nio.Buffer.nextGetIndex(Buffer.java:498) > at java.nio.HeapByteBuffer.getShort(HeapByteBuffer.java:304) > at kafka.api.ApiUtils$.readShortString(ApiUtils.scala:36) > at kafka.cluster.BrokerEndPoint$.readFrom(BrokerEndPoint.scala:52) > at > kafka.api.TopicMetadataResponse$$anonfun$1.apply(TopicMetadataResponse.scala:28) > at > kafka.api.TopicMetadataResponse$$anonfun$1.apply(TopicMetadataResponse.scala:28) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at scala.collection.immutable.Range.foreach(Range.scala:166) > at scala.collection.TraversableLike$class.map(TraversableLike.scala:245) > at scala.collection.AbstractTraversable.map(Traversable.scala:104) > at > kafka.api.TopicMetadataResponse$.readFrom(TopicMetadataResponse.scala:28) > at kafka.producer.SyncProducer.send(SyncProducer.scala:120) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:94) > at kafka.tools.GetOffsetShell$.main(GetOffsetShell.scala:78) > at kafka.tools.GetOffsetShell.main(GetOffsetShell.scala) -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka
[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15188187#comment-15188187 ] Gwen Shapira commented on KAFKA-3355: - If you think you will finish by 0.10.0, go for it. > GetOffsetShell command doesn't work with SASL enabled Kafka > --- > > Key: KAFKA-3355 > URL: https://issues.apache.org/jira/browse/KAFKA-3355 > Project: Kafka > Issue Type: Bug > Components: tools >Affects Versions: 0.9.0.1 > Environment: Kafka 0.9.0.1 >Reporter: TAO XIAO >Assignee: Ashish K Singh > > I found that GetOffsetShell doesn't work with SASL enabled Kafka. I believe > this is due to old producer being used in GetOffsetShell. > Kafka version 0.9.0.1 > Exception > % bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list > localhost:9092 --topic test --time -1 > [2016-03-04 21:43:56,597] INFO Verifying properties > (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property client.id is overridden to > GetOffsetShell (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property metadata.broker.list is overridden to > localhost:9092 (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property request.timeout.ms is overridden to > 1000 (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,674] INFO Fetching metadata from broker > BrokerEndPoint(0,localhost,9092) with correlation id 0 for 1 topic(s) > Set(test) (kafka.client.ClientUtils$) > [2016-03-04 21:43:56,689] INFO Connected to localhost:9092 for producing > (kafka.producer.SyncProducer) > [2016-03-04 21:43:56,705] WARN Fetching topic metadata with correlation id 0 > for topics [Set(test)] from broker [BrokerEndPoint(0,localhost,9092)] failed > (kafka.client.ClientUtils$) > java.nio.BufferUnderflowException > at java.nio.Buffer.nextGetIndex(Buffer.java:498) > at java.nio.HeapByteBuffer.getShort(HeapByteBuffer.java:304) > at kafka.api.ApiUtils$.readShortString(ApiUtils.scala:36) > at kafka.cluster.BrokerEndPoint$.readFrom(BrokerEndPoint.scala:52) > at > kafka.api.TopicMetadataResponse$$anonfun$1.apply(TopicMetadataResponse.scala:28) > at > kafka.api.TopicMetadataResponse$$anonfun$1.apply(TopicMetadataResponse.scala:28) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at scala.collection.immutable.Range.foreach(Range.scala:166) > at scala.collection.TraversableLike$class.map(TraversableLike.scala:245) > at scala.collection.AbstractTraversable.map(Traversable.scala:104) > at > kafka.api.TopicMetadataResponse$.readFrom(TopicMetadataResponse.scala:28) > at kafka.producer.SyncProducer.send(SyncProducer.scala:120) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:94) > at kafka.tools.GetOffsetShell$.main(GetOffsetShell.scala:78) > at kafka.tools.GetOffsetShell.main(GetOffsetShell.scala) -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka
[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15186615#comment-15186615 ] Ashish K Singh commented on KAFKA-3355: --- [~xiaotao183] you are correct and this problem persists in following tools. * ReplicationVerificationTool * SimpleConsumerShell * GetOffsetShell As we are deprecating old producer, we should really move these tools over to use new producer. [~gwenshap] do you think this could be something worth considering for 0.10? > GetOffsetShell command doesn't work with SASL enabled Kafka > --- > > Key: KAFKA-3355 > URL: https://issues.apache.org/jira/browse/KAFKA-3355 > Project: Kafka > Issue Type: Bug > Components: tools >Affects Versions: 0.9.0.1 > Environment: Kafka 0.9.0.1 >Reporter: TAO XIAO > > I found that GetOffsetShell doesn't work with SASL enabled Kafka. I believe > this is due to old producer being used in GetOffsetShell. > Kafka version 0.9.0.1 > Exception > % bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list > localhost:9092 --topic test --time -1 > [2016-03-04 21:43:56,597] INFO Verifying properties > (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property client.id is overridden to > GetOffsetShell (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property metadata.broker.list is overridden to > localhost:9092 (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,613] INFO Property request.timeout.ms is overridden to > 1000 (kafka.utils.VerifiableProperties) > [2016-03-04 21:43:56,674] INFO Fetching metadata from broker > BrokerEndPoint(0,localhost,9092) with correlation id 0 for 1 topic(s) > Set(test) (kafka.client.ClientUtils$) > [2016-03-04 21:43:56,689] INFO Connected to localhost:9092 for producing > (kafka.producer.SyncProducer) > [2016-03-04 21:43:56,705] WARN Fetching topic metadata with correlation id 0 > for topics [Set(test)] from broker [BrokerEndPoint(0,localhost,9092)] failed > (kafka.client.ClientUtils$) > java.nio.BufferUnderflowException > at java.nio.Buffer.nextGetIndex(Buffer.java:498) > at java.nio.HeapByteBuffer.getShort(HeapByteBuffer.java:304) > at kafka.api.ApiUtils$.readShortString(ApiUtils.scala:36) > at kafka.cluster.BrokerEndPoint$.readFrom(BrokerEndPoint.scala:52) > at > kafka.api.TopicMetadataResponse$$anonfun$1.apply(TopicMetadataResponse.scala:28) > at > kafka.api.TopicMetadataResponse$$anonfun$1.apply(TopicMetadataResponse.scala:28) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at scala.collection.immutable.Range.foreach(Range.scala:166) > at scala.collection.TraversableLike$class.map(TraversableLike.scala:245) > at scala.collection.AbstractTraversable.map(Traversable.scala:104) > at > kafka.api.TopicMetadataResponse$.readFrom(TopicMetadataResponse.scala:28) > at kafka.producer.SyncProducer.send(SyncProducer.scala:120) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:94) > at kafka.tools.GetOffsetShell$.main(GetOffsetShell.scala:78) > at kafka.tools.GetOffsetShell.main(GetOffsetShell.scala) -- This message was sent by Atlassian JIRA (v6.3.4#6332)
