Fix spec errors
MODIFY
lib/kafka_ex.ex
lib/kafka_ex.ex
@@ -22,7 +22,7 @@ defmodule KafkaEx do
alias KafkaEx.Protocol.Produce.Message
alias KafkaEx.Protocol.SyncGroup.Request, as: SyncGroupRequest
alias KafkaEx.Protocol.SyncGroup.Response, as: SyncGroupResponse
- alias KafkaEx.Protocol.CreateTopics.Request, as: CreateTopicsRequest
+ alias KafkaEx.Protocol.CreateTopics.TopicRequest, as: CreateTopicsRequest
alias KafkaEx.Protocol.CreateTopics.Response, as: CreateTopicsResponse
alias KafkaEx.Protocol.DeleteTopics.Response, as: DeleteTopicsResponse
alias KafkaEx.Protocol.ApiVersions.Response, as: ApiVersionsResponse

MODIFY
lib/kafka_ex/protocol/create_topics.ex
lib/kafka_ex/protocol/create_topics.ex
@@ -46,15 +46,15 @@ defmodule KafkaEx.Protocol.CreateTopics do
topic: binary,
num_partitions: integer,
replication_factor: integer,
- replica_assignment: [ReplicaAssignment],
- config_entries: [ConfigEntry]
+ replica_assignment: [ReplicaAssignment.t()],
+ config_entries: [ConfigEntry.t()]
}
end
defmodule Request do
@moduledoc false
defstruct create_topic_requests: nil, timeout: nil
- @type t :: %Request{create_topic_requests: [TopicRequest], timeout: integer}
+ @type t :: %Request{create_topic_requests: [TopicRequest.t()], timeout: integer}
end
defmodule TopicError do
@@ -66,7 +66,7 @@ defmodule KafkaEx.Protocol.CreateTopics do
defmodule Response do
@moduledoc false
defstruct topic_errors: nil
- @type t :: %Response{topic_errors: [TopicError]}
+ @type t :: %Response{topic_errors: [TopicError.t()]}
end
def api_version(api_versions) do

MODIFY
lib/kafka_ex/protocol/delete_topics.ex
lib/kafka_ex/protocol/delete_topics.ex
@@ -33,7 +33,7 @@ defmodule KafkaEx.Protocol.DeleteTopics do
defmodule Response do
@moduledoc false
defstruct topic_errors: nil
- @type t :: %Response{topic_errors: [TopicError]}
+ @type t :: %Response{topic_errors: [TopicError.t()]}
end
def api_version(api_versions) do

MODIFY
lib/kafka_ex/server.ex
lib/kafka_ex/server.ex
@@ -17,7 +17,7 @@ defmodule KafkaEx.Server do
alias KafkaEx.Protocol.Produce
alias KafkaEx.Protocol.Produce.Request, as: ProduceRequest
alias KafkaEx.Protocol.SyncGroup.Request, as: SyncGroupRequest
- alias KafkaEx.Protocol.CreateTopics.Request, as: CreateTopicsRequest
+ alias KafkaEx.Protocol.CreateTopics.TopicRequest, as: CreateTopicsRequest
alias KafkaEx.Socket
defmodule State do

Fix spec errors