diff --git a/apps/iot/src/iot.app.src b/apps/iot/src/iot.app.src
index a4c9956..ee6e2fe 100644
--- a/apps/iot/src/iot.app.src
+++ b/apps/iot/src/iot.app.src
@@ -12,11 +12,12 @@
     cowboy,
     lager,
     jiffy,
+    brod,
     parse_trans,
     hackney,
     poolboy,
     mysql,
-    gpb,
+    % gpb,
     esockd,
     mnesia,
     crypto,
diff --git a/apps/iot/src/iot_sup.erl b/apps/iot/src/iot_sup.erl
index 5e60842..02a5395 100644
--- a/apps/iot/src/iot_sup.erl
+++ b/apps/iot/src/iot_sup.erl
@@ -38,12 +38,12 @@ init([]) ->
         },
 
         #{
-            id => 'iot_endpoint_sup',
-            start => {'iot_endpoint_sup', start_link, []},
+            id => 'endpoint_sup',
+            start => {'endpoint_sup', start_link, []},
             restart => permanent,
             shutdown => 2000,
             type => supervisor,
-            modules => ['iot_endpoint_sup']
+            modules => ['endpoint_sup']
         },
 
         #{
diff --git a/rebar.config b/rebar.config
index 31e3fe9..3a83267 100644
--- a/rebar.config
+++ b/rebar.config
@@ -5,6 +5,7 @@
     {sync, ".*", {git, "https://github.com/rustyio/sync.git", {branch, "master"}}},
     {cowboy, ".*", {git, "https://github.com/ninenines/cowboy.git", {tag, "2.10.0"}}},
     {esockd, ".*", {git, "https://github.com/emqx/esockd.git", {tag, "v5.7.3"}}},
+    {brod, ".*", {git, "https://github.com/kafka4beam/brod.git", {tag, "4.4.5"}}},
     {jiffy, ".*", {git, "https://github.com/davisp/jiffy.git", {tag, "1.1.1"}}},
     {mysql, ".*", {git, "https://github.com/mysql-otp/mysql-otp", {tag, "1.8.0"}}},
     {eredis, ".*", {git, "https://github.com/wooga/eredis.git", {tag, "v1.2.0"}}},
diff --git a/rebar.lock b/rebar.lock
index b604e34..faf5f44 100644
--- a/rebar.lock
+++ b/rebar.lock
@@ -1,5 +1,9 @@
 {"1.2.0",
-[{<<"certifi">>,{pkg,<<"certifi">>,<<"2.5.2">>},1},
+[{<<"brod">>,
+  {git,"https://github.com/kafka4beam/brod.git",
+       {ref,"877852a175f6051b604ea7986bdb8da04ce19e76"}},
+  0},
+ {<<"certifi">>,{pkg,<<"certifi">>,<<"2.5.2">>},1},
  {<<"cowboy">>,
   {git,"https://github.com/ninenines/cowboy.git",
        {ref,"9e600f6c1df3c440bc196b66ebbc005d70107217"}},
@@ -8,6 +12,7 @@
   {git,"https://github.com/ninenines/cowlib",
        {ref,"cc04201c1d0e1d5603cd1cde037ab729b192634c"}},
   1},
+ {<<"crc32cer">>,{pkg,<<"crc32cer">>,<<"1.0.3">>},2},
  {<<"emqtt">>,
   {git,"https://gitea.s5s8.com/anlicheng/emqtt.git",
        {ref,"5111914a9b1b92b0b497f825c77bdd365e3989b0"}},
@@ -35,6 +40,7 @@
   {git,"https://github.com/davisp/jiffy.git",
        {ref,"9ea1b35b6e60ba21dfd4adbd18e7916a831fd7d4"}},
   0},
+ {<<"kafka_protocol">>,{pkg,<<"kafka_protocol">>,<<"4.2.7">>},1},
  {<<"lager">>,
   {git,"https://github.com/erlang-lager/lager.git",
        {ref,"459a3b2cdd9eadd29e5a7ce5c43932f5ccd6eb88"}},
@@ -66,18 +72,22 @@
 [
 {pkg_hash,[
  {<<"certifi">>, <<"B7CFEAE9D2ED395695DD8201C57A2D019C0C43ECAF8B8BCB9320B40D6662F340">>},
+ {<<"crc32cer">>, <<"AD0E42BED8603F2C72DE2A00F1B5063FFE12D5988615CAD984096900431D1C1A">>},
  {<<"fs">>, <<"9D147B944D60CFA48A349F12D06C8EE71128F610C90870BDF9A6773206452ED0">>},
  {<<"goldrush">>, <<"F06E5D5F1277DA5C413E84D5A2924174182FB108DABB39D5EC548B27424CD106">>},
  {<<"idna">>, <<"1D038FB2E7668CE41FBF681D2C45902E52B3CB9E9C77B55334353B222C2EE50C">>},
+ {<<"kafka_protocol">>, <<"6F53B15CD6F6A12C1D0010DB074B4A15985C71BC7F594BC2D67D9837B3B378A1">>},
  {<<"metrics">>, <<"25F094DEA2CDA98213CECC3AEFF09E940299D950904393B2A29D191C346A8486">>},
  {<<"mimerl">>, <<"67E2D3F571088D5CFD3E550C383094B47159F3EEE8FFA08E64106CDF5E981BE3">>},
  {<<"ssl_verify_fun">>, <<"CF344F5692C82D2CD7554F5EC8FD961548D4FD09E7D22F5B62482E5AEAEBD4B0">>},
  {<<"unicode_util_compat">>, <<"8516502659002CEC19E244EBD90D312183064BE95025A319A6C7E89F4BCCD65B">>}]},
 {pkg_hash_ext,[
  {<<"certifi">>, <<"3B3B5F36493004AC3455966991EAF6E768CE9884693D9968055AEEEB1E575040">>},
+ {<<"crc32cer">>, <<"08FDCD5CE51ACD839A12E98742F0F0EDA19A2A679FC9FBFAF6AAB958310FB70E">>},
  {<<"fs">>, <<"EF94E95FFE79916860649FED80AC62B04C322B0BB70F5128144C026B4D171F8B">>},
  {<<"goldrush">>, <<"99CB4128CFFCB3227581E5D4D803D5413FA643F4EB96523F77D9E6937D994CEB">>},
  {<<"idna">>, <<"A02C8A1C4FD601215BB0B0324C8A6986749F807CE35F25449EC9E69758708122">>},
+ {<<"kafka_protocol">>, <<"1D5E9597AD3C0776C86DC5E08D3BAAEA7DB805A52E5FD35E3F071AAD7789FC4C">>},
  {<<"metrics">>, <<"69B09ADDDC4F74A40716AE54D140F93BEB0FB8978D8636EADED0C31B6F099F16">>},
  {<<"mimerl">>, <<"F278585650AA581986264638EBF698F8BB19DF297F66AD91B18910DFC6E19323">>},
  {<<"ssl_verify_fun">>, <<"BDB0D2471F453C88FF3908E7686F86F9BE327D065CC1EC16FA4540197EA04680">>},