[jira] [Created] (KAFKA-7373) GetOffsetShell doesn't work when SSL authentication is enabled

["Andy Bryant (JIRA)" <ji...@apache.org>]

Andy Bryant created KAFKA-7373:
----------------------------------

             Summary: 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


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)