Design and Implementation of Internet of Things Message Subscription System Based on Kafka

In today's Internet of Things applications, a large number of terminal devices upload data. According to the business requirement of the server and the client, the remote server faces great challenges in data collection and data distribution. In view of the above requirements, this paper adopts Kafka middleware with fast processing speed, distributed multi-partition and high throughput to realize asynchronous communication between services, and realizes data collection and data classification through Netty framework and custom communication protocol. Implemented a high-concurrency, low-latency Message subscription system based on the Internet of Things. The experimental results show that the system meets the performance requirements of tens of thousands of data distribution.