[ https://issues.apache.org/jira/browse/KAFKA-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16605937#comment-16605937 ]
Stanislav Kozlovski commented on KAFKA-7373: -------------------------------------------- Hi [~kiwiandy], There is KIP-308 for GetOffsetShell which suggests the addition of a `--consumer-property` field: https://cwiki.apache.org/confluence/display/KAFKA/KIP-308%3A+GetOffsetShell%3A+new+KafkaConsumer+API%2C+support+for+multiple+topics%2C+minimize+the+number+of+requests+to+server > GetOffsetShell doesn't work when SSL authentication is enabled > -------------------------------------------------------------- > > Key: KAFKA-7373 > URL: https://issues.apache.org/jira/browse/KAFKA-7373 > Project: Kafka > Issue Type: Bug > Affects Versions: 2.0.0 > Reporter: Andy Bryant > Priority: Major > > GetOffsetShell doesn't provide a mechanism to provide additional > configuration for the underlying KafkaConsumer as does the `ConsoleConsumer`. > Passing SSL config as system properties doesn't propagate to the consumer > either. > {code:java} > 10:47 $ ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list > ${BROKER_LIST} --topic cld-dev-sor-crods-crodsdba_contact > Exception in thread "main" org.apache.kafka.common.errors.TimeoutException: > Timeout expired while fetching topic metadata{code} > Editing {{GetOffsetShell.scala}} to include the SSL properties in the > KafkaConsumer configuration resolved the issue. > Providing {{consumer-property}} and {{consumer-config}} configuration options > for {{kafka-run-class-sh}} or creating a separate run script for offsets and > using these properties in {{GetOffsetShell.scala}} seems like a good solution. -- This message was sent by Atlassian JIRA (v7.6.3#76005)