GitHub user VictoryAnn edited a discussion: proxy cluster how to enable acl ?
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)
```
GitHub link: https://github.com/apache/rocketmq/discussions/9061
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
