once more testing

stordco · Dec 10, 2024 · 55ba7f7 · 55ba7f7
1 parent 7560c0a
commit 55ba7f7
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/lib/kafee/consumer/broadway_adapter.ex b/lib/kafee/consumer/broadway_adapter.ex
@@ -288,8 +288,12 @@ defmodule Kafee.Consumer.BroadwayAdapter do
     # function above because `Kafee.Consumer.Adapter.push_message/2` will catch any
     # errors.
 
-    error = %RuntimeError{message: "Error converting a Broadway message to Kafee.Consumer.Message"}
-    messages |> List.wrap() |> Enum.each(&consumer.handle_failure(error, &1))
+    messages
+    |> List.wrap()
+    |> Enum.each(fn message ->
+      error = %RuntimeError{message: "Error occurred processing a message - #{inspect(message.status)}"}
+      consumer.handle_failure(error, message)
+    end)
 
     messages
   end

diff --git a/test/kafee/consumer/broadway_adapter_integration_test.exs b/test/kafee/consumer/broadway_adapter_integration_test.exs
@@ -130,7 +130,9 @@ defmodule Kafee.Consumer.BroadwayAdapterIntegrationTest do
 
       assert_receive message
       IO.inspect(message)
-      assert_receive {:error_reason, "%RuntimeError{message: \"Error handling a message for key-fail-2\"}"}
+
+      assert_receive {:error_reason,
+                      "%RuntimeError{message: \"Error converting a Broadway message to Kafee.Consumer.Message\"}"}
     end
   end
 end