Skip to content

Commit 34e4d60

Browse files
oneby-wangoneby-wang
authored andcommitted
Fix mqtt disconnect due to appId permission bug when namespace policies update (#1813)
Co-authored-by: oneby-wang <[email protected]>
1 parent 89c72f0 commit 34e4d60

File tree

1 file changed

+1
-1
lines changed
  • mqtt-broker/src/main/java/io/streamnative/pulsar/handlers/mqtt/broker/impl/consumer

1 file changed

+1
-1
lines changed

mqtt-broker/src/main/java/io/streamnative/pulsar/handlers/mqtt/broker/impl/consumer/MQTTConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ public MQTTConsumer(Subscription subscription, String mqttTopicName, String puls
7272
MQTTServerCnx cnx, MqttQoS qos, PacketIdGenerator packetIdGenerator,
7373
OutstandingPacketContainer outstandingPacketContainer, MQTTMetricsCollector metricsCollector) {
7474
super(subscription, CommandSubscribe.SubType.Shared, pulsarTopicName, 0, 0,
75-
connection.getClientId(), true, cnx, "", null, false,
75+
connection.getClientId(), true, cnx, connection.getUserRole(), null, false,
7676
null, MessageId.latest, Commands.DEFAULT_CONSUMER_EPOCH);
7777
this.pulsarTopicName = pulsarTopicName;
7878
this.mqttTopicName = mqttTopicName;

0 commit comments

Comments
 (0)