В настоящее время я использую @StreamListener для входящих сообщений один за другим, а затем обрабатываю их в нашем классе обслуживания, чтобы сохранить его в БД.
Вместо этого я хочу одновременно входить в список сообщений (скажем, 100), а затем обрабатывать его, чтобы сохранить все эти 100 сообщений одновременно, чтобы избежать повторных вызовов в БД.
Как этого добиться, используя @StreamListener.