allow partition to be nil in KafkaEx.Protocol.Produce.Request
MODIFY
lib/kafka_ex/protocol/produce.ex
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,

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