EMQXでIoTデータをKafkaにストリーミング

最小限のコーディングと設定でMQTTとKafkaのシームレスな統合を実現。複雑なプロセスとはお別れし、データの取り込みを効率化。

EMQXを使ってMQTTとKafkaを使う理由

MQTTは、IoT（モノのインターネット）のための事実上の標準メッセージングプロトコルで、軽量で効率的な設計で知られています。信頼性の低いネットワークでも、数百万台のIoTデバイスを接続し、スケーラビリティと信頼性を保証するのに最適です。

Apache Kafkaは、企業システム間でデータを接続・交換するデータストリーミングプラットフォームです。しかし、KafkaはIoT向けに設計されておらず、安定したネットワークを必要とし、より多くのリソースを消費し、数千のクライアントとトピックのみをサポートします。

EMQXは、内蔵されたKafka統合を備えた高スケーラブルなMQTTメッセージングブローカーです。EMQXはMQTTとKafkaを完璧にマッチさせ、数百万台のIoTデバイスを企業システムに接続し、IoTデータからビジネス価値を引き出します。

EMQXの箱出しの統合は、MQTTメッセージをKafkaのデータフローに効率的にストリーミングします。EMQXの内蔵されたSQLベースのルールエンジンを活用することで、MQTTメッセージを簡単にフィルタリング、抽出、エンリッチ、変換し、Kafkaへの取り込みをシームレスかつ柔軟に行えます。

内蔵データブリッジとルールエンジンを使用して、EMQXはKafkaからメッセージバッチを消費したり、Kafkaに対してメッセージバッチを生成したりできます。

非同期およびバッチ処理メカニズムにより、EMQXは1秒間に最大100万のMQTTメッセージをKafkaに書き込むことができます。

EMQXは、Kafkaのパーティション拡大を自動的に検出し、再設定や再起動を行うことなく容易にビジネスの成長に合わせてスケールアップできます。

内蔵のフローデザイナーを使用することで、IoTデータを抽出、フィルタリング、エンリッチ、変換し、特定のKafkaトピックにコードを書かずに書き込むことができます。

数クリックで、EMQXのルールエンジンとフローデザイナーを使用して、IoTデータをフィルタリング、抽出、変換し、Kafkaに取り込むことができます。