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

**URL:** <https://discuss.elastic.co/t/how-to-implement-data-stream-splitting-for-multiple-types-in-logstashs-java-plugin/330569>\
**Category:** Logstash\
**Created:** [April 23, 2023, 2:32am UTC](https://discuss.elastic.co/t/how-to-implement-data-stream-splitting-for-multiple-types-in-logstashs-java-plugin/330569 "2023-04-23T02:32:42Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![woxinfeishi](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/woxinfeishi/32/120103_2.png) [@woxinfeishi](https://discuss.elastic.co/u/woxinfeishi)\
**Post date:** [April 23, 2023, 2:32am UTC](https://discuss.elastic.co/t/how-to-implement-data-stream-splitting-for-multiple-types-in-logstashs-java-plugin/330569/1 "2023-04-23T02:32:42Z")

</div>

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?

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [May 21, 2023, 2:33am UTC](https://discuss.elastic.co/t/how-to-implement-data-stream-splitting-for-multiple-types-in-logstashs-java-plugin/330569/2 "2023-05-21T02:33:22Z")

</div>

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