How to implement data stream splitting for multiple types in Logstash's Java plugin?

When using the logstash-input-rabbitmq plugin, multiple service logs can be collected by specifying different types in the same Logstash configuration file. Now I want to implement a Java version of the Logstash-input-rocketmq plugin myself. How should I do it to support multiple types?

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.