Topic not present in metadata after 60000 ms

HiveMQ Extensions
1

Hi, I’m using HiveMQ 4.8.4 and Kafka broker 3.2.1 (Confluent Platform 7.2.1, using local docker images). After enabling the Kafka Extension and providing a basic MQTT-to-kafka configuration I got a repeated error:

Message with mqtt topic 'plant1/cell1/cell1.device02/out/stream' for mqtt-to-kafka-mapping 'mapping01' can not be sent to kafka. Retrying, attempt '1'. Reason: Topic site1_03-tool-telemetry not present in metadata after 60000 ms.

My current Kafka target topic exists and works well with other clients and I’m able to successfully publish to it using other tools.

After investigating I found that sometimes the Kafka client libraries for the internal produces could mismatch the broker version used, but I don’t know if this is the case with the HiveMQ extension.

Could you please help to figure out what’s going on? Thanks in advance.

Here is the config I’m using for the Kafka Extension.

<?xml version="1.0" encoding="UTF-8" ?>
<kafka-configuration xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
                     xsi:noNamespaceSchemaLocation="kafka-extension.xsd">

    <kafka-clusters>
        <kafka-cluster>
            <id>cluster01</id>
            <bootstrap-servers>localhost:9092</bootstrap-servers>
        </kafka-cluster>
    </kafka-clusters>

    <mqtt-to-kafka-mappings>
        <mqtt-to-kafka-mapping>
            <id>mapping01</id>
            <cluster-id>cluster01</cluster-id>
            <mqtt-topic-filters>
                <mqtt-topic-filter>plant1/#</mqtt-topic-filter>
            </mqtt-topic-filters>
            <kafka-topic>site1_03-tool-telemetry</kafka-topic>
        </mqtt-to-kafka-mapping>
    </mqtt-to-kafka-mappings>

</kafka-configuration>