Fix spec errors

kafkaex · Jun 3, 2019 · aa1ab28 · aa1ab28
1 parent 7f7cc7a
commit aa1ab28
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/lib/kafka_ex.ex b/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

diff --git a/lib/kafka_ex/protocol/create_topics.ex b/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

diff --git a/lib/kafka_ex/protocol/delete_topics.ex b/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

diff --git a/lib/kafka_ex/server.ex b/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