-
Notifications
You must be signed in to change notification settings - Fork 64
Open
Description
i was in kaffe version 1.26.0 and once i upgraded to 1.27.0 i started getting the following error, i already changed the consumers config to the new format
config :kaffe,
consumers: %{
"etl_consumer" => [
endpoints: [{"XYZ", 9092}],
topics: ["events-prod"],
consumer_group: "etl-prod-v1",
start_with_earliest_message: true,
message_handler: Etl.KafkaConsumer,
worker_allocation_strategy: :worker_per_topic_partition,
max_bytes: 250_000_000,
min_bytes: 10_000_000,
max_wait_time: 2_000,
rebalance_delay_ms: 30_000,
offset_reset_policy: :reset_to_earliest,
ssl: true
]
}and app config to
%{
id: Kaffe.GroupMemberSupervisor.EtlConsumer,
start: {Kaffe.GroupMemberSupervisor, :start_link, ["etl_consumer"]},
type: :supervisor
}Error
raise/1 and reraise/2 expect a module name, string or exception as the first
argument, got: {:error, {{{:badmatch, {:error, :timeout}}, [{Kaffe.GroupMember,
:init, 1, [file: ~c"lib/kaffe/consumer_group/subscriber/group_member.ex", line:
82]}, {:gen_server, :init_it, 2, [file: ~c"gen_server.erl", line: 2229]},
{:gen_server, :init_it, 6, [file: ~c"gen_server.erl", line: 2184]}, {:proc_lib,
:init_p_do_apply, 3, [file: ~c"proc_lib.erl", line: 329]}]}, {:child, :undefined,
:"group_member_etl_consumer_staging-events", {Kaffe.GroupMember, :start_link,
[:etl_consumer, "etl-staging", #PID<0.3080.0>, "staging-events", %{max_bytes:
1000000, topics: ["staging-events"], max_wait_time: 30000, min_bytes: 0,
offset_reset_policy: :reset_to_earliest, group_config: [offset_commit_policy:
:commit_to_kafka_v2, offset_commit_interval_seconds: 5], consumer_config:
[auto_start_producers: false, allow_topic_auto_creation: false, begin_offset:
:earliest, ssl: true], endpoints: [{~c"pkc-4kgmg.us-west-2.aws.confluent.cloud",
9092}], async_message_ack: false, client_down_retry_expire: 30000,
subscriber_name: :etl_consumer, consumer_group: "etl-staging",
message_handler: Etl.KafkaConsumer, rebalance_delay_ms: 30000,
subscriber_retries: 5, subscriber_retry_delay_ms: 5000,
worker_allocation_strategy: :worker_per_topic_partition}]}, :permanent, false,
5000, :worker, [Kaffe.GroupMember]}}}
Metadata
Metadata
Assignees
Labels
No labels