proxy cluster how to enable acl ?

[VictoryAnn]

proxy配置如下，proxy的plain_acl.yml为空，会报下面的PERMISSION_DENIED。
但是我把broker的plain_acl.yml拷贝到proxy的conf下面，就会报错Failed to fetch topic route。
有没有大佬用过proxy的acl的？

# rmq-proxy.json
{
	"rocketMQClusterName": "local-cluster",
	"proxyMode": "CLUSTER",
	"grpcServerPort": 1234,
	"remotingListenPort": 2345,
	"enableACL": true
}

# 客户端报错
org.apache.rocketmq.shaded.io.grpc.StatusRuntimeException: PERMISSION_DENIED
        at org.apache.rocketmq.shaded.io.grpc.Status.asRuntimeException(Status.java:539)
        at org.apache.rocketmq.shaded.io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:544)
        at org.apache.rocketmq.shaded.io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
        at org.apache.rocketmq.shaded.io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
        at org.apache.rocketmq.shaded.io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
        at org.apache.rocketmq.shaded.io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:563)
        at org.apache.rocketmq.shaded.io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:70)
        at org.apache.rocketmq.shaded.io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:744)
        at org.apache.rocketmq.shaded.io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:723)
        at org.apache.rocketmq.shaded.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
        at org.apache.rocketmq.shaded.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)

# 客户端报错
2024-12-17 20:44:47.898 ERROR [15381] [RocketmqClientAsyncWorker-0-11] [o.a.r.c.j.i.ClientImpl#?:?] - Failed to fetch topic route, clientId=SIH-D-1897.local@15381@0@48tjcrnmrx, topic=astest
java.lang.IllegalArgumentException: Message type is not specified
        at org.apache.rocketmq.client.java.message.MessageType.fromProtobuf(MessageType.java:38)
        at org.apache.rocketmq.client.java.route.MessageQueueImpl.<init>(MessageQueueImpl.java:43)
        at org.apache.rocketmq.client.java.route.TopicRouteData.<init>(TopicRouteData.java:48)
        at org.apache.rocketmq.client.java.impl.ClientImpl.lambda$fetchTopicRoute0$6(ClientImpl.java:623)
        at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractTransformFuture$AsyncTransformFuture.doTransform(AbstractTransformFuture.java:221)
        at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractTransformFuture$AsyncTransformFuture.doTransform(AbstractTransformFuture.java:208)
        at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractTransformFuture.run(AbstractTransformFuture.java:122)
        at org.apache.rocketmq.shaded.com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31)
        at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1270)
        at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:1038)
        at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractFuture.set(AbstractFuture.java:783)
        at org.apache.rocketmq.shaded.io.grpc.stub.ClientCalls$GrpcFuture.set(ClientCalls.java:569)
        at org.apache.rocketmq.shaded.io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:542)
        at org.apache.rocketmq.shaded.io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)

[VictoryAnn]

Message type is not specified 是因为proxy cluster这边acl报错导致的

[VictoryAnn]

proxy加上plain_acl配置就可以成功发送消息，这样就需要维护和broker的plain_acl配置保持一致。