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)