diff --git a/mix.exs b/mix.exs
index 7bb1676..9e0628e 100644
--- a/mix.exs
+++ b/mix.exs
@@ -21,7 +21,7 @@ defmodule ExAwsMskIamAuth.MixProject do
   # Run "mix help deps" to learn about dependencies.
   defp deps do
     [
-      {:broadway_kafka, "~> 0.3.5"},
+      {:broadway_kafka, "~> 0.3"},
       {:aws_signature, "~> 0.3.0"},
       {:jason, "~> 1.3"},
       {:hammox, "~> 0.5", only: :test}
diff --git a/mix.lock b/mix.lock
index 09b9c9a..7cd649e 100644
--- a/mix.lock
+++ b/mix.lock
@@ -1,7 +1,7 @@
 %{
   "aws_signature": {:hex, :aws_signature, "0.3.1", "67f369094cbd55ffa2bbd8cc713ede14b195fcfb45c86665cd7c5ad010276148", [:rebar3], [], "hexpm", "50fc4dc1d1f7c2d0a8c63f455b3c66ecd74c1cf4c915c768a636f9227704a674"},
   "broadway": {:hex, :broadway, "1.0.3", "04014322955d46c97d0608dbac2a76522d8a558245422fb6b3a6157ff7a0e36c", [:mix], [{:gen_stage, "~> 1.0", [hex: :gen_stage, repo: "hexpm", optional: false]}, {:nimble_options, "~> 0.3.7 or ~> 0.4.0", [hex: :nimble_options, repo: "hexpm", optional: false]}, {:telemetry, "~> 0.4.3 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "02562445a5af75288648a1cf7fe4ac8cb42acb3626a2339332f57951589fdd7b"},
-  "broadway_kafka": {:hex, :broadway_kafka, "0.3.6", "4e5e67c8224af48f448a1a1db897f02b347746cc8a4481dde6659eca82ac9d88", [:mix], [{:broadway, "~> 1.0", [hex: :broadway, repo: "hexpm", optional: false]}, {:brod, "~> 3.16", [hex: :brod, repo: "hexpm", optional: false]}], "hexpm", "0afed1b15badc9b3262da6bc0c1ad9a97d468bf692ab96780d1dfdcdff101e67"},
+  "broadway_kafka": {:hex, :broadway_kafka, "0.4.4", "ebcaa4b2495c672f459bd8ea12b81ae64dfcfd12ec0a77ef65779e35bffd48e0", [:mix], [{:broadway, "~> 1.0", [hex: :broadway, repo: "hexpm", optional: false]}, {:brod, "~> 3.16 or ~> 4.0", [hex: :brod, repo: "hexpm", optional: false]}, {:telemetry, "~> 0.4.3 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "c595b6d6b6d1eac6bb291b151ad92f7a1a101ec8af173f282a0d4fd8fa88b253"},
   "brod": {:hex, :brod, "3.16.4", "8d941d489b9a0de26acf8b2bb800fa22751606221ed3ef52534a582c6c265336", [:rebar3], [{:kafka_protocol, "4.1.0", [hex: :kafka_protocol, repo: "hexpm", optional: false]}, {:snappyer, "1.2.8", [hex: :snappyer, repo: "hexpm", optional: false]}, {:supervisor3, "1.1.11", [hex: :supervisor3, repo: "hexpm", optional: false]}], "hexpm", "872ceaff5c2f99234e744e57580ed5f5dfbea29fe0b1387505a8dcb6cf2812b1"},
   "crc32cer": {:hex, :crc32cer, "0.1.8", "c6c2275c5fb60a95f4935d414f30b50ee9cfed494081c9b36ebb02edfc2f48db", [:rebar3], [], "hexpm", "251499085482920deb6c9b7aadabf9fb4c432f96add97ab42aee4501e5b6f591"},
   "gen_stage": {:hex, :gen_stage, "1.1.2", "b1656cd4ba431ed02c5656fe10cb5423820847113a07218da68eae5d6a260c23", [:mix], [], "hexpm", "9e39af23140f704e2b07a3e29d8f05fd21c2aaf4088ff43cb82be4b9e3148d02"},