Versions Compared

Old Version 1

changes.mady.by.user Daria Samkova

Saved on

compared with

New Version 2

changes.mady.by.user Daria Samkova

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Info

If a Pub/Sub consumer frequently experiences this kind of dropped message: “The QoS 0 memory limit exceeded“, it can indicate that the Pub/Sub is consuming messages too slowly or has unstable network connections.

\uD83C\uDF31Bridge uDF31 Bridge Extension

  1. Look at the configuration XML of Bridge Extension.

    Code Block
    languagexml
    <bridges>
    <bridge>
        <enabled>true</enabled>
        <name>my-bridge-1</name>
        ...
    </bridge>
    <bridge>
        <enabled>true</enabled>
        <name>my-bridge-2</name>
        ...
    </bridge>
</bridges>

  2. Consumer Id will be the Bridge name.

\uD83C\uDF31Amazon uDF31 Amazon Kinesis Extension

Amazon Kinesis Extension is using the same approach as Google Pub/Sub Extension:

...

  1. Look at the extension configuration:

    Code Block
    languagexml
    <mqtt-to-kinesis-routes>
  <mqtt-to-kinesis-route>
      <id>my-mqtt-to-kinesis-route</id>
      <enabled>true</enabled>
      <aws-credential-profile-id>aws-credential-profile-01</aws-credential-profile-id>
      <region>eu-central-1</region>
      <mqtt-topic-filters>
          <mqtt-topic-filter>mqtt/topic/a</mqtt-topic-filter>
      </mqtt-topic-filters>
      ...

  2. ConsumerId will be base32 encoded lowercase string my-mqtt-to-kinesis-route|mqtt/topic/a → nv4s23lror2c25dpfvvws3tfonuxgllsn52xizl4nvyxi5bporxxa2ldf5qq====.

Kafka Extension

In the Kafka Extension, a Consumer Id consists of kafka-extension_ prefix concatenated to a mapping id:

Code Block
languagejava
String CONSUMER_PREFIX = "kafka-extension_";
...
final String consumerId = CONSUMER_PREFIX + mqttToKafkaMapping.getId();

Look at the kafka-cofiguration.xml:

Code Block
languagexml
    <mqtt-to-kafka-mappings>
        <mqtt-to-kafka-mapping>
            <id>mapping01</id>
            <cluster-id>cluster01</cluster-id>
            <mqtt-topic-filters>
                <mqtt-topic-filter>#</mqtt-topic-filter>
            </mqtt-topic-filters>
            <kafka-topic>kafka-topic</kafka-topic>
        </mqtt-to-kafka-mapping>
    </mqtt-to-kafka-mappings>

The Consumer id will look like kafka-extension_mapping01.

...