你好，我收集java日志，logstash开启多线程乱序了，请问如何解决？
kafka的消息日志是这样的
# Topic:test1
{"id":27228,"taskId":24259,"subTaskId":27443,"idx":0,"dataId":171189,"bizCode":"xp","workFlowTopic":"cs-test-xp-ab","csTopic":"cs-test-back-msg","appId":"v2zcc7dcrkvnydebbt868hfbs8jimjbj","tenantId":null,"taskInfoLocation":"{\"bucketName\":\"ab-test\",\"location\":\"task/xp/22273/task.json\"}","sourceType":"ab","dispatchParam":"{\"seqId\":\"3721211111269333272\",\"testBucketName\":\"test-data\",\"url\":null}"}
# Topic:test2
{"servicelog":"2025-04-29T11:01:26.354699559+08:00 stdout F 2025-04-29 03:01:26.354 [] [http-nio-9999-exec-8] |INFO|com.test.common.log.BaseLogAspect - Aspect: execution(int com.test.cs.aaa.application.TestService.testLog(int,int)) use time: 0 ms, the args are: [5,6], the result is: 1","kubernetes":{"container_name":"service-ab-cs-aaaa","namespace_name":"cs","pod_name":"aaaaaaaaaaaaaaa","pod_id":"e75c52b9-11111111-42a6-9387-1111111111111","host":"10.21.3.15","labels":{"app":"1111111111","pod-hash":"111111c5f","project":"ab"}},"message":null,"source":"test-log"}
# Topic:test3
{"msgType": "updateState", "id": 9923, "taskId": 2345, "subTaskId": 8842, "dataId": 123567, "bizCode": "xp", "data": "TESTESSING"}
请问如何解决INPUT多种不同的消息，开启多线程不乱序，感谢大佬！这对我很有帮助
