apache-kafka - kafka-run-class 抛出 java.lang.OutOfMemoryError 错误

Question

我在 Linux 上运行 kafka_2.12-2.2.0。当我运行此命令时，它会给出 OOM 错误。如果我增加内存选项，它会超时：

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list broker1:9092,broker2:9092,broker3:9092 --topic test（给OOM喜欢Exception in thread "main" java.lang.OutOfMemoryError: Java heap space）

如果我先这样做，export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"那么我会超时Exception in thread "main" org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata

我的 kafka 服务器属性使用 SSL，我读到 SSL 有时会出现问题。我注意到没有像--command-config其他命令那样的参数，所以我不知道这个命令将如何进行身份验证。

如何成功运行此命令？

标签： apache-kafka