Yufei Cai

[MQTT5] Negative manual acknowlegement via Publish.acknowledge

9

Hi, is there any way to perform "negative acknowledgement" for incoming MQTT5 PUBLISH messages as a client subscriber? I want to send PUBACK with reason code 0x80, 0x83, 0x87, 0x90...

A throughput bottleneck is the deserialization of signals published over Ditto PubSub. The reason is that all published signals to 1 cluster member were sent to a single instance-level subscriber,...

When modifying e. g. a feature property via HTTP, the header "put-metadata" has no effect and does not modify the thing's metadata.

To reproduce: - Create a feature property or attribute. - Put metadata for the feature property or attribute. - Delete the feature property or attribute. Expected behavior: - Metadata of...

Reproducer: ```java ConfigFactory.empty() .withFallback( ConfigWithFallback.newInstance( ConfigFactory.empty(), "x", new KnownConfigValue[0])); ``` Expected behavior: An empty config object. Actual behavior: ClassCastException thrown. ``` java.lang.ClassCastException: org.eclipse.ditto.services.utils.config.ConfigWithFallback cannot be cast to com.typesafe.config.impl.MergeableValue at com.typesafe.config.impl.AbstractConfigValue.withFallback(AbstractConfigValue.java:274)...

Default unit of 'timeout' changed from ms to s. Some examples have invalid timeout values like '10000'.

Ditto java client 1.1.2 allocates and shuts down its own thread pools, which lead to performance problems when many instances of the java client run in the same JVM. It...

I think we should set users on the right path of asynchronous programming by not calling Thread.sleep in the client usage examples.