nananatsu / emqx_plugin_kafka Goto Github PK

可以像这样吗？

2024-04-01T02:49:54.525876+00:00 [error] input-config:, #{'$hcMeta' =>, #{filename =>, "/opt/emqx/plugins/emqx_plugin_kafka-1.0.1/emqx_plugin_kafka-5.0.0/priv/config.hocon", line => 61}, '$hcTyp' => array, '$hcVal' =>, [#{'$hcMeta' =>, #{filename =>, "/opt/emqx/plugins/emqx_plugin_kafka-1.0.1/emqx_plugin_kafka-5.0.0/priv/config.hocon", line => 72}, '$hcTyp' => object, '$hcVal' =>, #{<<"filter">> =>, #{'$hcMeta' =>, #{filename =>, "/opt/emqx/plugins/emqx_plugin_kafka-1.0.1/emqx_plugin_kafka-5.0.0/priv/config.hocon", line => 66}, '$hcTyp' => string,'$hcVal' => <<"test/#">>}, <<"hook">> =>, #{'$hcMeta' =>, #{filename =>, "/opt/emqx/plugins/emqx_plugin_kafka-1.0.1/emqx_plugin_kafka-5.0.0/priv/config.hocon", line => 64}, '$hcTyp' => string,'$hcVal' => <<"message.publish">>}, <<"key">> =>, #{'$hcMeta' =>, #{filename =>, "/opt/emqx/plugins/emqx_plugin_kafka-1.0.1/emqx_plugin_kafka-5.0.0/priv/config.hocon", line => 70}, '$hcTyp' => string,'$hcVal' => <<"${topic}">>}, <<"topic">> =>, #{'$hcMeta' =>, #{filename =>, "/opt/emqx/plugins/emqx_plugin_kafka-1.0.1/emqx_plugin_kafka-5.0.0/priv/config.hocon", line => 68}, '$hcTyp' => string,'$hcVal' => <<"test">>}, <<"value">> =>, #{'$hcMeta' =>, #{filename =>, "/opt/emqx/plugins/emqx_plugin_kafka-1.0.1/emqx_plugin_kafka-5.0.0/priv/config.hocon", line => 72}, '$hcTyp' => string, '$hcVal' =>, <<"{ "topic" : "${topic}", "payload" : "${payload}", "ts" : "${ts}" }">>}}}]}, #{exception => function_clause,field => <<"hook">>,path => "kafka", reason => failed_to_check_field}, mfa: undefined
2024-04-01T02:49:54.526148+00:00 [error] crasher: initial call: application_master:init/4, pid: <0.3294.0>, registered_name: [], exit: {{bad_return,{{emqx_plugin_kafka_app,start,[normal,[]]},{'EXIT',{#{exception => function_clause,field => <<"hook">>,path => "kafka",reason => failed_to_check_field},[{hocon_schema,field_schema,[{union,[{ref,emqx_plugin_kafka_schema,hook}]},default],[]},{hocon_tconf,resolve_field_value,3,[{file,"hocon_tconf.erl"},{line,816}]},{hocon_tconf,map_one_field_non_hidden,4,[{file,"hocon_tconf.erl"},{line,490}]},{hocon_tconf,do_map_array,5,[{file,"hocon_tconf.erl"},{line,801}]},{hocon_tconf,'-map_field/4-fun-4-',4,[{file,"hocon_tconf.erl"},{line,622}]},{hocon_tconf,map_one_field_non_hidden,4,[{file,"hocon_tconf.erl"},{line,492}]},{hocon_tconf,map_fields_cont,4,[{file,"hocon_tconf.erl"},{line,431}]},{hocon_tconf,map_one_field_non_hidden,4,[{file,"hocon_tconf.erl"},{line,492}]},{hocon_tconf,map_fields_cont,4,[{file,"hocon_tconf.erl"},{line,431}]},{hocon_tconf,map,4,[{file,"hocon_tconf.erl"},{line,301}]},{hocon_tconf,map_translate,3,[{file,"hocon_tconf.erl"},{line,99}]},{hocon_tconf,generate,3,[{file,"hocon_tconf.erl"},{line,93}]},{emqx_plugin_kafka_app,load_config,1,[{file,"/emqx_plugin/kafka/src/emqx_plugin_kafka_app.erl"},{line,75}]},{emqx_plugin_kafka_app,start,2,[{file,"/emqx_plugin/kafka/src/emqx_plugin_kafka_app.erl"},{line,39}]},{application_master,start_it_old,4,[{file,"application_master.erl"},{line,293}]}]}}}},[{application_master,init,4,[{file,"application_master.erl"},{line,142}]},{proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,240}]}]}, ancestors: [<0.3293.0>], message_queue_len: 1, messages: [{'EXIT',<0.3295.0>,normal}], links: [<0.3293.0>,<0.2009.0>], dictionary: [], trap_exit: true, status: running, heap_size: 610, stack_size: 28, reductions: 187; neighbours:
2024-04-01T02:49:54.535541+00:00 [alert] msg: failed_to_start_plugin, mfa: emqx_plugins:ensure_started/1(368), reason: #{app => emqx_plugin_kafka,err_app => emqx_plugin_kafka,error => "failed_to_start_plugin_app",reason => {bad_return,{{emqx_plugin_kafka_app,start,[normal,[]]},{'EXIT',{#{exception => function_clause,field => <<"hook">>,path => "kafka",reason => failed_to_check_field},[{hocon_schema,field_schema,[{union,[{ref,emqx_plugin_kafka_schema,hook}]},default],[]},{hocon_tconf,resolve_field_value,3,[{file,"hocon_tconf.erl"},{line,816}]},{hocon_tconf,map_one_field_non_hidden,4,[{file,"hocon_tconf.erl"},{line,490}]},{hocon_tconf,do_map_array,5,[{file,"hocon_tconf.erl"},{line,801}]},{hocon_tconf,'-map_field/4-fun-4-',4,[{file,"hocon_tconf.erl"},{line,622}]},{hocon_tconf,map_one_field_non_hidden,4,[{file,"hocon_tconf.erl"},{line,492}]},{hocon_tconf,map_fields_cont,4,[{file,"hocon_tconf.erl"},{line,431}]},{hocon_tconf,map_one_field_non_hidden,4,[{file,"hocon_tconf.erl"},{line,492}]},{hocon_tconf,map_fields_cont,4,[{file,"hocon_tconf.erl"},{line,431}]},{hocon_tconf,map,4,[{file,"hocon_tconf.erl"},{line,301}]},{hocon_tconf,map_translate,3,[{file,"hocon_tconf.erl"},{line,99}]},{hocon_tconf,generate,3,[{file,"hocon_tconf.erl"},{line,93}]},{emqx_plugin_kafka_app,load_config,1,[{file,"/emqx_plugin/kafka/src/emqx_plugin_kafka_app.erl"},{line,75}]},{emqx_plugin_kafka_app,start,2,[{file,"/emqx_plugin/kafka/src/emqx_plugin_kafka_app.erl"},{line,39}]},{application_master,start_it_old,4,[{file,"application_master.erl"},{line,293}]}]}}}}}

用的是EMQX5.0.11 版本

配置文件和代码中的 priv/config.hocon.example 一致，并放入到 /opt/emqx/etc/emqx_plugin_kafka.conf， 期待大佬回复！

请问支持emqx5.0版本吗？