diff --git a/apps/emqx_bridge_azure_event_hub/rebar.config b/apps/emqx_bridge_azure_event_hub/rebar.config index 55928485702..b2357a21cda 100644 --- a/apps/emqx_bridge_azure_event_hub/rebar.config +++ b/apps/emqx_bridge_azure_event_hub/rebar.config @@ -2,7 +2,7 @@ {erl_opts, [debug_info]}. {deps, [ - {wolff, "4.0.5"}, + {wolff, "4.0.6"}, {kafka_protocol, "4.1.10"}, {brod_gssapi, "0.1.3"}, {brod, "4.3.1"}, diff --git a/apps/emqx_bridge_confluent/rebar.config b/apps/emqx_bridge_confluent/rebar.config index c909be20b51..9b9e3df721d 100644 --- a/apps/emqx_bridge_confluent/rebar.config +++ b/apps/emqx_bridge_confluent/rebar.config @@ -2,7 +2,7 @@ {erl_opts, [debug_info]}. {deps, [ - {wolff, "4.0.5"}, + {wolff, "4.0.6"}, {kafka_protocol, "4.1.10"}, {brod_gssapi, "0.1.3"}, {brod, "4.3.1"}, diff --git a/apps/emqx_bridge_kafka/rebar.config b/apps/emqx_bridge_kafka/rebar.config index 8c68bc163ba..9f185726888 100644 --- a/apps/emqx_bridge_kafka/rebar.config +++ b/apps/emqx_bridge_kafka/rebar.config @@ -2,7 +2,7 @@ {erl_opts, [debug_info]}. {deps, [ - {wolff, "4.0.5"}, + {wolff, "4.0.6"}, {kafka_protocol, "4.1.10"}, {brod_gssapi, "0.1.3"}, {brod, "4.3.1"}, diff --git a/changes/ee/fix-14631.en.md b/changes/ee/fix-14631.en.md new file mode 100644 index 00000000000..2c09db6ef8a --- /dev/null +++ b/changes/ee/fix-14631.en.md @@ -0,0 +1 @@ +Now, when enabling Memory Overload Protection in Kafka / Azure Event Hub / Confluent Producer Actions, buffered data will be dropped more aggressively when the system reaches the high memory watermark, reducing the risk of reaching out of memory state. diff --git a/mix.exs b/mix.exs index 20f3f6d8cde..fd80b5b0546 100644 --- a/mix.exs +++ b/mix.exs @@ -206,7 +206,7 @@ defmodule EMQXUmbrella.MixProject do def common_dep(:cowboy), do: {:cowboy, github: "emqx/cowboy", tag: "2.9.2", override: true} def common_dep(:jsone), do: {:jsone, github: "emqx/jsone", tag: "1.7.1", override: true} def common_dep(:ecpool), do: {:ecpool, github: "emqx/ecpool", tag: "0.6.1", override: true} - def common_dep(:replayq), do: {:replayq, github: "emqx/replayq", tag: "0.3.10", override: true} + def common_dep(:replayq), do: {:replayq, github: "emqx/replayq", tag: "0.3.12", override: true} def common_dep(:jsx), do: {:jsx, github: "talentdeficit/jsx", tag: "v3.1.0", override: true} # in conflict by emqtt and hocon def common_dep(:getopt), do: {:getopt, "1.0.2", override: true} @@ -275,7 +275,7 @@ defmodule EMQXUmbrella.MixProject do def common_dep(:influxdb), do: {:influxdb, github: "emqx/influxdb-client-erl", tag: "1.1.13", override: true} - def common_dep(:wolff), do: {:wolff, "4.0.5"} + def common_dep(:wolff), do: {:wolff, "4.0.6"} def common_dep(:brod_gssapi), do: {:brod_gssapi, "0.1.3"} def common_dep(:kafka_protocol), diff --git a/rebar.config b/rebar.config index a751cf37c55..e8fd5fabc21 100644 --- a/rebar.config +++ b/rebar.config @@ -88,7 +88,7 @@ {grpc, {git, "https://github.com/emqx/grpc-erl", {tag, "0.6.12"}}}, {minirest, {git, "https://github.com/emqx/minirest", {tag, "1.4.4"}}}, {ecpool, {git, "https://github.com/emqx/ecpool", {tag, "0.6.1"}}}, - {replayq, {git, "https://github.com/emqx/replayq.git", {tag, "0.3.10"}}}, + {replayq, {git, "https://github.com/emqx/replayq.git", {tag, "0.3.12"}}}, {emqtt, {git, "https://github.com/emqx/emqtt", {tag, "1.13.5"}}}, {rulesql, {git, "https://github.com/emqx/rulesql", {tag, "0.2.1"}}}, % NOTE: depends on recon 2.5.x