{"id":1041,"date":"2021-03-12T14:50:30","date_gmt":"2021-03-12T14:50:30","guid":{"rendered":"http:\/\/www.igfasouza.com\/blog\/?p=1041"},"modified":"2021-04-19T20:55:07","modified_gmt":"2021-04-19T19:55:07","slug":"energy-switch-and-smart-home-with-kafka","status":"publish","type":"post","link":"http:\/\/www.igfasouza.com\/blog\/energy-switch-and-smart-home-with-kafka\/","title":{"rendered":"Energy switch and smart home with Kafka"},"content":{"rendered":"

\"\"<\/p>\n

How the hell are you?<\/b>
\n2021\/03\/12<\/small><\/p>\n

Smart devices are all of the everyday objects made intelligent with advanced computers, including AI and machine learning, and networked to form the internet of things (IoT).
\nNot just computers and smartphones, but everything: clocks, speakers, lights, doorbells, cameras, windows, window blinds, hot water heaters, appliances, cooking utensils, you name it. And what if those devices could all communicate, send you information, and take your commands? And what if I could use Kafka to get this device’s real-time information?<\/p>\n

\"\"<\/p>\n

Today I want to show a Raspberry PI Java Spring web app to simulate a Lamp switch using the TP-link smart bulb and smart plug. Once the device is on its start to collect the real-time energy consumption info and send to a Kafka topic.<\/p>\n

I already did a blog about TP-link smart plush<\/a>, but today I want to use a Java API that I found here<\/a> and here<\/a>. I kind of did a mix of both.<\/p>\n

I\u2019m using a smart plug HS110 and smart bulb LB110<\/p>\n

code<\/h2>\n
1
2
3
4
5
<\/div><\/td>
@RequestMapping(<\/span>
\nvalue =<\/span> "\/process"<\/span>,
\nmethod =<\/span> RequestMethod.POST<\/span>,
\nconsumes =<\/span> "text\/plain"<\/span>)<\/span>
\npublic<\/span> void<\/span> process(<\/span>@RequestBody String<\/span><\/a> payload)<\/span> throws<\/span> Exception<\/span><\/a> {<\/span><\/div><\/td><\/tr><\/tbody><\/table><\/div>\n
1
2
3
4
5
6
7
8
<\/div><\/td>
        System<\/span><\/a>.out<\/span>.println<\/span>(<\/span>payload)<\/span>;<\/span>
\n
\nif<\/span>(<\/span>payload.equals<\/span>(<\/span>"true"<\/span>)<\/span>)<\/span>{<\/span>
\nplug.switchOn<\/span>(<\/span>)<\/span>;<\/span>
\nthis<\/span>.producer<\/span>.sendMessage<\/span>(<\/span>plug.getEnergy<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n}<\/span>else<\/span> {<\/span>
\nplug.switchOff<\/span>(<\/span>)<\/span>;<\/span>
\n}<\/span><\/div><\/td><\/tr><\/tbody><\/table><\/div>\n
1
<\/div><\/td>
    }<\/span><\/div><\/td><\/tr><\/tbody><\/table><\/div>\n

For configure kafka just need add the settings on \u201capplication.yml\u201d. Here I did with my raspberry pi kafka cluster<\/a>.<\/p>\n

\"\"<\/p>\n

Disclaimer \u2013 I got the CSS from here<\/a><\/p>\n

You can get the full code on my GitHub<\/a>.<\/p>\n

And you can combine this with my influxdb-and-grafana<\/a> blog and add some nice visualization.<\/p>\n

Smart Plug HS110
\n