search

dashbitco / broadway_kafka

A Broadway connector for Kafka
233 stars 53 forks source link

fix: no case clause maching error timeout #115

Closed yordis closed 2 years ago

yordis commented 2 years ago

A fix for the following:

CaseClauseError: no case clause matching: {:error, :timeout}
  File "lib/broadway_kafka/brod_client.ex", line 137, in BroadwayKafka.BrodClient.resolve_offset/5
  File "lib/broadway_kafka/producer.ex", line 356, in anonymous fn/3 in BroadwayKafka.Producer.handle_info/2
  File "lib/enum.ex", line 1593, in Enum."-map/2-lists^map/1-0-"/2
  File "lib/enum.ex", line 1593, in Enum."-map/2-lists^map/1-0-"/2
  File "lib/broadway_kafka/producer.ex", line 346, in BroadwayKafka.Producer.handle_info/2
  File "lib/broadway/topology/producer_stage.ex", line 229, in Broadway.Topology.ProducerStage.handle_info/2
  File "lib/gen_stage.ex", line 2117, in GenStage.noreply_callback/3
  File "gen_server.erl", line 695, in :gen_server.try_dispatch/4
josevalim commented 2 years ago

:green_heart: :blue_heart: :purple_heart: :yellow_heart: :heart: