Как мы можем использовать протокол mqtt с kafka в качестве посредника сообщений?

Клиенты (java-приложения android / ios / desktop и т. Д.) Будут создавать и потреблять сообщения, используя клиентские библиотеки mqtt phao, которые доступны на разных языках, с использованием kafka в качестве брокера сообщений.

Любой совет?