소스 검색

fix: dialyzer

zmstone 1 년 전
부모
커밋
b3fe971228
1개의 변경된 파일1개의 추가작업 그리고 0개의 파일을 삭제
  1. 1 0
      apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_consumer.erl

+ 1 - 0
apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_consumer.erl

@@ -54,6 +54,7 @@
     group_id => binary(),
     group_id => binary(),
     key_encoding_mode := encoding_mode(),
     key_encoding_mode := encoding_mode(),
     max_batch_bytes := emqx_schema:bytesize(),
     max_batch_bytes := emqx_schema:bytesize(),
+    max_wait_time := non_neg_integer(),
     max_rejoin_attempts := non_neg_integer(),
     max_rejoin_attempts := non_neg_integer(),
     offset_commit_interval_seconds := pos_integer(),
     offset_commit_interval_seconds := pos_integer(),
     offset_reset_policy := offset_reset_policy(),
     offset_reset_policy := offset_reset_policy(),