mop

mop copied to clipboard

Add management API

1

Technoboy-

[DISCUSS] MIP-7 Support MoP proxy to pulsar proxy

6

# Support MoP proxy to pulsar-proxy ## Motivation Apache pulsar needs to use the lookup mechanism to find which broker the topic is on, but the MQTT protocol specification does...

mattisonchao

**Describe the bug** topic grant-permission operation caused all devices subcribed topics in the same namespace lost connection. for example: test-user-a is connected and subscribes persistent://test-tenant/ns/test-topic-a test-user-b is connected and subscribes...

letsopen

Bump mop version to 3.1.0-SNAPSHOT

2

This is a PR created by snbot to trigger the check suite in each repository.

streamnativebot

integration tests reproducing MoP proxy issue

1

Master Issue: #1212 ### Motivation In the issue regarding this issue I was asked to reproduce the issue with an integration tests. This PR provides an integration test which reproduces...

tsturzl

fix a ClassCastException when scheduling to look up

1

### Motivation `new ExecutorProvider(proxyConfig.getLookupThreadPoolNum(), "mop-lookup-thread") ;` It will create a FinalizableDelegatedExecutorService `(ScheduledExecutorService) executorProvider.getExecutor();` It can't be cast to a ScheduledExecutorService, and it will create a RuntimeException without catch, which is...

Yimiun

MoP Proxy, keep alive is not managed correctly causes connection to fail

13

**Describe the bug** MQTT keep alive is initiated by the client, however per the MQTT spec keep alive only sends a PINGREQ control message if the keep alive time has...

tsturzl

MoP Proxy seems redundant, introduces unnecessary complexity

5

**Is your enhancement request related to a problem? Please describe.** In several attempts to get the MoP proxy to work properly we run across constant stability problems, and bugs related...

tsturzl

MQTT QOS support level?

1

## Motivation which version support mqtt v3/v5 QOS 1 2 and 3 ？ what is the plan /roadmap ? thanks!

snowfly568790005

Please redo the lookup. Request is denied: namespace=public/default

2

2023-01-06T16:32:02,241+0800 [pulsar-ph-mqtt-48-1] ERROR io.streamnative.pulsar.handlers.mqtt.support.MQTTBrokerProtocolMethodProcessor - [Publish] [persistent://public/default/test-13-1] Write MqttPublishMessage[fixedHeader=MqttFixedHeader[messageType=PUBLISH, isDup=false, qosLevel=AT_MOST_ONCE, isRetain=false, remainingLength=475], variableHeader=MqttPublishVariableHeader[topicName=persistent://public/default/test-13-1, packetId=-1], payload=PooledSlicedByteBuf(ridx: 0, widx: 436, cap: 436/436, unwrapped: PooledUnsafeDirectByteBuf(ridx: 24814, widx: 131448, cap: 262144))] to Pulsar...

BaoHuaWang