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)
