diff --git a/lib/kafka_ex/new/protocols/kayrock/describe_groups.ex b/lib/kafka_ex/new/protocols/kayrock/describe_groups.ex index 7fce8dc3..3b5f00c1 100644 --- a/lib/kafka_ex/new/protocols/kayrock/describe_groups.ex +++ b/lib/kafka_ex/new/protocols/kayrock/describe_groups.ex @@ -1,4 +1,4 @@ -defprotocol KafkaEx.New.Protocols.Kayrock.DescribeGroups do +defmodule KafkaEx.New.Protocols.Kayrock.DescribeGroups do @moduledoc """ This module handles Describe Groups request & response parsing. Request is built using Kayrock protocol, response is parsed to diff --git a/lib/kafka_ex/new/protocols/kayrock/list_offsets.ex b/lib/kafka_ex/new/protocols/kayrock/list_offsets.ex index 5b0120e5..f3c4613d 100644 --- a/lib/kafka_ex/new/protocols/kayrock/list_offsets.ex +++ b/lib/kafka_ex/new/protocols/kayrock/list_offsets.ex @@ -1,4 +1,4 @@ -defprotocol KafkaEx.New.Protocols.Kayrock.ListOffsets do +defmodule KafkaEx.New.Protocols.Kayrock.ListOffsets do @moduledoc """ This module handles List Offsets request & response parsing. Request is built using Kayrock protocol, response is parsed to