Достижение аварийного переключения через MQTT Kafka Bridge
Я использовал МОСТ MQTT-KAFKA в java, и у меня есть сценарий для преодоления потери данных в MQTT и Kafka в случае сбоя клиента MQTT или моста MQTT-KAFKA в производственной среде, необходимо обеспечить аварийное переключение.
Я протестировал сценарий, в котором я остановил клиент MQTT и смог восстановить данные в клиенте MQTT только из последнего datetime полезной нагрузки, которые я потерял, когда клиент MQTT был отключен / остановлен, и теперь, когда я соединяюсь с MQTT и Kafka Producer, не получает или восстановить потерю данных во время остановки моста MQTT-KAFKA, т. е. Kafka Producer не создает его, данные запущены до самых последних записей вместо создания потерянных данных.
Конфигурации Kafka Producer по умолчанию: https://kafka.apache.org/11/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html.
Я использовал ниже зависимости от maven
пружинная интеграция-mqtt
весна-интеграция-кафка
Для MQTT CleanSession установлено значение false
Конфигурации производителя Kafka при запуске
Может ли кто-нибудь подсказать, как этого добиться? Благодарность!
