diff --git a/apps/emqx_bridge_kinesis/src/emqx_bridge_kinesis.erl b/apps/emqx_bridge_kinesis/src/emqx_bridge_kinesis.erl index 40849a29d..ddba5a10d 100644 --- a/apps/emqx_bridge_kinesis/src/emqx_bridge_kinesis.erl +++ b/apps/emqx_bridge_kinesis/src/emqx_bridge_kinesis.erl @@ -166,7 +166,7 @@ fields(producer) -> )}, {partition_key, sc( - binary(), + emqx_schema:template(), #{ required => true, desc => ?DESC("partition_key")