0

我正在尝试在启用 kerberos 的集群上运行 Mirrormaker，该集群源自非现场非 kerberos 集群，并且在启动镜像制造商时出现以下错误。

我的所有关键选项卡都经过验证且有效，我的 server.properties/producer.properties/consumer.properties 设置正确，并且 KDC 也可以访问。防火墙端口配置正确。有没有人遇到过这种类型的错误？

Found unsupported keytype (3) for mirrormaker/myhost.org@KAFKA.SECURE
Found unsupported keytype (8) for mirrormaker/myhost.org@KAFKA.SECURE
Found unsupported keytype (25) for mirrormaker/myhost.org@KAFKA.SECURE
Found unsupported keytype (26) for mirrormaker/myhost.org@KAFKA.SECURE
Added key: 23version: 2
Added key: 16version: 2
Added key: 17version: 2
Added key: 18version: 2
>>> EType: sun.security.krb5.internal.crypto.Aes256CtsHmacSha1EType
>>> KrbAsRep cons in KrbAsReq.getReply mirrormaker/myhost.org
[2019-08-20 10:51:00,351] ERROR [mirrormaker-thread-2] Mirror maker thread failure due to  (kafka.tools.MirrorMaker$MirrorMakerThread)
java.lang.OutOfMemoryError: Java heap space
    at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57)
    at java.nio.ByteBuffer.allocate(ByteBuffer.java:335)
    at org.apache.kafka.common.memory.MemoryPool$1.tryAllocate(MemoryPool.java:30)
    at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:140)
    at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:93)
    at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:244)
    at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:205)
    at org.apache.kafka.common.network.Selector.attemptRead(Selector.java:561)
    at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:497)

这是我们第一次在启用 kerberos 的集群上使用 mirrormaker，所以我们不知道我们应该得到什么样的输出，或者如何解决这个问题。Mirrormaker 在配置方面似乎非常善变。

任何帮助将不胜感激。

4

0 回答 0