Fix msg_input type spec

kafka4beam · Mar 14, 2019 · e9ed3ac · e9ed3ac
1 parent 19438ae
commit e9ed3ac
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/brod.erl b/src/brod.erl
@@ -168,8 +168,8 @@
 -type value() :: undefined %% no value, transformed to <<>>
                | iodata() %% single value
                | {msg_ts(), binary()} %% one message with timestamp
-               | ?KV(key(), value()) %% backward compatible
-               | ?TKV(msg_ts(), key(), value()) %% backward compatible
+               | [?KV(key(), value())] %% backward compatible
+               | [?TKV(msg_ts(), key(), value())] %% backward compatible
                | kpro:msg_input() %% one magic v2 message
                | kpro:batch_input(). %% maybe nested batch