[
https://issues.apache.org/jira/browse/KAFKA-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16605911#comment-16605911
]
ASF GitHub Bot commented on KAFKA-7373:
---------------------------------------
stanislavkozlovski opened a new pull request #5617: KAFKA-7373: Allow
GetOffsetShell command to accept a configurations file
URL: https://github.com/apache/kafka/pull/5617
GetOffsetShell doesn't provide a mechanism to provide additional
configuration for the underlying KafkaConsumer as does the `ConsoleConsumer`.
This leaves it unable to connect to a broker using SSL.
This PR allows it to accept a client configuration file, subsequently
allowing it to provide SSL configurations and connect to a broker.
I tested this manually. Trying to connect to a broker's SSL listener raised
an out of memory error for me. After passing in the appropriate configurations
via a config file, it connected successfully
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> 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
> Assignee: Stanislav Kozlovski
> 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)
