MQTT Example: Read from an MQTT topic, group messages and publish to Kafka This example is available in the Alpakka Samples project.