allow partition to be nil in KafkaEx.Protocol.Produce.Request

kafkaex · Jun 3, 2019 · e1e4872 · e1e4872
1 parent aa1ab28
commit e1e4872
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/kafka_ex/protocol/produce.ex b/lib/kafka_ex/protocol/produce.ex
@@ -31,7 +31,7 @@ defmodule KafkaEx.Protocol.Produce do
 
     @type t :: %Request{
             topic: binary,
-            partition: integer,
+            partition: integer | nil,
             required_acks: integer,
             timeout: integer,
             compression: atom,