I am sending data to kafka through fluentd config as below

I am accumulating logs of data that failed to be transmitted through secondary_file.

I followed the method you guided for retransmission, but only the phrase "Input must be a map (got Array)" is displayed.

Which part did I make a mistake?

====How i used flunetd-cat====
cat /home/temp/eventqueue.log.0 | fluent-cat --format msgpack --host 127.0.0.1 --port 24224 tag

=====my fluentd config======