kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Pablo Panero (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka
Date Wed, 11 Oct 2017 10:09:00 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200057#comment-16200057
] 

Pablo Panero edited comment on KAFKA-3355 at 10/11/17 10:08 AM:
----------------------------------------------------------------

Hello I tested with 0.10.2.1 and is not working. Are there any intentions on merging the proposed
PR. If not I am willing on working on it. I would just need access to the CI servers to check
why is it failing in two of the options.

It would be really helpful for me

PR: https://github.com/apache/kafka/pull/2891

[~Sagar Lad] [~fredji] [~magarmes] [~ashishujjain]


was (Author: ppanero):
Hello I tested with 0.10.2.1 and is not working. Are there any intentions on merging the proposed
PR. If not I am willing on working on it. I would just need access to the CI servers to check
why is it failing in two of the options.

PR: https://github.com/apache/kafka/pull/2891

[~Sagar Lad] [~fredji] [~magarmes]

> 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.4.14#64029)

Mime
View raw message